最近公司使用到了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！！！