二、RocketMQ源码分析之Broker概述与同步消息发送原理与高可用设计及思考
1、Broker概述
Broker 在 RocketMQ 架构中的角色,就是存储消息,核心任务就是持久化消息,生产者发送消息给 Broker,消费者从 Broker 消费消息,其物理部署架构图如下:



备注:以上摘录自官方 RocketMQ 设计文档。
上述基本描述了消息中间件的架构设计,不仅限于 RocketMQ,不同消息中间件的最大区别之一在消息的存储上。
2、Broker存储设计概要

接下来从配置文件的角度来窥探 Broker 存储设计的关注点,对应代码(MessageStoreConfig)。
- storePathRootDir
设置Broker的存储根目录,默认为 $Broker_Home/store。 - storePathCommitLog
设置commitlog的存储目录,默认为$Broker_Home/store/commitlog。 - mapedFileSizeCommitLog
commitlog 文件的大小,默认为1G。 - mapedFileSizeConsumeQueue
consumeQueueSize,ConsumeQueue 存放的是定长的信息(20个字节,偏移量、size、tagscode),默认30w * ConsumeQueue.CQ_STORE_UNIT_SIZE。