1.Hello World#前山翻译

2017-08-15 本文已影响26人前山饭店

注：这是RabbitMQ-java版Client的指导教程翻译系列文章，欢迎大家批评指正
第一篇Hello Word了解RabbitMQ的基本用法
第二篇Work Queues介绍队列的使用
第三篇Publish/Subscribe介绍转换器以及其中fanout类型
第四篇Routing介绍direct类型转换器
第五篇Topics介绍topic类型转换器
第六篇RPC介绍远程调用

预备条件
这篇指导教程的前提是已经下载了RabbitMQ并且运行在本机上默认端口号5672。如果你使用不同的主机，端口号或者相关认证，连接设置需要做一些调整。
寻求帮助
如果你在阅读这个系列指导教程时有任何的问题，可以通过邮件联系我们。

介绍（Introduction）

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

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

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

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

producer.png

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

queue.png
消费和接受有着同样的意思，一个应用常在等待接受消息就是消费者：

consumer.png
注解：生产者，消费者以及消息中间件并不会存在于同一个主机上，且大部分应用确实也不会这样做。

"Hello World"

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

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

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

java_one.png

MabbitMQ的java版本客户端的依赖包(The Java Client library)
RabbitMQ支持多种协议，这篇指导教程中使用AMQP协议，这是一个开源，多用途的消息传递协议。针对不同的语言，RabbitMQ提供专门的客户端版本，目前我们使用的是Java版本。
下载Java Client library并且依赖于SLF4J API和SLF4J Simple，拷贝这些文件到你的工作目录下，跟其它的java文件一块放。
请注意SLF4J Simple只是在指导教程中使用，而在真正的生产项目中，应该使用更强大的日志包，像Logback。
现在我们有了Java版本的客户端RabbitMQ和依赖包，可以写些代码了。

发送（Sending）

sending.png

我们将称消息发布者（发送者）为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();

这里是Send.java的源码(这么简答的代码，不想贴)

发送失败

如果这是你第一次使用RabbitMQ，并且你没有看到发送的消息，可能伤脑筋了：哪里出了问题？可能是消息中间件开始的时候可用硬盘空间不足（默认的至少剩余200MB），因此会拒绝接收消息。查看消息中间件的日志文件和如果有必要的话减少这些限制。这篇配置文档将会告诉你如何去设置硬盘剩余空间的限制。

接受（Receiving）

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

receiving.png

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去停止运行），因此可以尝试从另外一个终端来运行生产者。

第一节的内容大致翻译完了，这里是原文的链接。接着进入下一节：Work Queues。

终篇是我对RabbitMQ使用理解的总结文章，欢迎讨教。
--谢谢--