RocketMQ 消息重复消费：生产环境的终极解决方案

RocketMQ 消息重复消费：生产环境的终极解决方案（附完整代码）

在分布式系统中，消息一定会重复。 真正成熟的系统，从来不是“避免重复”，而是允许重复，但结果永远正确。

一、先纠正一个 90% 人都会犯的认知错误

1️⃣ 重复消费是不是 Bug？

不是。

RocketMQ 的消费语义是：

At-Least-Once（至少一次）

这意味着：

• 网络抖动
• Broker 主从切换
• Consumer 重启 / Rebalance

都会导致 消息被再次投递

2️⃣ 幂等 ≠ 不重复消费

👉 消息可以重来，但状态不能回退

二、RocketMQ 重复消费的根本原因（生产级视角）

1️⃣ 生产端（不可控）