RocketMQ Broker消息刷盘源码解析是怎样的？

本文共计2096个文字，预计阅读时间需要9分钟。

目录前言磁盘相关类介绍Broker刷盘源码分析CommitLog构造属性赋值TransientStorePoolEnabled介绍消息保存源码分析消息刷盘入口方法源码分析总结前言我们在学习RocketMQ的时候，了解到以下内容：

目录

• 前言
• 刷盘相关类介绍
• Broker刷盘源码分析
• CommitLog构造&属性赋值
• TransientStorePoolEnabled介绍
• 消息保存源码分析
• 消息刷盘入口方法源码分析
• 总结

前言

我们在学习RocketMQ的时候，我们知道RocketMQ的刷盘策略有两个刷盘策略

• 同步刷盘

同步刷盘即Broker消息已经被持久化到硬盘后才会向客户端返回成功。同步刷盘的优点是能保证消息不丢失，但是这是以牺牲写入性能为代价的。

• 异步刷盘

异步刷盘是指Broker将信息存储到pagecache后就立即向客户端返回成功，然后会有一个异步线程定时将内存中的数据写入磁盘，默认时间间隔为500ms。