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!