Spring Cloud Stream RocketMQ 延时消息不生效排查指南

使用 Spring Cloud Stream 和 RocketMQ 发送延时消息时，可能会遇到消息没有生效的情况。以下列出了几种常见的导致延时消息不生效的原因及解决方法：

RocketMQ 版本不支持延时消息: 确保使用的是支持延时消息的 RocketMQ 版本，延时消息是在 RocketMQ 4.3.0 及以上版本中引入的功能。
消息发送方式不正确: 在 Spring Cloud Stream 中，使用 @Output 注解将消息发送到对应的输出通道，并使用 MessageBuilder 构建消息并设置延时级别。例如：

@Output("output-channel")
MessageChannel outputChannel;

...

Message<String> message = MessageBuilder
    .withPayload('延时消息')
    .setHeader(MessageConst.PROPERTY_DELAY_TIME_LEVEL, 3)
    .build();
outputChannel.send(message);

确保正确设置了 MessageConst.PROPERTY_DELAY_TIME_LEVEL 的值，该值表示延时级别，对应的延时时间为 level * 5s。

RocketMQ 配置不正确: 在 RocketMQ 的配置文件中，需要正确设置 messageDelayLevel 参数，以支持延时消息。例如：

# 延时消息级别
messageDelayLevel=1

确保 messageDelayLevel 的值大于等于发送消息时设置的延时级别。

消息消费方式不正确: 延时消息的消费需要特殊的消费者配置。在 Spring Cloud Stream 中，使用 @StreamListener 注解监听延时消息的输入通道，并设置 delayExpression 属性来指定延时时间。例如：

@StreamListener("input-channel")
public void receiveDelayedMessage(String message) {
    // 处理延时消息
    System.out.println('接收到延时消息：' + message);
}

确保消费者正确处理延时消息，并设置了正确的延时时间。

如果仍然无法解决问题，建议检查 RocketMQ 和 Spring Cloud Stream 的日志，查看是否有相关的错误或警告信息。