RocketMQ源码中Broker如何实现消息持久化刷盘机制？

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

目录+前言+磁盘服务源码分析+CommitRealTimeService磁盘源码分析+FlushRealTimeService磁盘源码分析+FlushRealTimeService磁盘源码分析+GroupCommitService磁盘源码分析+总结+前言+上篇章节我们介绍了消息刷盘的四种方式，本章节我们将深入分析...

目录

• 前言
• 刷盘服务源码分析
• CommitRealTimeService刷盘源码分析
• FlushRealTimeService刷盘源码分析
• GroupCommitService刷盘源码分析
• 总结

前言

上篇文章我们介绍了消息刷盘的四种方式，本篇文章我们来介绍Broker是如何实现这四种刷盘方式。

刷盘服务源码分析

Broker中的四种刷盘分别是由CommitRealTimeService，FlushRealTimeService，GroupCommitService将消息从内存中刷到磁盘上的。