ActiveMQ消息队列

1.消息队列是什么
ActiveMQ是一个消息中间件(MOM),是一个实现了JMS规范的系统间远程通信的消息代理。
两个程序可能所属公司不同,甚至语言不同,但是需要产生交互合作,在某一方做实现非常不方便开发和维护,所以,相应的中间件,我们直接使用,沟通双方都遵守所选中间件的规范
2.为什么使用消息队列
(1)程序间需要通信
(2)消息的异步处理
(3)消息的排队
三大好处:功能解耦,异步处理,流量削峰
3.使用步骤
(1)下载,安装,调试
官网下载安装包,放到usr/local下(推荐)
tar -zxvf apache-activemq-xx.xxx.xx.tar.gz
cd bin
./activemq start
就可以启动了
访问这台服务器的8161端口,就能看到activemq工作台页面
(2)程序代码加载依赖,写你的业务实现
让程序能够使用activemq,不管是发送的一方还是接收的一方,都是一样的依赖和配置
ActiveMQ消息队列springboot自身集成了,直接打勾就行
配置,最简单的话只需要:
ActiveMQ消息队列

消息生产者:
ActiveMQ消息队列

消息消费者:
ActiveMQ消息队列

写一个controller,提供一个调用的途径:
ActiveMQ消息队列

启动项目,postman测一下,就能看到
ActiveMQ消息队列

这里会有变化和显示
接收的方法也会执行
如果,你把接收的方法注释掉,或者把监听取消
只是发送的话
可以发送成功,mq的工作台页面也会有显示,但是消息没被处理,就会保留,等以后接着发
什么时候,接收处理的方法开启了,就会把之前没收到的,都按顺序收到
(3)连接,发送,接受