操作场景
本文以调用 Spring Boot Starter SDK 为例介绍通过开源 SDK 实现消息收发的操作过程,帮助您更好地理解延迟消息收发的完整过程。
前提条件
已经了解发送与接收普通消息
操作步骤
发送消息
和普通发送消息相同,在调用发送方法的时候,传递对应的延迟级别即可。
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 |
消费消息
和普通消息相同,无需特殊处理。