編制RabbitMQ配置、傳送、接受的程式碼

1、編寫配置檔案類

在com.example包中增加類，名稱為HelloRabbitConfig，並修改程式碼為

1. package com.example;  
2. import org.springframework.amqp.core.Queue;  
3. import org.springframework.context.annotation.Bean;  
4. import org.springframework.context.annotation.Configuration;  
5. @Configuration
6. publicclass HelloRabbitConfig {  
7.     @Bean
8.     public Queue helloQueue() {  
9.         returnnew Queue("hello");  
10.     }  
11. }  

2、編寫傳送訊息類

在com.example包中增加類，名稱為HelloSender，並修改程式碼為

1. package com.example;  
2. import java.util.Date;  
3. import org.slf4j.Logger;  
4. import org.slf4j.LoggerFactory;  
5. import org.springframework.amqp.core.AmqpTemplate;  
6. import org.springframework.beans.factory.annotation.Autowired;  
7. import org.springframework.stereotype.Component;  
8. @Component
9. publicclass HelloSender {  
10.     protectedstatic Logger logger=LoggerFactory.getLogger(HelloSender.class);   
11.     @Autowired
12.     private AmqpTemplate rabbitTemplate;  
13.     public
     String send(String name) {  
14.         String context = "hello "+name+" --" + new Date();  
15.         logger.debug("HelloSender: " + context);  
16.         this.rabbitTemplate.convertAndSend("hello", context);  
17.         return context;  
18.     }  
19. }  

3、編寫接受訊息類

在com.example包中增加類，名稱為HelloReceiver，並修改程式碼為

1. package com.example;  
2. import org.slf4j.Logger;  
3. import org.slf4j.LoggerFactory;  
4. import org.springframework.amqp.rabbit.annotation.RabbitHandler;  
5. import org.springframework.amqp.rabbit.annotation.RabbitListener;  
6. import org.springframework.stereotype.Component;  
7. @Component  
8. @RabbitListener(queues = "hello")  
9. public class HelloReceiver {  
10.     protected static Logger logger = LoggerFactory.getLogger(HelloReceiver.class);  
11.     @RabbitHandler  
12.     public void process(String hello) {  
13.         logger.debug("HelloReceiver : " + hello);  
14.     }  
15. }  

4、編寫RestController，呼叫傳送訊息

在com.example包中增加類，名稱為HelloController，並修改程式碼為

1. package com.example;  
2. import org.slf4j.Logger;  
3. import org.slf4j.LoggerFactory;  
4. import org.springframework.beans.factory.annotation.Autowired;  
5. import org.springframework.web.bind.annotation.PathVariable;  
6. import org.springframework.web.bind.annotation.RequestMapping;  
7. import org.springframework.web.bind.annotation.RestController;  
8. @RestController
9. publicclass HelloController {  
10.     protectedstatic Logger logger=LoggerFactory.getLogger(HelloController.class);   
11.     @Autowired
12.         private HelloSender helloSender;  
13.     @RequestMapping("/send/{name}")  
14.     public String helloworld(@PathVariable String name) {  
15.         return helloSender.send(name);  
16.     }  
17. }  

5、執行測試

A、啟動Docker中容器rabbitmq5672。docker start rabbitmq5672   (如果已啟動，則忽略)

B、啟動工程。在工程所在的資料夾開啟命令列，且在命令列中執行 mvn spring-boot:run

C、在瀏覽器中輸入 http://localhost：8080/send/上帝

瀏覽器中顯示

控制檯中顯示，成功傳送、接收訊息

三、小結

1、rabbitmq連線

1.1 springboot,在啟動時，根據系統配置檔案的引數建立一個rabbitmq連線。參看控制檯日誌：

 (MBeanExporter.java:431)- Registering beans for JMX exposure on startup

(MBeanExporter.java:916)- Bean with name 'rabbitConnectionFactory' has been autodetected for JMX exposure

 (MBeanExporter.java:678)- Located managed bean 'rabbitConnectionFactory': registering with JMX server as MBean [org.springframework.amqp.rabbit.connection:name=rabbitConnectionFactory,type=CachingConnectionFactory]

(DefaultLifecycleProcessor.java:343)- Starting beans in phase -2147482648

(DefaultLifecycleProcessor.java:343)- Starting beans in phase 2147483647

(AbstractConnectionFactory.java:347)- Created new connection: [email protected] [delegate=amqp://[email protected]:5672/, localPort= 62881]

1.2、在springboot啟動之後，檢視rabbitmq(http://localhost:15672/)的connections，也可以檢視到。當然，你也可以停止springboot去看連結(停止之後，當然就沒有連結了).
1.3、把logbak.xml的root的等級修改為debug，你會發現監聽在不斷的連結reabitmq；它就是一個心跳。通過這個心跳，rabbitmq也知道存在哪些監聽器在監聽那個佇列。

2、配置檔案

在配置檔案中，僅僅配置了一個名為hello的佇列。以後傳送、接收都與這個佇列相關。

3、傳送訊息

3.1、傳送訊息使用模板機制，用springboot自動注入的rabbitTemplate，它已經封裝好連結、管道、轉換等。

3.2、訊息轉換和傳送

void convertAndSend(String routingKey, Object message) throws AmqpException;

它的註釋是：Convert a Java object to an Amqp {@link Message} and send it to a default exchange with a specific routing key.

轉換一個Java物件為Amqp訊息，然後再用預設的交換機指定路由鍵傳送訊息。

4、接受訊息

4.1、監聽訊息

在類上宣告@RabbitListener(queues = "hello")，表示監聽hello佇列

4.2、訊息處理控制代碼

在接收處理訊息的方法上宣告@RabbitHandler

Annotation that marks a method to be the target of a Rabbit message  listener within a class that is annotated with {@link RabbitListener}.

5、印象

整個工程比較簡單，沒有什麼特殊的配置，僅僅三個類檔案即可實現訊息的傳送和接受。