Broker消息持久化

在 RocketMQ 中，Broker 消息持久化，同步刷盘，同步复制是 RocketMQ 保证消息不丢失的方法

RocketMQ 如何保证消息不丢失

• 同步刷盘：Producer 发送消息时，Broker 收到消息后立即写入磁盘（同步刷盘），确保消息持久化。
• 同步复制：在主从架构中，消息会同步到从节点，只有主从都确认后才返回成功。
• ACK 机制：Producer 可设置 ack=1 或 ack=all，确保消息被 Broker 正确接收。
• 消息重试：发送失败时，Producer 会自动重试，Consumer 消费失败时也会触发重试机制。
• 持久化存储：消息存储在磁盘上的 CommitLog 文件中，即使 Broker 重启也能恢复。

此处分析下 RocketMQ Broker 是如何接受 Producer 的消息并存储的
同时也分析下几种类型的消息 Broker 都是如何处理的

具体的代码解析可以见

• note: broker 写消息与刷盘
• note: 事务消息提交/回滚事务，消息处理
• note: 延迟消息
• 5.x延迟消息-精确时间