这是本人学习的总结，主要学习资料如下

• 马士兵教育
• rocketMq官方文档

---

1、Overview

这篇文章的源码的版本是release-4.9.8。在启动各个模块之前应该先对项目进行打包mvn install -Dmaven.test.skip=true。

2、NameServer

2.1、源码启动NameServer

NameServer的代码在namesrv模块。相关启动类是namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java。

在运行启动类之前需要设置一个ROCKETMQ_HOME的环境变量。运行期间RocketMQ需要的配置文件或者产生的文件都会以ROCKETMQ_HOME指定的路径作为根路径。

在ROCKETMQ_HOME指定的目录下创建三个文件夹conf，store和logs。

之后从在源代码的distribution模块下复制borker.conf，logback_broker.xml和logback_namesrv.xml到刚刚创建的conf文件夹下。

之后运行启动类，这样就算是启动成功。

3、Broker启动过程

在刚刚复制的broker.conf更改一些配置。主要是指定存储路径。以下是全部配置。

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH

namesrvAddr=127.0.0.1:9876
autoCreateTopicEnable=true
storePathRootDir=/Users/fulanbin/rocketmq/store
#commitLog存储路径
storePathCommitPath=/Users/fulanbin/rocketmq/store/commitlog
#消息队列存储路径
storePathConsumeQueue=/Users/fulanbin/rocketmq/store/consumequeue
#消息索引存储路径
storePathindex=/Users/fulanbin/rocketmq/store/index
#checkpoint文件存储路径
storeCheckpoint=/Users/fulanbin/rocketmq/store/checkpoint
#abort文件存储路径
abortFile=/Users/fulanbin/rocketmq/store/abort

在broker模块中找到broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java启动类，配置环境变量和启动参数。

Broker启动成功。