标签：listen depend .bat aging col tin slist 数据 override
此篇文章介绍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里面的消息已经被消费了。
Springboot1.5.10整合ActiveMq5.14
标签：listen depend .bat aging col tin slist 数据 override
原文地址：https://www.cnblogs.com/jameszheng/p/10229872.html
