Springboot1.5.10整合ActiveMq5.14
阿新 • • 發佈:2019-01-06
此篇文章介紹springboot整合activemq,使用的版本為:springboot 1.5.10,activemq 5.13
首先安裝Windows版的activeMq,本機安裝的是為5.15.4。
在安裝路徑apache-activemq-5.15.4-bin\bin\win64,雙擊activemq.bat啟動服務。
我們知道queue的訊息傳送有兩種,一種為點對點模式,一條訊息只能被消費一次,一種為釋出訂閱模式,一條訊息可以被多個消費者消費。此處我們介紹的只是一個簡單的點對點模式的例子。
一 生產端
1.新增依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
<version>1.5.10.RELEASE</version>
</dependency>
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> <version>1.4.0.RELEASE</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-pool</artifactId> <version>5.14.0</version> </dependency>
2.新增屬性
在application.properties裡面新增如下屬性:
spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.in-memory=false spring.activemq.packages.trust-all=true spring.activemq.pool.enabled=true spring.activemq.pool.max-connections=20
這裡配置的是mq pool。
3.傳送訊息
在service中使用template傳送訊息到queue中
@Autowiredprivate JmsMessagingTemplate jmsMessagingTemplate; @Override public void sentToQueue() { jmsMessagingTemplate.convertAndSend("testQueue", "test"); }
瀏覽器開啟http://localhost:8161/admin/queues.jsp,輸入使用者名稱和密碼(admin,admin),頁面上可看到queue中的資料。
二 消費端
依賴和屬性配置跟生產端一樣,用註解@JmsListener接收訊息:
@JmsListener(destination ="testQueue") @Override public void test() { .... }
重新整理頁面,可以看到queue裡面的訊息已經被消費了。