Spring Cloud Stream 发送 RocketMQ 延时消息失效问题解决

在 Spring Cloud Stream 中发送 RocketMQ 延时消息，需要配置'rocketmq.producer.send-message-timeout'属性来设置发送消息的超时时间。默认情况下，超时时间为3秒。如果消息在超时时间内没有发送成功，将被认为发送失败。

另外，需要注意的是，RocketMQ 的延时消息是通过设置消息的'delayTimeLevel'属性来实现的。'delayTimeLevel'表示消息的延时级别，级别越高，延时时间越长。在发送延时消息时，需要在消息头中设置'rocketmq_delay'属性，值为延时级别，例如'rocketmq_delay: 3'。

如果在使用 Spring Cloud Stream 发送延时消息时仍然失效，可以检查以下几个方面：

1. 确保 RocketMQ 的版本支持延时消息功能。延时消息是在 RocketMQ 4.3.0 版本中引入的，如果使用的版本较低，可能不支持延时消息功能。

2. 检查 RocketMQ 的 Broker 配置，确保'enablePropertyFilter'属性设置为'true'。延时消息需要使用消息的属性来实现，如果该属性被过滤掉，延时消息将无法生效。

3. 检查 RocketMQ 的 Topic 配置，确保'delayTimeLevel'属性设置正确。延时消息的延时级别需要在 Topic 配置中进行设置，如果设置不正确，延时消息将无法生效。

4. 查看 RocketMQ 的日志，检查是否有相关的错误或警告信息。日志中可能会有一些有用的信息，帮助排查延时消息失效的原因。

如果以上方法都无法解决问题，建议参考 RocketMQ 的官方文档或寻求 RocketMQ 社区的帮助。