发送与接收延迟消息

最近更新时间: 2026-06-30 15:06:00

操作场景

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

前提条件

  • 完成资源创建与准备
  • 安装1.8或以上版本 JDK
  • 安装2.5或以上版本 Maven
  • 已经了解发送与接收普通消息

操作步骤

发送消息

和普通发送消息相同,在调用发送方法的时候,传递对应的延迟级别即可。

 SendResult sendResult = rocketMQTemplate.syncSend(
                destination,
                MessageBuilder.withPayload(message).build(),
                5000,
                delayLevel);

延迟等级与时间对应关系

其他延迟级别和具体延迟时间的对应关系如下:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18

1s、 5s、 10s、 30s、 1m、 2m、 3m、 4m、 5m、 6m、 7m、 8m、 9m、 10m、 20m、 30m、 1h、 2h;

消费消息

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