SpringBoot中使用ActiveMQ

1.  首先下载ActiveMQ，链接地址：http://activemq.apache.org/  ，在bin目录下启动

1-1. 启动ActiveMQ

2.  成功启动后，我们可以通过 http://localhost:8161 来访问管理页面，连接消息服务器的地址为tcp://localhost:61616 ，默认用户名密码都为admin，可在如下文件中进行自定义

2-1. 自定义消息服务的用户名密码

3.  接下来是SpringBoot连接ActiveMQ，

（1）  引入如下依赖 

ActiveMQ依赖

（2）  配置ActiveMQ 连接，本人使用虚拟机运行的ActiveMQ，故IP有变，本机启动IP为localhost（127.0.0.1）

3-1. ActiveMQ连接属性

至此配置完成，开始使用。

4.  发布&订阅

（1）发布消息

4-1. 发布消息

（2） 订阅消息 

4-2. 订阅消息

 在pub/sub模式中, 对消息的监听需要对containerFactory进行以下配置: 

4-3. 配置 containerFactory

完整订阅如下:

4-4. 完整的订阅

（3） 测试

4-5. 测试

运行测试程序，收到发出的消息 "Hello !"即成功。

4.  历史消息查看可访问 127.0.0.1:8161/admin/queues.jsp 即可。