最近公司使用到了RocketMQ,所以打算研究一下RocketMQ 准备自己动手搭建一下RocketMq源码
前提
需要搭建jdk环境，jdk版本需要高于1.8
首先
从github 拉源码
源码地址：rocketMq源码传送门
启动namesrv
启动之前需要配置一下ROCKERMQ_HOME
配置如下：
图片是我自己的一个ROCKETMQ_HOME的目录，你也可以将其指定到代码的distribution模块，如图
配置完成之后，找到namesrv模块的NamesrvStartup类，启动即可。
出现如下字样即启动成功
The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
至此，namesrv已启动完成，接下来启动borker.
同理，需要配置模块的ROCKETMQ_HOME,除此之外，还需要指定namesrv地址，否则borker无法注册到namesrv，导致后续系列问题
NAMESRV_ADDR=127.0.0.1:9876;ROCKETMQ_HOME=D:\project\rocketmq
出席之外还需要配置启动参数
-c D:\project\rocketmq\broker.conf autoCreateTopicEnable=true
broker.conf:为distribution模块下的broker.conf
autoCreateTopicEnable=true：表示是否自动创建主题
上述完成之后，找到broker的启动类，启动即可
出现如下字样即启动成功
The broker[broker-a, 127.0.0.1:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876
over！！！
