Spring Boot ActiveMQ连接池配置过程解析

时间:2021-05-19

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:61616spring.activemq.in-memory=true#默认值false,表示point to point(点到点)模式,true时代表发布订阅模式,需要手动开启spring.jms.pub-sub-domain=truespring.activemq.user=wienerspring.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,neverspring.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发布/订阅消息模式原理解析中的测试用例验证即可查看效果,解锁新技能成功。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章