生产消息 

在本配方中, 我们将学习了如何将消息发送到AMQP队列. 我们将介绍AMQP消息的构建块:消息,队列,以及交换器.你可以在Chapter01/Recipe02/src/rmqexample中找到代码.
w to do it…
在连接到中间件后, 像前面配方中看到的一样,你可以按下面的步骤来来发送消息:
1. 声明队列, 在 com.rabbitmq.client.Channel上调用queueDeclare()方法:
String myQueue = "myFirstQueue";
channel.queueDeclare(myQueue, true, false, false, null); //创建一个名为myFirstQueue,持久化的,非限制的,不自动删除的队列,
2. 发送第一个消息到RabbitMQ broker:
String message = "My message to myFirstQueue";
channel.basicPublish("",myQueue, null, message.getBytes());
3. 使用不同的选项发送第二个消息:
channel.basicPublish("",myQueue,MessageProperties.PERSISTENT_TEXT_PLAIN,message.getBytes());

注意:队列名称是大小写敏感的: MYFIRSTQUEUE与myFirstQueue是不同的.
如何工作

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

String messageIdentifier =properties.getCorrelationId();

String action = actions.get(messageIdentifier);

actions.remove(messageIdentifier);

String response = new String(body);

OnReply(action, response);

}

4. 调用channel.basicConsume()方法启动消息消费.

5. 准备和序列化请求(我们例子中是messageRequest).

6. 初始化一个任意的唯一消息标识符(messageIdentifier).

7. 当消费者收到相应回复的时候，定义应该做什么，通过使用messageIdentifier来绑定动作.在我们的例子中，我们通过调用我们自定义的方法 consumer.AddAction()来完成的.

8. 发布消息到请求队列,设置其属性:

BasicProperties props = new BasicProperties.Builder().correlationId(messageIdentifier)replyTo(replyQueue).build();

channel.basicPublish("", requestQueue,props,messageRequest.getBytes());

如何工作

在我们的例子中，RPC responder扮演的是RPC server的角色; responder会监听requestQueue公共队列(步骤1),这里放置了调用者的请求.

另一方面，每个调用者会在其私有队列上消费responder的回复信息(步骤5).当caller发送消息时(步骤11),它包含两个属性:一个是用于监听的临时回复队列 (replyTo())名称,另一个是消息标识(correlationId()),当回复消息时，用于标识caller.事实上,在我们的例子中，我们已经实现了一个异步的RPC caller. The action to be performed by the RpcCallerConsumer (step 6) when the reply comes back is recorded by the nonblocking consumer by calling AddAction() (step 10).