在上一篇隨筆中我們認識並安裝了RabbitMQ，接下來我們來看下怎麼在Spring Boot 應用中整合RabbitMQ。

先給出最終目錄結構：

搭建步驟如下：

1. 新建maven工程amqp
2. 修改pom檔案，引入spring-boot-starter-amqp和spring-boot-starter-test

   <project xmlns="http://maven.apache.org/POM/4.0.0"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
    
   >
       <modelVersion>4.0.0</modelVersion>
       <groupId>com.sam</groupId>
       <artifactId>amqp</artifactId>
       <version>0.0.1-SNAPSHOT</version>
   
       <parent>
           <groupId>org.springframework.boot</groupId>
           <artifactId
    
   >spring-boot-starter-parent</artifactId>
           <version>1.5.1.RELEASE</version>
       </parent>
   
       <properties>
           <javaVersion>1.8</javaVersion>
       </properties>
       <dependencies>
           <!-- 引入amqp依賴，它能很好的支援RabbitMQ -->
           <
    
   dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-amqp</artifactId>
           </dependency>
           <!-- 引入test依賴，這次需要用到JUnit -->
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-test</artifactId>
           </dependency>
       </dependencies>
   </project>

3. 新建application.properties配置檔案，主要就是配置下連線RabbitMQ的資訊：

   spring.application.name=rabbitmq-hello
   #config rabbitmq info
   spring.rabbitmq.host=localhost
   spring.rabbitmq.port=5672
   spring.rabbitmq.username=guest
   spring.rabbitmq.password=guest

4. 新建啟動類，這裡沒什麼特殊的，就是普通的spring boot啟動類

   /**
    * 這裡沒什麼特殊的地方，就是普通的spring boot 配置
    *
    */
   @SpringBootApplication
   public class RabbitMQApp {
   
       public static void main(String[] args) {
           SpringApplication.run(RabbitMQApp.class, args);
       }
   }

5. 建立生產者類，通過AmqpTemplate實現訊息的傳送，AmqpTemplate介面定義了一套針對AMQP協議的基礎操作。在Spring Boot中會根據配置來注入具體的實現。這裡我們會產生一個字串，併發送到名為hello的佇列中。

   @Component
   public class Sender {
   
       @Autowired
       AmqpTemplate rabbitmqTemplate;
   
       /**
        * 傳送訊息
        */
       public void send() {
           String content = "Sender says:" + "'hello， I'm sender'";
           System.out.println(content);
           rabbitmqTemplate.convertAndSend("hello", content);
       }
   }

6. 建立消費者類，需要用到@RabbitListener來定義對hello佇列的監聽，並用@RabbitHandler註解來指定對訊息處理的方法。我們這裡實現了對hello佇列的消費。

   /**
    * 通過@RabbitListener對hello佇列進行監聽
    *
    */
   @Component
   @RabbitListener(queues="hello")
   public class Receiver {
   
       /**
        * 通過@RabbitHandler宣告的方法，對hello佇列中的訊息進行處理
        */
       @RabbitHandler
       public void receiver(String str) {
           System.out.println("Receiver says:[" + str + "]");
       }
   }

7. 編寫RabbitMQ的配置類，配置類可以配置佇列、交換器、路由等高階資訊。我們這裡為了簡單，只配置佇列，其他的採用預設配置。

   /**
    * rabbitmq配置類，
    * 為了簡單，我們這裡只配置了Queue
    * 至於exchanges、brokers等用的預設配置
    *
    */
   @Configuration
   public class RabbitConfig {
   
       @Bean
       public Queue helloQueue() {
           return new Queue("hello");
       }
       
       
   }

8. 編寫測試類，用來呼叫訊息生產者

   @RunWith(SpringJUnit4ClassRunner.class)
   @SpringBootTest(classes=RabbitMQApp.class)
   public class HelloTest {
   
       @Autowired
       private Sender sender;
   
       /**
        * 呼叫生產者進行訊息傳送
        */
       @Test
       public void hello() throws Exception{
           sender.send();
       }
   }

9. 執行啟動類，啟動後控制檯會有下面的提示內容：
10. 執行測試類，在測試類的控制檯會列印我們打的log內容

　　切換到amqp應用的控制檯，能看到列印：

　　在管理頁面中我們能看到Connections和Channels中包含了當前連線的條目：

 在整個生產和消費的過程中，生產和消費是一個非同步操作，這是分散式系統中要使用訊息代理的重要原因。