生產消息 

在本配方中, 我們將學習了如何將消息發送到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).