一、ActiveMQ 介绍
MQ是消息中间件,是一种在分布式系统中应用程序借以传递消息的媒介,常用的有 ActiveMQ,RabbitMQ,kafka。ActiveMQ 是 Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。
特点:
(1)支持多种语言编写客户端
(2)对spring的支持,很容易和spring整合
(3)支持多种传输协议:TCP,SSL,NIO,UDP等
(4)支持AJAX
消息形式:
(1)点对点(queue)
(2)一对多(topic)
二、ActiveMQ 安装
首先下载需要的 ActiveMQ:https://activemq.apache.org/activemq-5120-release
然后上传到 Linux 中解压:这里需要确保 linux 中已经装好了 jdk
由于我这里的 jdk 是1.7 的版本所以我下载的 activemq 是5.12.0
解压:tar -zxvf apache-activemq-5.12.0-bin.tar.gz
然后进入解压的目录启动即可:./bin/activemq start
登录验证,注意需要登录:192.168.245.129:8161/admin,用户名和密码均为:admin
不然直接访问会出错:http://192.168.245.129:8161/
三、SpringBoot 整合 ActiveMQ
1. 加入依赖配置
2. 配置 application.properties
3. 配置队列
这里由于就一个 Bean,所以在 启动类中对其进行了配置:
4. 配置 Message 对象
5. 配置 JmsComponent
实现消息的接收和发送