RocketMQ 存储高可用与故障恢复深度剖析
在分布式消息系统中，数据的 持久化、一致性 和 高可用性 是衡量可靠性的核心指标。RocketMQ 凭借其卓越的存储设计，在这些方面提供了强有力的保障。本章将深入剖析 RocketMQ 如何在节点故障或宕机情况下快速恢复，并解读其基于主从复制的 HA（High Availability，高可用）机制，同时提供实践优化建议。
一、故障恢复：Broker 异常重启的坚固防线
故障恢复主要指单个 Broker 节点因断电、宕机、Crash 或正常重启后，如何保证 CommitLog 和 ConsumeQueue 的数据一致性，并快速恢复至宕机前状态。
其核心设计思想是：定长追加写的物理结构 + 高效索引重建机制。
1. 恢复流程剖析
Broker 启动时的恢复流程主要包括：
(1) 文件检测与验证
- 遍历 ${ROCKET_HOME}/store 目录下的 CommitLog、ConsumeQueue、IndexFile 文件。
- 检查文件 魔法数 与 物理长度，确保文件完整性与合法性。
(2) 恢复 CommitLog 与 ConsumeQueue
- 核心问题：消息先写入 CommitLog，再异步构建 ConsumeQueue，宕机可能导致 ConsumeQueue 数据落后。
- 恢复机制：
- 找到最后一个完整的 CommitLog 文件。<
)