欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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" 

Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟

相关标签: ActiveMq