1. 程式人生 > >Springboot1.5.10整合ActiveMq5.14

Springboot1.5.10整合ActiveMq5.14

此篇文章介紹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中
 @Autowired
    
private 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裡面的訊息已經被消費了。