本文章简单介绍了activemq,以及在springboot项目中使用activemq
activemq介绍
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。
ActiveMQ的消息机制:
1.点对点方式:
每个消息只能有一个消费者。
2.发布/订阅消息传递域
每个消息可以有多个消费者。
在springboot中使用
配置pom文件
|
|
配置文件
|
|
配置工厂
|
|
发送消息
|
|
接收消息
此处是接收的topic模式的消息
队列的定义
|
|
异常错误
Could not connect to broker URL
问题:
Could not refresh JMS Connection for destination ‘queue_toc_tob’ - retrying using FixedBackOff{interval=10000, currentAttempts=2013, maxAttempts=unlimited}. Cause: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused
分析:
activemq正常启动着,数据量小没有问题,通过 nestat -nalp |grep 61616
发现有很多连接。
解决:
使用连接池。
1、在pom.xml中:(springboot使用1.5.6.RELEASE版本)
2、在application.yml中: