注：这是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使用理解的总结文章，欢迎讨教。
--谢谢--
网友评论