ActiveMQ 延迟投递与定时调度实战指南

周期重复投递

若需要消息先等待 30 秒，之后每隔 10 秒重发一次，共执行 10 次（含首次），代码如下：

MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");

long delay = 30 * 1000;   // 初始延迟 30 秒
long period = 10 * 1000;  // 间隔 10 秒
int repeat = 9;           // 额外重复 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 表达式。例如 0 * * * * 表示每分钟的第 0 秒执行（即每小时整点）：

MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, "0 * * * *");
producer.send(message);

4. 注意事项

Cron 表达式的优先级高于单纯的延迟设置。不过，当同时配置 Cron、延迟和周期时，ActiveMQ 会在 Cron 触发时执行消息投递逻辑，并应用设定的延迟与周期参数。

举个例子，如果你希望消息每小时触发一次，且每次触发后间隔 1 秒连续发送 10 条消息，可以这样组合：

// 每小时触发一次
message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, "0 * * * *");
// 每次触发后延迟 1 秒
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 1000);
// 间隔 1 秒重发
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 1000);
// 额外重复 9 次（共 10 条）
message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 9);

更多细节可参考官方文档：ActiveMQ Delay and Schedule Message Delivery。