SpringBoot2.x系列教程61--SpringBoot整合消息隊列之ActiveMQ代碼實現消息傳遞

作者：一一哥

我在上一章節中，給大家介紹了ActiveMQ，本節中我會介紹Spring Boot中如何整合ActiveMQ，實現消息的創建和消費。

一. Spring Boot中整合ActiveMQ

1. 創建web項目

我們按照之前的經驗，創建一個web程序，并將之改造成Spring Boot項目，具體過程略。

2. 添加依賴包

3. 創建application.yml配置文件

4. 創建ActiveMQ的配置類

在這個類中創建連接工廠，消息隊列等。

5. 創建消息生產者的工具類

在這個Producer類中，創建幾個發送消息的的方法。

6. 定義消費消息的Consumer類

7. 創建Controller，發布消息

8. 創建入口類

9. 完整項目結構

10. 啟動項目進行測試

測試發送點對點類型的消息

隊列中可以看到成功的收到了消息。

在ActiveMQ中也可以看到出現了springboot.queue隊列，并且隊列中的消息已被消費掉。

測試發送發布者訂閱者類型的消息

Topic中可以看到成功的收到了消息。

在ActiveMQ中也可以看到出現了springboot.topic隊列，并且隊列中的消息已被消費掉。

二. 回復消息的實現

我們在上面的基礎之上，進一步實現發送消息后，進行消息的回復。

1. 改造ActiveMQ類

在該類中添加一個用來接收回復消息的隊列。

完整的ActivemqConfig代碼:

2. 改造Producer類

在Producer類中定義一個新的Queue類,并定義發送消息和消費消息的方法。

完整的Producer類代碼:

3. 改造Consumer類

在該類中添加接收消息，并且設置回復消息的方法。

完整的Consumer類代碼:

4. 重新運行，測試消息的回復功能

調用如下接口，測試消息回復功能。

此時可以看到控制臺輸出如下信息，說明消息回復成功。

至此，我們實現了Spring boot中如何整合ActiveMQ。

總結

以上是生活随笔為你收集整理的springboot接收文件_SpringBoot2.x系列教程61--SpringBoot整合MQ之ActiveMQ实现消息传递的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。