面试题答案
一键面试1. 消息同步机制
- RocketMQ 主从架构采用异步复制的方式来同步消息。主节点在接收到消息并持久化到本地CommitLog文件后，会异步地将消息发送给从节点。从节点接收到消息后，同样会将其持久化到本地的CommitLog文件。
- 这种异步复制方式虽然不能像同步复制那样实时保证主从数据完全一致，但在性能上有较大优势，并且通过一些后续机制来尽量保证数据可靠性和一致性。
2. 故障检测机制
- 心跳检测：主从节点之间通过定时发送心跳包来维持连接和检测对方状态。从节点会定期向主节点发送心跳消息，主节点也会响应。如果主节点在一定时间内没有收到从节点的心跳，就会认为从节点可能出现故障；反之，从节点如果在一定时间内没有收到主节点的心跳，也会判定主节点可能故障。
- Broker 故障感知：除了心跳检测，RocketMQ 集群中的其他节点（如 NameServer）也会感知到 Broker（主节点或从节点）的故障情况。NameServer 会定期与各个 Broker 进行通信，若发现某个 Broker 长时间无响应，就会将其从可用节点列表中移除。
3. 故障切换流程
- 选举新主节点：当检测到主节点故障后，需要从从节点中选举出一个新的主节点。RocketMQ 目前并没有内置的自动选举机制，通常需要借助外部工具（如 Zookeeper 等）来实现选举功能。在选举过程中，从节点会向选举工具（如 Zookeeper）发送选举请求，选举工具根据一定的算法（如 Zab 协议等）来确定哪个从节点成为新的主节点。
- 角色转换：选举出的新主节点会将自己的角色从从节点转换为主节点，开始承担接收和处理新消息的任务。同时，其他从节点会更新自己的配置，将新主节点作为同步消息的目标。
4. 数据恢复与一致性保证
- 数据补齐：新主节点在承担主节点角色后，可能会存在部分消息在原主节点故障时还未同步到从节点的情况。此时，新主节点会与其他从节点进行数据比对，找出缺失的消息。通常通过对比CommitLog文件的偏移量等方式来确定缺失消息范围。
- 消息重同步：确定缺失消息后，新主节点会从其他拥有完整数据的从节点处获取这些缺失的消息，并将其持久化到本地CommitLog文件。然后，新主节点会通知其他从节点进行新一轮的消息同步，确保所有从节点的数据都与新主节点保持一致。
- Consumer 端处理：在故障切换过程中，Consumer 可能会因为主节点故障而短暂中断消费。当新主节点选举完成并恢复正常服务后，Consumer 会根据自身的消费进度（通常记录在 Broker 或外部存储中，如 OffsetStore）从正确的位置继续消费消息，从而保证消息的有序消费和一致性。
通过以上消息同步、故障检测、故障切换以及数据恢复等机制，RocketMQ 在主从架构下主节点故障时尽量保证了消息存储的可靠性以及消息的一致性。