发送与接收延迟消息

最近更新时间:2023-10-20 14:28:21

我的收藏

操作场景

本文以调用 Spring Boot Starter SDK 为例介绍通过开源 SDK 实现消息收发的操作过程,帮助您更好地理解延迟消息收发的完整过程。

前提条件

下载 Demo 或者 查看Github项目

操作步骤

发送消息

和普通发送消息相同,在调用发送方法的时候,传递对应的延迟级别即可。
SendResult sendResult = rocketMQTemplate.syncSend(
destination,
MessageBuilder.withPayload(message).build(),
5000,
delayLevel);
延迟等级和具体延迟时间的对应关系如下表:
延迟等级
时间
1
1s
2
5s
3
10s
4
30s
5
1m
6
2m
7
3m
8
4m
9
5m
10
6m
11
7m
12
8m
13
9m
14
10m
15
20m
16
30m
17
1h
18
2h

消费消息

和普通消息相同,无需特殊处理。