RocketMQ源码深入剖析

先说结论：这门课不适合当入门课

如果你还没用过消息队列，或者只是听说过 RocketMQ 这个名字，直接点开这套源码分析会非常痛苦。它默认你已经知道消息队列在解决什么问题，也写过 Producer 发消息、Consumer 收消息的代码，甚至踩过消息重复、消息丢失、顺序消费这类坑。它真正面向的是：日常在用 RocketMQ、但遇到问题只能靠搜索引擎和试错来解决的后端开发；以及准备面试中高级岗位、需要把「会用」讲成「懂原理」的转岗或跳槽人群。

换句话说，这门课解决的不是「怎么用 RocketMQ」，而是「它为什么这么设计」。当你线上遇到消息堆积、消费位点回退、事务消息状态不明时，能不能从源码层面定位到是哪一环出的问题，这才是它要帮你补上的能力。

内容重心：五个模块，建议按这个顺序看

整套资料围绕五块展开：整体架构与 NameServer、消息存储、Producer、Consumer、分布式事务消息。这里最值得先啃的是消息存储和NameServer两块。存储决定了 RocketMQ 的吞吐和可靠性上限，CommitLog、ConsumeQueue、索引文件的组织方式，是理解后续所有问题的地基；NameServer 则是整个集群的路由中心，先搞清楚它怎么注册、怎么发现、怎么容错，后面看 Producer 和 Consumer 的路由逻辑才不会迷路。

Producer 和 Consumer 两块可以放在中间看，重点在发送端的重试与故障规避、消费端的负载均衡与位点管理。分布式事务消息放在最后，它依赖前面存储和发送流程的理解，单独看容易只记住「两阶段提交」这个结论，却说不清半消息到底存在哪、回查是怎么触发的。

需要提醒的是，这套资料以视频讲解为主，节奏偏跟读源码。如果基础薄弱，建议先自己搭一个单机环境跑起来，对着日志看一遍消息从发送到落盘再到消费的完整链路，再回头听讲解，效率会高很多。

学完能做什么，以及怎么配合练习

认真跟完并能自己复述关键流程的话，你应该能做到几件事：独立排查常见的消息堆积和消费异常，说清问题出在存储、路由还是消费端；在设计方案时判断某个需求该不该用事务消息、顺序消息，以及代价是什么；面试时把 RocketMQ 的存储模型和事务实现讲出自己的理解，而不是背概念。

练习方式上，不建议只看不写。每看完一个模块，回到本地环境打断点或加日志，验证讲解里的关键判断，比如消息写入 CommitLog 后 ConsumeQueue 是什么时候更新的、消费位点什么时候提交。遇到和自己理解不一致的地方，那往往就是真正学到东西的入口。这套资料更适合当「对照手册」反复翻，而不是一次性刷完的连续剧。