标签：源码分析

kafka

源码分析RocketMQ刷盘机制

刷盘机制支持同步刷盘和异步刷盘。为了了解其具体事项，我们以 Commitlog 的存储为例来说明RocketMQ是如何进行磁盘读写。Comitlog#putMessage 首先，主要是将消息写入到 MappedFile,内存映射文件。然后根据刷盘策略刷写到磁盘，入口：CommitLog#putMessage handleDiskFlushCommit……