前 目 录 c~11巾的 推荐序 刚吕 第1 章阅读源代码前的准备·· 1.1 I 获取和调试 RocketMQ 的源代码 ···I I. I. I Eclipse 获取 RocketMQ 掠码 … ·2 1.1.2 Eclipse 调试 RocketMQ 源码 . ... 1.1.3 lntelliJ IDEA 获取 RocketMQ 源码 ………… … ………… . . 1.1.4 9 15 IntelliJ IDEA 调试 RocketMQ 源码 …………… ·· RocketMQ 源代码的目 录结构... . 27 1.3 RocketMQ 的设计理念和目标… ·28 1.3.1 设计理念 …………………… 28 1.3.2 设计目标 ……… E ………….. NameServer 架构设计…………… 31 2.2 NameServer 启动流程 ……·· 32 2.3 NameServer 路由 注册、故障 . 36 路由注册 …………………… 38 2.3.3 路由删除 …………………… 43 2.3.4 路由发现 ……………… …… 46 本章 小结…………··………… … 47 RocketMQ 消息发送· ..... ·49 3.2 认识 RocketMQ 消息…………… ·50 3.3 生产者启动流程 ……… … 3.3.J 51 初识 DefaultMQProducer 消息、发送者 ............... ...... 3.3.2 3.4 消息发送基本流程 ……………… ·56 3.4.1 消息长度，如正 ……………… 56 3.4.2 查找主题路由信息 … 3.4.3 选择消息队列 …………… 60 3.4.4 消息发送 ………………… 65 …. . 56 批量 消息发送…………………… 3.6 本章小结 4.1 仅供非商业用途或交流等习使用 51 消息生产者启动流程 ……… ·54 3.5 第4章 剔除………………………... 2.3.2 漫谈 RocketMQ 消息 发送… …… 49 RocketMQ路由中心 31 路由元信息 ………………… 36 3.1 28 N ame Serv er · · · · · · · · · · · · · · · · · · · · · · · · · 2.1 第3 章 … ··20 1.2 第2 章 2.4 2.3.1 71 …………………… 74 RocketMQ 消息存储· … 存储概要设计……… . .....… 75 …… ·75 IX 4.4 存储文件组织与内存映射………. 83 4.4.1 5.4.1 PullMessageService 实现 L MappedFileQueue 映射文件 队列 ………………· ·……… 84 4.5 4.6 4.4.2 MappedFile 内存映射文件… . . 87 4.4.3 TransientStorePool …… ……. . 93 5.5 Commitlog 文件 ………… ··95 4.5.2 ConsumeQueue 文件 ……… ··97 4.5.3 Index 索引文件 ………… 100 4.5.4 checkpoint 文件 ………….. 文件…··· ····… · 5.6 5.7 4.10 消息队列负载与重新分布 154 消息消 费过程…………… …….. 162 消息消费 …………………. 163 定时消息机制…… …….. ......… 176 5.7.2 start 方法 ………………. 178 文件… ……… …… … 108 4.9 消息拉取基本流程 ……… 138 5.7.1 load 方法 ………………… ·177 …… 105 4.6.2 根据消息更新 Index 索引 5.7.3 定时调度逻辑 ……………. · 179 5.8 消息过滤机制 …………………. . 181 5.9 顺序消息… ……………… …….. 186 消息队列与索引文件恢复…... 109 4.7.1 Broker 正常停止文件恢复 ···· 112 4.7.2 Broker 异常停止文件恢复 … 114 文件刷盘机制 5.4.3 136 5.6.3 消费进度管理 …………. . 171 ConumeQueue …………….. 107 4.8 ProcessQueue 实现机制 … 5.6.2 消息确认 （ACK）………… 167 4.6.1 根据消息更新 4.7 5.4.2 5.6.1 104 实 时更新消息消费队列与索引 A 机制… . ............... . ........ . . .. ... RocketMQ 存储文件… ……… · ·94 4.5.1 - JV 竹、 J 句、 消息发送存储流程 ………… .. . 78 消息拉取… Md JH川 4.3 5.4 t巾 初识消息存储…… ……………… ·76 都V 4.2 5.9.1 5.9.2 消息拉取 …………………. 187 5.9.3 消息消费 …………………. 188 5.9.4 消息队列锁实现 …………. . 195 ……………….. 115 4.8.1 Broker 同步刷盘 ………….. 116 4.8.2 Broker 异步刷盘 ………... 119 过期文件删除机制…………….. 122 消息队列负载 ……… ……. · 187 5.10 本章小结… … …………·…… ·196 第6章消息过滤FilterServer… 本章小结………………… .. 126 ... 198 6.1 ClassFilter 运行机制………… 198 ..... 127 6.2 FilterServer 注册剖析…………. . 199 5.1 RocketMQ 消息消 费概述… …… 127 6.3 类过滤模式订阅机制… 5.2 消息消费者初探……………… 128 6.4 消息拉取……………………… 205 5.3 消费者启动流程……………. 130 6.5 本章小结·············………… 206 第5章 RocketMQ消息消费·· 仅供非商业用途或交流学习佼m … ···202 x 8.5 ……… … ……… 240 『 A ’ 呵 呵』 叫L 战司 L 句 4·A ， 气 ＆ 4 且寸 句3 择 「L 句4 。o 选 叫发队 m 比白白白 , 叶 A 句J 付L 句J AM 量 送滤 M－批发过 － u 自U 1i f L ’ 配消消泊 n ，』一－ 第 “，句 q， A ，叫川吐 m旧t ω 川 e － 忘 11 丛峰叶川丁γ宁』4 作 工 体 nb ！尸机实 理 制 原 飞〈 －－ 复 整 阳 从时∞ 主 m州 R77 … mM nununu 2i oyEQJ D QJny 吁／寸 H咀也 市Ebnu 相 寸f 7.1.3 M 本章小结 实送州 RocketMQ主从同步（HA) 牛md12 第7章 原理 …………………… ··208 9.3 .1 TAG 模式过滤 GroupTransferService 实现 9.3.2 SQL 表达模式过滤 …… ··244 9.3.3 类过臆模式 原理 …… ......... .......... ... 210 ……… … 244 …… …… .. 245 7.1.4 HAC!ient 实现原理 ·· …… 211 9.4 事务消息…………........ … …… 247 7.1.5 HAConnecti on 实现原理 …… 214 9.5 Spring 整合 RocketMQ ……….. 250 7.2 RocketMQ 读写分离机制 …… 220 9.6 Spring C loud 整合 RocketMQ … ·251 7.3 本章小结·· ……… · ·… .. 223 9.7 RocketMQ 监控与运维命令… 258 第8章 RocketMQ 事务消息 ..... . 225 9.7.1 RocktetMQ 监控平台 搭建 … ·258 9.7.2 RocketMQ 管理命令 ……… 261 8.1 事务消息实现思想 …………. 225 9.8 应用场景分析… ……………….. 280 8.2 事务消息发送流程 ………… 226 9.9 本章小结 …………· ·· ···… …… 281 8.3 提交或因滚事务 ……………….. 232 8.4 事务消息回查 事务状态 …… … . . 233 附录A 仅供非商业用途或 交流学 习使用 参数说明… …· ... 282 ···· ····· .... .... ........ ..... ..... ·-·· ······· . 」－ 血事 句男 f24t ., C M·/ JqF ay U ,, ·..,...................................... 阅读源代码前的准备 研究 一 款开源中间件，首先我们需要了解它的整体架构以及如何在开发环境调试源 码，从代码入手才能快速熟悉一个开源项目，只有这样才能抽丝剥茧地理解透彻，了解 作者的设计思想和实现原理 。 本章将重点介绍 RocketMQ 的 整体设计理念以及如何调试 RocketMQ ，为后续源码阅读打下扎实的基础 。 本章重点内容如下 。 ·获取和调试 RocketMQ 源代码 • RocketMQ 源代码的目录结构 • RocketMQ 的设计理念和设计目标 1.1 获取和调试 RocketMQ 的源代码 RocketMQ 原先是阿里巴巴内部使用的消息中间件，于 2017 年提交到 Apache 基金 会成为 Apache 基金会的顶级开源项目， G itHub 代码 库链接： h ttps ://github .com/apache/ rocketmq.git 。 在 Github 网站上搜索 RocketMQ ，如1 图 1-1 所