跳到主要内容

三、RocketMQ源码分析之CommitLog消息存储机制

本文重点分析 Broker 接收到生产者发送消息请求后如何存储在 Broker 上，本文暂不关注事务消息机制。

本文前置篇:RocketMQ源码分析之Broker概述与同步消息发送原理与高可用设计及思考 。

RocketMQ 的存储核心类为 DefaultMessageStore,存储消息的入口方法为：putMessage。

在深入学习消息存储之前，我们先大概了解一下DefaultMessageStore的属性与构造方法。

1、消息存储分析​

1.1 DefaultMessageStore 概要​

其核心属性如下：

  • messageStoreConfig
    存储相关的配置，例如存储路径、commitLog文件大小，刷盘频次等等。
  • CommitLog commitLog
    comitLog 的核心处理类，消息存储在 commitlog 文件中。
  • ConcurrentMap&lt;String/\* topic \*/, ConcurrentMap<Integer/* queueId */, ConsumeQueue>>` consumeQueueTable
    topic 的队列信息。
  • FlushConsumeQueueService flushConsumeQueueService
    ConsumeQueue 刷盘服务线程。
  • CleanCommitLogService cleanCommitLogService
    commitLog 过期文件删除线程。
  • CleanConsumeQueueService cleanConsumeQueueService
    consumeQueue 过期文件删除线程。、
  • IndexService indexService
    索引服务。
  • AllocateMappedFileService allocateMappedFileService
    MappedFile 分配线程，RocketMQ 使用内存映射处理 commitlog、consumeQueue文件。
  • ReputMessageService reputMessageService