一、源码环境搭建

1、源码拉取

RocketMQ的官方Git仓库地址：https://github.com/apache/rocketmq

2、注解版源码引入

3、功能模块

功能模块

• broker: Broker 模块（broke 启动进程）
• client ：消息客户端，包含消息生产者、消息消费者相关类
• example: RocketMQ 例代码
• namesrv：NameServer模块
• store：消息存储模块
• remoting：远程访问模块

4、源码调试

mvn clean install -Dmaven.test.skip=true

在项目目录下创建一个conf目录，并从distribution拷贝broker.conf和logback_broker.xml和logback_namesrv.xml

4.1 启动nameServer

namesrv模块，运行NamesrvStartup

环境变量： ROCKETMQ_HOME