190720-ActiveMQ延迟消息队列

ActiveMQ延迟消息队列
- 如何实现延迟消息队列
- 参考资料

ActiveMQ延迟消息队列

延迟消息使用场景在实际业务中，比如说一些定时任务，超时处理等，在我们公司的业务中，订单未支付超时关闭就是最典型的使用延迟消息队列的场景。

如何实现延迟消息队列

第一步：修改activemq.xml配置文件，开启延时发送

1
2
3

<broker xmlns="http://activemq.apache.org/schema/core" ... schedulerSupport="true" >
 ...
</broker>

第二步：消息生产者在发送消息的时候需进行设置

TextMessage message =  session.createTextMessage("这是一条延迟消息”);
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 200000L);//设置延迟时间
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 3000L);//设置重复投递间隔（非必要，根据实际情况）
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 5L);//重复投递次数（非必要，根据实际情况）
messageProducer.send(message);

发送消息查看ActiveMQ Web管理端

web_console

在管理端可以看到发送的延迟消息。

参考资料

2020-11-06

201106-Python自动化常用模块介绍

python / mysql

190720-ActiveMQ延迟消息队列

ActiveMQ延迟消息队列

如何实现延迟消息队列

第一步：修改activemq.xml配置文件，开启延时发送

第二步：消息生产者在发送消息的时候需进行设置

发送消息查看ActiveMQ Web管理端

参考资料

链接

标签云

最新文章

标签

分类

归档

分类

归档

Your browser is out-of-date!

190720-ActiveMQ延迟消息队列

ActiveMQ延迟消息队列

如何实现延迟消息队列

第一步：修改activemq.xml配置文件，开启延时发送

第二步：消息生产者在发送消息的时候需进行设置

发送消息 查看ActiveMQ Web管理端

参考资料

链接

标签云

最新文章

标签

分类

归档

分类

归档

Your browser is out-of-date!

发送消息查看ActiveMQ Web管理端