本文主要是介绍ActiveMQ—消息特性（延迟和定时消息投递），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
ActiveMQ消息特性：延迟和定时消息投递（Delay and Schedule Message Delivery）
转自：http://blog.csdn.net/kimmking/article/details/8443872
有时候我们不希望消息马上被broker投递出去，而是想要消息60秒以后发给消费者，或者我们想让消息没隔一定时间投递一次，一共投递指定的次数。。。
类似这种需求，ActiveMQ提供了一种broker端消息定时调度机制。
首先要修改activemq.xml配置文件，启用延时投递。
<broker xmlns="http://activemq.apache.org/schema/core" ... schedulerSupport="true">...</broker>然后我们只需要把几个描述消息定时调度方式的参数作为属性添加到消息，broker端的调度器就会按照我们想要的行为去处理消息。
一共有四个属性:
| Property name | type | description |
|---|---|---|
| AMQ_SCHEDULED_DELAY | long | 延迟投递的时间 |
| AMQ_SCHEDULED_PERIOD | long | 重复投递的时间间隔 |
| AMQ_SCHEDULED_REPEAT | int | 重复投递次数 |
| AMQ_SCHEDULED_CRON | String | Cron表达式 |
当然ActiveMQ也提供了一个封装的消息类型：org.apache.activemq.ScheduledMessage.
使用示例，延迟60秒:
MessageProducer producer = session.createProducer(destination);TextMessage message = session.createTextMessage("test msg");long time = 60 * 1000;message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);producer.send(message);
延迟30秒，投递10次，间隔10秒:
MessageProducer producer = session.createProducer(destination);TextMessage message = session.createTextMessage("test msg");long delay = 30 * 1000;long period = 10 * 1000;int repeat = 9;message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay);message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, period);message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, repeat);producer.send(message);
使用 CRON 表达式的例子：
MessageProducer producer = session.createProducer(destination);TextMessage message = session.createTextMessage("test msg");message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, "0 * * * *");producer.send(message);
CRON表达式的优先级高于另外三个参数，如果在设置了CRON的同时，也有repeat和period参数，则会在每次CRON执行的时候，重复投递repeat次，每次间隔为period。就是说设置是叠加的效果。例如每小时都会发生消息被投递10次，延迟1秒开始，每次间隔1秒:
MessageProducer producer = session.createProducer(destination);TextMessage message = session.createTextMessage("test msg");message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, "0 * * * *");message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 1000);message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 1000);message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 9);producer.send(message);
这篇关于ActiveMQ—消息特性（延迟和定时消息投递）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
