企业官网建设流程全解析

RocketMQ 的底层通信完全基于 Netty 实现。

整体架构：

Broker 端：Netty 服务器，负责与客户端的连接请求处理
Producer/Consumer 端：Netty 客户端，负责与 Broker 的通信及请求响应处理
Netty 多线程模型：

RocketMQ 在 Netty 基础之上采用了多线程分离设计，将 I/O 线程和业务处理线程分开。

核心类：

类 职责
NettyRemotingServer 服务端实现，底层基于 ServerBootstrap
NettyRemotingClient 客户端实现
NettyServerConfig / NettyClientConfig 通信配置
连接感知：

Broker 通过 Netty 的 ChannelInboundHandlerAdapter#channelInactive() 可以实时感知到 Consumer/Producer 的下线。这为 Rebalance 和故障剔除提供了基础。

消息过滤源码剖析
RocketMQ 支持两种消息过滤方式：Tag 过滤和 SQL92 过滤。

Tag 过滤：

根据消息的 Tag 进行过滤
性能极高，在 ConsumeQueue 中存储了 Tag 的哈希码（8 字节），过滤时只需比对哈希值
一条消息只能有一个 Tag，这是它的主要限制
SQL92 过滤：

使用 SQL92 语法作为过滤规则表达式
可以过滤消息的属性和 Tag（在 SQL 语法中，Tag 的属性名称为 TAGS）
比 Tag 过滤更灵活，但性能开销更大
需要设置 Broker 配置项 enablePropertyFilter=true（默认为 false）
两种过滤方式的对比：

对比维度 Tag 过滤 SQL92 过滤
过滤依据 Tag 字符串 用户自定义属性 + Tag
性能 极高（哈希比对） 较低（解析 SQL + 遍历属性）
灵活性 低（只能一个 Tag） 高（复杂条件组合）
Broker 配置 默认开启 需 enablePropertyFilter=true
过滤表达式类型在源码中定义为 ExpressionType.TAG 和 ExpressionType.SQL92。SQL92 表达式需要先编译检查合法性，再使用编译后的表达式进行计算。

源码阅读实战建议
读完上面这些模块的源码剖析，你可能跃跃欲试了。这里给你几个实战建议：

1. 搭建源码调试环境：

从 GitHub 克隆 RocketMQ 源码
用 IDEA 导入 Maven 项目
先启动 NamesrvStartup，再启动 BrokerStartup
运行 example 模块中的示例代码进行调试
2. 阅读顺序建议：

阶段 模块 目的
第一阶段 remoting 理解网络通信基础
第二阶段 namesrv 理解路由注册与发现
第三阶段 store 理解存储核心（CommitLog + ConsumeQueue）
第四阶段 broker 理解服务端业务逻辑
第五阶段 client 理解生产者和消费者
3. 调试断点建议：

Producer 发送：DefaultMQProducerImpl#sendDefaultImpl
Consumer 拉取：PullMessageService#run
Broker 写入：CommitLog#putMessage
Broker 拉取：PullMessageProcessor#processRequest
Rebalance：RebalanceService#doRebalance
4. 善用日志：

RocketMQ 的日志非常详细，在 ~/logs/rocketmqlogs/ 目录下：

broker.log：Broker 运行日志
namesrv.log：NameServer 日志
store.log：存储相关日志
rocketmq_client.log：客户端日志
小结
这篇文章我们完整走了一遍 RocketMQ 源码的“地图”，通过 8 张流程图 + 代码片段，搞清楚了：

源码工程结构：各模块的职责划分，从哪里入手
NameServer：路由管理的 5 个核心数据结构、心跳注册流程
Broker：分层架构、启动流程、存储设计理念
消息发送：4 个核心步骤、Producer 启动流程、定时任务机制
消息拉取与消费：Push 消费者启动、长轮询的本质
CommitLog 写入：MappedFile 机制、锁策略、刷盘实现
ConsumeQueue 构建：ReputMessageService 的“消息重放”机制
Rebalance：触发入口、分配策略、广播与集群模式的区别
事务消息：半消息存储、回查机制的完整流程
消息重试与死信：16 次重试、指数退避、DLQ 处理
Netty 通信层：多线程模型、连接感知
消息过滤：Tag 与 SQL92 的原理与对比
恭喜你！ 从入门认知到架构原理，从存储机制到发送消费，从进阶特性到部署运维，再到今天的源码深入——你已经完整走过了 RocketMQ 学习的全过程。你现在已经是一名真正意义上的 RocketMQ 专家了。

源码阅读是一个长期的过程，不要指望一次性全部读懂。建议你带着问题去读——遇到生产环境的故障时，顺着调用栈去追源码；想优化性能时，去读相关模块的实现。带着目的读源码，事半功倍。

祝你在 RocketMQ 的进阶之路上越走越远！

系列文章：

入门认知篇 ✅
核心概念与架构篇 ✅
存储与原理篇（上）✅
存储与原理篇（中）✅
存储与原理篇（下）✅
事务消息 ✅
进阶应用篇 ✅
部署与运维篇 ✅
源码深入篇 ✅（本文）
整合实战篇 （待续…）