ActiveMQ消息特性：延遲和定時消息投遞（Delay and Schedule Message Delivery）

轉(zhuǎn)自：http://blog.csdn.net/kimmking/article/details/8443872

有時候我們不希望消息馬上被broker投遞出去，而是想要消息60秒以后發(fā)給消費者，或者我們想讓消息沒隔一定時間投遞一次，一共投遞指定的次數(shù)。。。

類似這種需求，ActiveMQ提供了一種broker端消息定時調(diào)度機制。

首先要修改activemq.xml配置文件，啟用延時投遞。

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

然后我們只需要把幾個描述消息定時調(diào)度方式的參數(shù)作為屬性添加到消息，broker端的調(diào)度器就會按照我們想要的行為去處理消息。

一共有四個屬性:

Property name	type	description
AMQ_SCHEDULED_DELAY	long	延遲投遞的時間
AMQ_SCHEDULED_PERIOD	long	重復(fù)投遞的時間間隔
AMQ_SCHEDULED_REPEAT	int	重復(fù)投遞次數(shù)
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表達式的優(yōu)先級高于另外三個參數(shù)，如果在設(shè)置了CRON的同時，也有repeat和period參數(shù)，則會在每次CRON執(zhí)行的時候，重復(fù)投遞repeat次，每次間隔為period。就是說設(shè)置是疊加的效果。例如每小時都會發(fā)生消息被投遞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);

總結(jié)

以上是生活随笔為你收集整理的ActiveMQ—消息特性（延迟和定时消息投递）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。