spring.activemq.pool.enabled=false時,每發送一條數據都需要創建一個連接,這樣會出現頻繁創建和銷毀連接的場景。為了不踩這個坑,我們參考池化技術的思想,配置ActiveMQ連接池。在《【Spring Boot】ActiveMQ 發布/訂閱消息模式介紹》的基礎上配置ActiveMQ連接池,只需要做兩項修改——配置文件和添加連接池依賴。
修改application.properties配置文件
## URL of the ActiveMQ broker. Auto-generated by default. For instance `tcp://localhost:61616`
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.in-memory=true #默認值false,表示point to point(點到點)模式,true時代表發布訂閱模式,需要手動開啟 spring.jms.pub-sub-domain=true spring.activemq.user=wiener spring.activemq.password=wiener #true表示使用連接池;false時,每發送一條數據創建一個連接 spring.activemq.pool.enabled=true #連接池最大連接數 spring.activemq.pool.max-connections=10 #空閑的連接過期時間,默認為30秒 spring.activemq.pool.idle-timeout=30000
#強制的連接過期時間,與idleTimeout的區別在於:idleTimeout是在連接空閑一段時間失效,而expire Timeout不管當前連接的情況,只要達到指定時間就失效。默認為0,never
spring.activemq.pool.expire-timeout=0
添加maven依賴
pom.xml也要加入依賴包,否則啟動報JmsMessagingTemplate注入失敗 。 使用springboot2.1+的時候,maven配置依賴是:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>5.2.7.RELEASE</version> </dependency>
使用springboot2.0及以下版本時候,maven配置依賴是:
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pool</artifactId>
</dependency>
使用《【Spring Boot】ActiveMQ 發布/訂閱消息模式介紹》中的測試用例驗證即可查看效果,解鎖新技能成功。