RocketMQ 源码环境与 NameServer/Broker 启动

Corey2026/9/20大约 3 分钟

RocketMQ 系列 · 第 5/10 篇
上一篇：《SpringBoot 与注意点》 · 下一篇：《发送、拉取与负载均衡源码》

开头：会用 API 不够，线上抖动时要能读源码

客户端 API 固定，但 Broker 宕机、消息堆积、延迟不准 往往要追到 NameServer 路由、Netty RPC、CommitLog 刷盘。本篇搭建源码调试环境，并梳理 NameServer/Broker 启动链路与 remoting 模块 的 RPC 框架——后续发送、持久化、长轮询都建立在此之上。

一、源码环境搭建

仓库：https://github.com/apache/rocketmq

主要模块：

模块	职责
`namesrv`	NameServer
`broker`	Broker 进程
`store`	消息存储
`remoting`	Netty 远程调用
`client`	生产/消费客户端
`example`	示例

编译：

mvn clean install -Dmaven.test.skip=true

源码模块与编译

IDEA 导入与模块结构

distribution 中的 broker.conf

启动 NameServer

运行 org.apache.rocketmq.namesrv.NamesrvStartup：

-c namesrv.properties 指定配置
-p 打印生效参数（如 orderMessageEnable）

成功日志：The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876

NameServer 启动与参数

启动 Broker

运行 org.apache.rocketmq.broker.BrokerStartup，-c 指向 distribution/conf/broker.conf，-p/-m 查看配置。

Broker 启动入口

调试建议

RocketMQ 几乎无注释，线程与定时任务多，不建议大量断点
带着问题读：NameServer 端口怎么改？Broker 挂了 Producer 还能发吗？
分阶段：热身（启动结构）→ 小试（RPC/收发）→ 融汇（持久化/延迟）

读源码的三阶段方法

二、NameServer 启动过程

入口：NamesrvStartup → 构建并启动 NamesrvController（类似 MVC Controller，处理 Netty 请求）。

5.x 新增 ControllerManager、NameServer 侧 NettyRemotingClient（4.x NameServer 不对外发 Netty 请求）。

核心：RouteInfoManager 维护 Broker 路由表；整体风格是 Controller + Manager/Service + 内存 Table。

三、Broker 启动过程

BrokerStartup.createBrokerController() 加载核心配置：

BrokerConfig —— Broker 行为
MessageStoreConfig —— 存储（刷盘、路径等）
NettyServerConfig / NettyClientConfig —— 10911 等端口；Broker 既是 Server（对 Client）又是 Client（对 NameServer）
AuthConfig —— ACL

BrokerController.start() 节选：

this.messageStore.start();
this.timerMessageStore.start();      // 指定时间点延迟消息
this.remotingServer.start();
this.fastRemotingServer.start();     // VIP 通道
this.brokerOuterAPI.start();
this.topicRouteInfoManager.start();
registerBrokerAll(...);              // 向所有 NameServer 注册
this.brokerStatsManager.start();

Producer 可 setSendMessageWithVIPChannel(true)，Consumer 可 setVipChannelEnabled(true) 走 fast 通道。

Broker 核心组件启动

四、Netty 服务注册框架（remoting）

1. 谁需要 Server / Client？

NameServer、Broker：既有 RemotingServer 又有 RemotingClient
Producer/Consumer：主要是 Client；事务 Producer 还要响应 Broker 回查，需要 NettyServer

Channel 建立后 双向 RPC，Server 也可向 Client 推请求。

2. 协议与处理链

RemotingCommand：code（业务码）、opaque（请求 ID）、customHeader、body、flag（0 请求 / 1 响应）。

NettyRemotingServer.configChannel pipeline：Handshake → Encoder/Decoder → IdleState → ConnectionManage → NettyServerHandler → processMessageReceived。

3. processorTable

Map<Integer, Pair<NettyRequestProcessor, ExecutorService>>：按 code 注册处理器。
Broker：BrokerController.registerProcessor()；NameServer：GET_ROUTEINFO_BY_TOPIC 等。

Client 侧 ClientRemotingProcessor 统一处理 Broker 下行（如拉取响应、事务回查）。