ActiveMQ延迟消息队列
延迟消息使用场景 在实际业务中，比如说一些定时任务，超时处理等，在我们公司的业务中，订单未支付超时关闭就是最典型的使用延迟消息队列的场景。
如何实现延迟消息队列
第一步：修改activemq.xml配置文件，开启延时发送
1
2
3
| <broker xmlns="http://activemq.apache.org/schema/core" ... schedulerSupport="true" >
...
</broker>
|
第二步：消息生产者在发送消息的时候需进行设置
1
2
3
4
5
| 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
在管理端可以看到发送的延迟消息。
参考资料
- ActiveMQ实现延迟消息队列
- ActiveMQ延迟消息队列