笔记
RocketMQ定时消息
00 分钟
2023-3-2
2024-1-9
type
status
date
slug
summary
tags
category
icon
password
RocketMQ提供了消息定时功能,即可以将消息发送到指定的时间点才被消费者接收。通过消息定时功能,可以实现一些定时任务,例如发送定时通知、定时统计等。
在RocketMQ中,消息定时功能是通过设置消息的延迟级别来实现的。延迟级别表示消息发送后多长时间才能被消费者接收,RocketMQ支持18个级别的延迟时间,从1s到2h不等。在消息发送时,需要将消息的延迟级别设置为对应的值,RocketMQ会在指定的时间点将消息发送给消费者。 messageDelayLevel,默认值为 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h  18 个 level
需要注意的是,RocketMQ的消息定时功能仅适用于可靠同步传输方式(SYNC),不适用于异步传输方式(ASYNC)和单向传输方式(ONEWAY)。
以下是一个发送定时消息的示例代码(Java客户端):