Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
程序员文章站
2022-05-18 14:48:03
...
转自:https://blog.csdn.net/liboyang71/article/details/78869135
1.简介
1.1 什么是ActiveMQ ActiveMQ 是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个 完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现,尽管 JMS 规范出台已经是很久的事 情了,但是 JMS 在当今的 J2EE 应用中间仍然扮演着特殊的地位。
1.2 JMS介绍
1.2.1 基本概念 JMS全称为Java Message Service 即Java消息服务。其API是一个消息服务的规范,JMS的客户端之间可以通过JMS服务进行异步的消息传输。
1.2.2 消息模型 模型分为两种,即 Point-to-Point(P2P)(点对点模型) 和 Publish/Subscribe(Pub/Sub)(发布订阅模型)
2.4 实现MQ延迟
其实所谓的MQ延迟说白了就是我要多少秒之后再去创建这个消息队列,从而达到多少秒之后自动调用某个接口的效果。
需求:例如我创建了一个秒杀活动,APP端有一个秒杀活动开启五分钟前自动给点击了”提醒我”的用户的手机发送短信的功能。
这个时候我们就会使用到mq的延迟功能,在秒杀活动开启前五分钟调用 查询所有点击了”提醒我”的会员的电话号码,给他们发送短信 功能的接口。
2.4.1 开启mq延迟功能
首先,上篇文章中我们有mq在linux下的安装过程,但是默认情况下mq的延迟功能是关闭的,所以首先我们需要将mq的延迟功能开启。
切换目录
/usr/local/apache-activemq-5.14.0/conf
以vim查看配置文件
vi activemq.xml
在第40行添加 schedulerSupport="true"
如下图所示
schedulerSupport="true"
上一篇: ActiveMQ初识