关于RocketMQ ConsumeMessageOrderlyService.sendMessageBack方法的疑问

问题核心 #

ConsumeMessageOrderlyService.sendMessageBack方法的注释明确标注：// max reconsume times exceeded then send to dead letter queue.，但实际代码逻辑并未实现该逻辑——无论消息重试次数是否超过配置的最大值，都会被发送至%RETRY%{ConsumerGroup}重试主题，随后通过SCHEDULE_TOPIC_XXXX延迟调度后再次投递给同一消费组，从未进入死信队列。

代码逻辑拆解 #

从提供的源码可以看到，方法全程没有任何判断重试次数是否达标的逻辑：

• 直接通过MixAll.getRetryTopic()获取重试主题，构造新消息
• 设置延迟等级为3 + msg.getReconsumeTimes()，但未判断该次数是否超过getMaxReconsumeTimes()
• 无条件发送消息至重试主题，完全跳过了死信队列的分支处理

对比并发消费对应的ConsumeMessageConcurrentlyService.sendMessageBack方法，后者会先检查msg.getReconsumeTimes() >= getMaxReconsumeTimes()，满足条件时才会将消息发送至死信队列（%DLQ%{ConsumerGroup}），否则才进入重试流程。

结论 #

这属于RocketMQ的注释与实现不一致问题，顺序消费的sendMessageBack方法遗漏了“超过最大重试次数转死信队列”的核心逻辑，导致消息会被持续重试（直到延迟等级达到上限后，以固定延迟重复投递），无法进入死信队列。

内容的提问来源于stack exchange，提问作者ComeOnWang