RocketMQ源码一，启动篇

1.2 源码结构目录

1.3 下载 Maven 依赖

# 填入命令&＃xff0c;并回车
mvn clean install -Dmaven.test.skip&＃61;true

1.4 调试
1.4.1 新建conf文件夹

 并将这三个配置copy到conf文件夹

 需要为 RocketMQ 配置环境变量

1.4.2 NameSrv 启动

成功&＃xff1a;

1.4.3 BrokerSrv 启动
新建 data 文件夹&＃xff0c;位置自定义&＃xff0c;用于存储 broker 数据

修改 config 文件夹下的 broker.conf 文件

brokerClusterName &＃61; DefaultCluster
brokerName &＃61; broker-a
brokerId &＃61; 0
# namesrvAddr地址
namesrvAddr&＃61;127.0.0.1:9876
deleteWhen &＃61; 04
fileReservedTime &＃61; 48
brokerRole &＃61; ASYNC_MASTER
flushDiskType &＃61; ASYNC_FLUSH
autoCreateTopicEnable&＃61;true#### 配置为上面设置的文件夹路径
# 存储路径
storePathRootDir&＃61;D:\\cass\\rocketmq-master\\data\\dataDir
# commitLog路径
storePathCommitLog&＃61;D:\\cass\\rocketmq-master\\data\\dataDir\\commitlog
# 消息队列存储路径
storePathConsumeQueue&＃61;D:\\cass\\rocketmq-master\\data\\dataDir\\consumequeue
# 消息索引存储路径
storePathIndex&＃61;D:\\cass\\rocketmq-master\\data\\dataDir\\index
# checkpoint文件路径
storeCheckpoint&＃61;D:\\cass\\rocketmq-master\\data\\dataDir\\checkpoint
# abort文件存储路径
abortFile&＃61;D:\\cass\\rocketmq-master\\data\\dataDir\\abort

找到 broker 项目&＃xff0c;启动项目

发现又要配置环境变量&＃xff0c;配置方式与NameSrv 相同

设置引用的配置文件&＃xff1a;

-c D:\cass\rocketmq-master\conf\broker.conf

启动项目

1.4.4 快速测试

找到 example 项目下的 quickstart

修改启动类&＃xff0c;配置 namesrv 服务地址

先启动 Producer 

再启动 Consumer 消费