上篇講了RabbitMQ連接工廠的作用是用來創建RabbitMQ的連接，本篇就來講講RabbitMQ的發送消息。通過RabbitMQ發送消息最簡單的方式就是將connectionFactory Bean注入到服務層類中，并使用它創建Connection，使用這個Connection來創建Channel，再使用這個Channel發布消息到Exchange中。

當然Spring AMQP提供了RabbitTemplate來簡便我們的操作，消除RabbitMQ發送和接收消息相關的樣板代碼。使用RabbitTemplate也是先在配置文件中寫相關的配置，使用Rabbit命名空間的<template>元素，如下：

<template id="rabbitTemplate" connection-factory="connectionFactory">

現在要發送消息只需要將模板bean注入到服務層類中（這里以SendServiceImpl為例），并使用它來發送Spittle，使用RabbitTemplate來發送Spittle提醒，代碼如下：

public class SendServiceImpl implements SendService {private RabbitTemplate rabbit;@Autowiredpublic SendServiceImpl (RabbitTemplate rabbit) {this.rabbit = rabbit;}public void sendSpittle (Spittle spittle) {rabbit.convertAndSend("spittle.test.exchange", "spittle.test", spittle);}
}

上面代碼中sendSpittle()調用RabbitTemplate的convertAndSend()方法，傳入的三個參數分別是Exchange的名稱、routing key以及要發送的對象。
這里如果使用最簡單的只傳要發送的對象的重載方法，RabbitTemplate就使用默認的Exchange和routing key。按之前配置的話，這兩項默認都為空，也可以自行在<template>元素上借助exchange和routing-key屬性配置不同的默認值：

<template id="rabbitTemplate" connection-factory="connectionFactory"exchange="spittle.test.exchange" routing-key="spittle.test" />

此外RabbitTemplate還有其他方法可以用來發送消息，比如用send()方法來發送org.springframework.amqp.core.Message對象，如下所示：

Message message = new Message("Hello World".getBytes(), new MessageProperties());
rabbit.send("hello.exchange", "hello.routing", message);

使用send()方法的技巧在于構造要發送的Message對象，在上面的例子中，通過給定字符串的字節數組來構建Message實例。這里是字符串相對比較簡單，如果消息是復雜對象的話，則會比較復雜。也是因為這樣，所以一般會用convertAndSend()方法，它會自動將對象轉換為Message，不過它需要一個消息轉換器來幫助完成該任務，默認的轉換器是SimpleMessageConverter，它適用于String、Serializable實例和字節數組。

發送消息完后，接下來就是接收消息了。
在傳統JMS中有兩種從隊列獲取信息的方式，使用JmsTemplate的同步方式以及使用消息驅動pojo的異步方式。Spring AMQP也提供了類似的方式來獲取通過AMQP發送的消息。

使用RabbitTemplate來接收消息

RabbitTemplate提供的接收信息的方法中最簡單的就是receive()方法，通過該方法就可以從隊列中獲取一個Message對象：

Message message = rabbit.receive("spittle.test.queue");

或者也可以通過配置獲取消息的默認隊列，這是通過在配置模板的時候，設置queue屬性實現的：

<template id="rabbitTemplate" connection-factory="connectionFactory"exchange="spittle.test.exchange" routing-key="spittle.test" queue="spittle.test.queue" />

這樣的話，在調用receive()方法時，不需要設置任何參數就能從默認隊列中獲取消息：

Message message = rabbit.receive( );

獲取到Message對象后，一般需要將它的body屬性中的字節數組轉換為想要的對象，就像在發送的時候將領域對象轉換為Message一樣，將接收到的Message轉換為領域對象也很繁瑣。這里可以考慮使用RabbitTemplate的receiveAndConvert()方法作為替代方案：

Spittle spittle = (Spittle) rabbit.receiveAndConvert("spittle.test.queue");

receiveAndConvert()方法會使用與sendAndConvert()方法相同的消息轉換器，將Message對象轉換為原始的類型。
調用receive()和receiveAndConvert()方法都會立即返回，如果隊列中沒有等待的消息，將會得到null。這時一般需要程序員自己管理輪詢以及必要的線程，實現隊列監控。如果不想每次都同步輪詢等待消息到達，可以使用Spring AMQP提供的消息驅動pojo，下面就看看使用消息驅動pojo的方式來接收消息。

使用消息驅動pojo來接收消息

如果想要在消息驅動pojo中異步地消費使用Spittle對象，先要解決這個pojo本身，如下的SpittleTestHandler扮演了這個角色：

public class SpittleTestHandler {public void handleSpittleTest (Spittle spittle) {...}
}

其實這個類并沒有依賴于AMQP，不管通過什么機制傳遞過來Spittle對象，它都能夠處理。
這里還需要在Spring應用上下文中將SpittleTestHandler聲明為一個bean：

<bean id="spittleListener"class="com.***.spittr.test.SpittleTestHandler">

最后要聲明一個監聽器容器和監聽器，當消息到達的時候，能夠調用SpittleTestHandler，配置如下：

<listener-container connection-factory="connectionFactory"><listener ref="spittleListener" method="handleSpittleTest"queue-names="spittle.test.queue" />
</listener-container>

上面的<listener-container>與<listener>元素都來自rabbit命名空間。并通過queue-names屬性來指定要監聽的隊列，這里只設定了一個要監聽的隊列，如果要設置多個隊列的話，用逗號隔開。到這里消息接收就完成了，拿到消息后就可以在相應方法里執行相應處理了，使用AMQP發送接收消息就講解到此了。