RocketMQ Broker消息存储机制源码解析是怎样的？

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

目录+前言+消息存储格式总览+CommitLog介绍+MappedFile详解+消息存储格式介绍+DefaultMessageStore介绍+消息存储源码分析+发送消息存储流程+消息预处理阶段+消息保存阶段+消息保存结果处理阶段

目录

• 前言
• 消息存储格式总览
• CommitLog介绍
• MappedFile详解
• 消息存储格式介绍
• DefaultMessageStore介绍
• 消息存储源码分析
• 发送消息存储流程
• 消息预处理阶段
• 消息保存阶段
• 消息保存结果处理阶段
• 总结

前言

前面我们介绍了RocketMQ是如何接收消息的，下面我们来介绍Broker是如何保存消息的。

消息存储格式总览

Broker消息存储主要包括CommitLog，ConsumerQueue和Index三个部分。

• CommitLog

CommitLog主要用于消息存储，所有topic的消息按顺序都存储在CommitLog中。