Spring整合ActiveMQ实现消息延迟投递和定时投递

摘要:
linux(centos)系统安装activemq参考:https://www.cnblogs.com/pxblog/p/12222231.html首先在ActiveMQ的安装路径/conf/activemq.xml修改配置文件增加:schedulerSupport="true"然后保存重启服务进入bin目录,执行./activemqrestartSpring整合ActiveMQ,实现队列主题消息

linux(centos)系统安装activemq参考:https://www.cnblogs.com/pxblog/p/12222231.html

首先在ActiveMQ的安装路径 /conf/activemq.xml 修改配置文件 增加:schedulerSupport="true"

Spring整合ActiveMQ实现消息延迟投递和定时投递第1张

然后保存重启服务

进入bin目录,执行

./activemq restart

Spring整合ActiveMQ,实现队列主题消息生产消费参考:https://www.cnblogs.com/pxblog/p/12615773.html

以下伪代码是在上述链接基础上修改的

/*队列生产者*/jmsTemplate.send(session1 ->{
            TextMessage textMessage = session1.createTextMessage("发送的消息内容");
            //延迟投递的时间 毫秒
            textMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY,4000);
            //重复投递的的时间间隔 毫秒
            textMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD,4000);
            //重复投递的次数
            textMessage.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT,3);
            returntextMessage;
        });

免责声明:文章转载自《Spring整合ActiveMQ实现消息延迟投递和定时投递》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇利用FileWatcher实现文件实时监视ffmpeg参数设定解说下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Linux下activeMQ的安装和启动

Linux下activeMQ的安装和启动 ActiveMQ的安装和启动 安装JAVA配置JAVA环境 下载ActiveMQ解压压缩包tar zxvf activemq-x.x.x-bin.tar.gz至此,linux下ActiveMQ的安装工作就完成了。ActiveMQ在Linux下的启动启动ActiveMQ分为两种模式 ,以 前端进程的方式启动(控制台关...

Linux 安装ActiveMQ(使用Mac远程访问)

阅读本文需要安装JDK 一 ActiveMQ简介 activemq是用java语言编写的一款开源消息总线 activemq是apache出品 activemq消息的传递有两种类型   一种是点对点: 即一个生产者和一个消费者一一对应 这种消息如果没有消费者接收 可以保留在服务端 等待被接收   另一种是发布|订阅模式: 即一个生产者产生消息并发送后 可以由...

activemq 安装配置二

管理后台地址http://localhost:8161/admin 或 http://127.0.0.1:8161/admin 默认用户名密码admin admin,端口默认是8161,且服务采用的是服务器,所以我们进入到conf/jetty.xml 一. 放开本地访问限制 将host由127.0.0.1 变更为0.0.0.0 , 放开非本地访问限制...

ActiveMQ从入门到精通(一)

  这是关于消息中间件ActiveMQ的一个系列专题文章,将涵盖JMS、ActiveMQ的初步入门及API详细使用、两种经典的消息模式(PTP and Pub/Sub)、与Spring整合、ActiveMQ集群、监控与配置优化等。话不多说,我们来一起瞧一瞧! JMS 首先来说较早以前,也就是没有JMS的那个时候,很多应用系统存在一些缺陷:...

Springboot+ActiveMQ(ActiveMQ消息持久化,保证JMS的可靠性,消费者幂等性)

ActiveMQ 持久化设置: 在redis中提供了两种持久化机制:RDB和AOF 两种持久化方式,避免redis宕机以后,能数据恢复,所以持久化的功能 对高可用程序来说 很重要。 同样在ActiveMQ 中 也提供了持久化的功能,在生产者 生产消息 到队列中,可以通过设置 该消息在队列中是否持久化。持久化以后,即使ActiveMQ重启了,队列中的消息也不...

SpringBoot JMS(ActiveMQ) 使用实践

ActiveMQ 1. 下载windows办的activeMQ后,在以下目录可以启动:      2. 启动后会有以下提示      3. 所以我们可以通过http://localhost:8161访问管理页面,通过tcp://localhost:61616来连接消息服务器,用到的用户名和密码都在以下文件中(默认为admin=admin)      sp...