1. 程式人生 > >spring boot 整合 activeMQ 之 P2P 的簡單應用

spring boot 整合 activeMQ 之 P2P 的簡單應用

      在實際專案中,很多時候要訊息中介軟體來進行分散式系統之間的通訊。它具有低耦合,可靠投遞廣播,流量控制,最終一致性等一系列功能。

      訊息機制主要有三種: P2P、訂閱/釋出、應答模式。本人也是初步學習使用訊息機制,先寫個P2P的訊息機制以供記錄學習筆記。

直接上程式碼:

第一步 pom.xml中引入activeMq的依賴

<!--訊息佇列  -->
<!-- activeMq support -->
<dependency>
<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- activeMq end -->

第二步 application.properties檔案中新增如下配置


第三步  定義一個 P2P 佇列


第四步:  定義一個生產者,通過springboot提供的JmsMessagingTemplate實現send動作,並生產p2p訊息;


第五步: 定義消費者


第六步 測試介面


第七步 測試結果



P2P訊息機制就到這裡了。