RocketMq源码中，消息存储机制是如何实现的？

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

RocketMQ在存储消息时，最终是通过mmap映射成磁盘文件进行存储的。简要概述消息存储流程如下：

原文：

RocketMQ在存储消息的时候，最终是通过mmap映射成磁盘文件进行存储的，本文将消息的存储流程作一个整体梳理。源码版本是4.9.2+，主要的存储组件有如下4个：

+ CommitLog：存储业务层，接收消息。+ CommitLog：存储业务层，接收消息。

rocketmq在存储消息的时候，最终是通过mmap映射成磁盘文件进行存储的，本文就消息的存储流程作一个整理。源码版本是4.9.2
主要的存储组件有如下4个：
CommitLog：存储的业务层，接收“保存消息”的请求
MappedFile：存储的最底层对象，一个MappedFile对象就对应了一个实际的文件
MappedFileQueue：管理MappedFile的容器
AllocateMappedFileService：异步创建mappedFile的服务
对于rocketmq来说，存储消息的主要文件被称为CommitLog，因此就从该类入手。