ActiveMQ消息特性：延迟和定时消息投递（Delay and Schedule Message Delivery）

淩亂°似流年 2022-06-14 08:53 270阅读 0赞

有时候我们不希望消息马上被broker投递出去，而是想要消息60秒以后发给消费者，或者我们想让消息没隔一定时间投递一次，一共投递指定的次数。。。

类似这种需求，ActiveMQ提供了一种broker端消息定时调度机制。

我们只需要把几个描述消息定时调度方式的参数作为属性添加到消息，broker端的调度器就会按照我们想要的行为去处理消息。

一共有四个属性:

<table style="font-size:10px; color:rgb(0,0,0); margin:5px; border-collapse:collapse"> 
 <tbody> 
  <tr style="font-size:10px"> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> Property name</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> type</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> description</th> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> AMQ_SCHEDULED_DELAY</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> long</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> 延迟投递的时间</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> AMQ_SCHEDULED_PERIOD</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> long</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> 重复投递的时间间隔</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> AMQ_SCHEDULED_REPEAT</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> int</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> 重复投递次数</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> AMQ_SCHEDULED_CRON</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Cron表达式</td> 
  </tr> 
 </tbody> 
</table>

当然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][] 表达式的例子：

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);

[CRON]: http://en.wikipedia.org/wiki/Cron