目录
一、生产端：消息能可靠到达 Broker
二、Broker 端：消息落盘 + 多副本，硬件故障也不丢
1. 同步刷盘（SYNC_FLUSH）
2. 主从同步复制（SYNC_MASTER）
3. 存储结构：顺序写 + 持久化
三、消费端：消费成功才确认，失败可重试
四、全链路配置建议（零丢失方案）
五、一句话总结
RocketMQ 保证消息不丢失，核心是生产端可靠发送 + Broker 持久化与高可用 + 消费端可靠消费的全链路设计。下面分段讲清楚原理与关键配置。
一、生产端：消息能可靠到达 Broker
- 同步发送 + 等待 ACK
- 用
send()同步发送，Broker 成功写入并持久化后才返回SEND_OK。 - 禁止用
OneWay（单向发送，无确认），核心业务必须用同步 / 异步带回调发送。
- 用
- 自动重试 + 业务兜底
- 客户端默认重试 2 次，可自定义重试次数与间隔。
- 重试失败时，本地日志 / 数据库记录 + 定时重试，避免消息丢失RocketMQ。
- 事务消息（解决生产者本地事务与发送原子性）
- 流程：发送 Half 消息 → 执行本地事务 → 成功则 Commit，失败则 Rollback。
- Broker 长时间未收到指令会回查生产者事务状态，防止悬挂。
二、Broker 端：消息落盘 + 多副本，硬件故障也不丢
1. 同步刷盘（SYNC_FLUSH）
- 消息写入CommitLog后，立即刷入磁盘才返回 ACK。
- 配置：
flushDiskType=SYNC_FLUSH（默认异步刷盘 ASYNC_FLUSH，断电会丢内存数据）。 - 适用：金融 / 支付等零丢失场景。
2. 主从同步复制（SYNC_MASTER）
- 主 Broker 写入成功后，同步复制到从 Broker，从节点确认后主节点才返回 ACK。
- 配置：
brokerRole=SYNC_MASTER（默认异步 ASYNC_MASTER，主宕机可能丢未复制数据）。 - 高可用：主宕机，从自动切换为主，数据不丢。
3. 存储结构：顺序写 + 持久化
- 消息 append 到 CommitLog，顺序写盘，性能高且不易损坏。
- 配合主从集群 + 同步刷盘，可抵御单机断电、磁盘损坏等故障。
三、消费端：消费成功才确认，失败可重试
- 先消费后 ACK（At Least Once）
- Consumer 拉取消息→执行业务逻辑→成功后返回
CONSUME_SUCCESS；失败返回RECONSUME_LATER。 - Broker 收到成功 ACK 才删除消息，否则重试投递。
- Consumer 拉取消息→执行业务逻辑→成功后返回
- Offset 持久化
- 消费位点（Offset）定期持久化（默认 5 秒），也可手动提交，避免重启后重复消费或漏消费。
- 重试队列 + 死信队列（DLQ）
- 消费失败→进入重试队列，延迟重试（默认最多 16 次）。
- 超过最大重试次数→进入死信队列，人工排查补偿，防止消息丢失。
- 消费幂等（必做）
- 重试会导致消息重复，业务需实现幂等性（如唯一键约束、状态机），保证 “至少一次” 转为 “精确一次”。
四、全链路配置建议（零丢失方案）
| 环节 | 配置 / 实践 |
|---|---|
| 生产端 | 同步发送、3-5 次重试、失败落地本地库、事务消息 |
| Broker | 同步刷盘（SYNC_FLUSH）、同步主从（SYNC_MASTER） |
| 消费端 | 手动提交 ACK、业务成功后才返回成功、消费幂等、死信监控 |
五、一句话总结
RocketMQ 不丢消息靠：生产端同步发送 + 重试 + 事务、Broker 同步刷盘 + 同步主从、消费端先业务后 ACK + 重试 + 幂等，全链路闭环保障。
