1.Hello World#前山翻译

介绍（Introduction）

RabbitMQ是一个消息中间件：它接受并转发消息。你可以把它看成是一个邮局：当你把想投递的邮件放在邮箱中时，知道邮递员终会把邮件派送给收件人。这个比喻中，RabbitMQ是邮箱，邮局和邮递员。

RabbitMQ和邮局之间最大的不同是前者不需要处理纸张，就可以接受，存储并且传发二进制数据的消息。

通常，RabbitMQ和消息传送会有一些专业术语。

生产和发送的意义是一样的，一个应用发送消息就是生产者：

队列类似邮局中的邮箱存在于RabbitMQ中，尽管消息是在RabbitMQ和应用间传送，但消息只存储在队列中。队列的大小只受限于主机的内存或者硬盘的大小，本质上是有无限大的缓存区间。许多生产者可以发送消息到一个队列中，当然需要消费者也可以从一个队列中接受消息。我们用下列图形代表队列：

"Hello World"

（using the java Client ,我是搞Android开发的，所以语言没得选：java是当今世界上最流行的语言）

在这篇指导教程中，我们将用Java写两个应用，发送一条简单消息的生产者，和接受消息并且将消息打印出来的消费者。我们将会省略掉部分Java API的具体细节，专注于开始学习最简单的"Hello World"消息传递。

在下面的图表中，"P"表示生产者和"C"表示消费者，中间的盒子表示队列-消费者的消息缓存在RabbitMQ中。

发送（Sending）

我们将称消息发布者（发送者）为Send，消息消费者(接受者)为Recv。发布者将会连接上服务端RabbitMQ，发送一条简单的消息，然后退出。

在Send.java中，我们需要引入一些类：

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

创建类并且给队列命名：

public class Send {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv)  throws java.io.IOException {

      ...

    }

}

接着我们连接服务端：

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");  //factory可以设置主机Ip，端口号，认证信息等连接服务端

Connection connection = factory.newConnection();  //创建连接

Channel channel = connection.createChannel();  //创建通道

这是抽象的Socket（套接宇）连接方式，注意协议版本的差异和验证等等都取决于我们自己。我们连接到本机的RabbitMQ上，所以才是localhost。如果我们想连接到不同的机器上的RabbitMQ上，可以简单说明该机器的名称和IP地址。（下面代码是我擅自添加的）

factory.setPort(8080);

factory.setUsername("admin");

factory.setPassword("password"):

下一步创建通道（channel）,大部分的事情都是在这里处理。

我们必须先声明发送消息去的队列，然后发送消息到队列中：

channel.queueDeclare(QUEUE_NAME, false, false, false, null);

String message = "Hello World!";

channel.basicPublish("", QUEUE_NAME, null, message.getBytes());

System.out.println(" [x] Sent '" + message + "'");

声明队列是很重要的，它不存在时才会被创建，消息体是字节数组类型，因此可以在这里编码你需要的类型。
最后，关闭通道和连接：

channel.close();
connection.close();

发送失败

接受（Receiving）

发布者相对应的就是我们的接受者，接受者是接受从RabbitMQ推送过来的消息，而不像发布者是发布消息到RabbitMQ中。我们设置了对消息的监听，并且打印出消息：

Recv.java的引入类和Send.java有三个是一样的：

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Consumer;

import com.rabbitmq.client.DefaultConsumer;

这个额外的DefaultConsumer是一个实现了Consumer接口的类，我们用来缓存由服务端推送给接受者的消息。

和发布者开始的创建是类似的，打开连接(connection)和通道（channel）,并且声明一条可以消费消息的队列。注意这个队列是匹配send发布消息的队列：

public class Recv {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv)  throws  java.io.IOException,  java.lang.InterruptedException {

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");

        Connection connection = factory.newConnection();

        Channel channel = connection.createChannel();

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

        ...

    }

}

请注意消费者也声明了队列，因为我们可以在创建发布者之前先创建消费者。我们像确保这些队列已经存在了，然后就可以从队列中消费消息。

将要告诉 服务端要从队列中分发消费者的消息，然后就会异步的推送消息给消费者。我们提供了一个callBack的表单对象用于缓存消息直到消费者已经获取到它们。这个就是DefaultConsumer子类的工作：

Consumer consumer = new DefaultConsumer(channel) {

    @Override

    public void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body)  throws IOException {

        String message = new String(body, "UTF-8");

        System.out.println(" [x] Received '" + message + "'");

   }

};

    channel.basicConsume(QUEUE_NAME, true, consumer);

综合

你可以在RabbitMQ java客户端编译这些类：

javac -cp amqp-client-4.0.2.jar Send.java Recv.java

在一个终端上运行消费者，你需要rabbitmq-client.jar和一些依赖：

java -cp .:amqp-client-4.0.2.jar:slf4j-api-1.7.21.jar:slf4j-simple-1.7.22.jar Recv

接着运行生产者：

java -cp .:amqp-client-4.0.2.jar:slf4j-api-1.7.21.jar:slf4j-simple-1.7.22.jar Send

在Windows系统上，使用分好代替冒号去分割每一个条目。
通过RabbitMQ，消费者将会打印出从生产者接受的消息，并且一直运行等待着接受消息（可以使用Ctrl +C去停止运行），因此可以尝试从另外一个终端来运行生产者。