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客户端):
- Author:NotionNext
- URL:https://tangly1024.com/article/4218f072-b4e2-4fb1-b525-285ce60d1dd1
- Copyright:All articles in this blog, except for special statements, adopt BY-NC-SA agreement. Please indicate the source!