参考资料:rocketmq那些事儿之本地调试环境搭建
编译代码下载下载地址:Github地址
单点部署执行步骤:
-
先将三个xml文件拷贝到本地对应目录文件夹下。我这里放到D:codeopensourcerocketmqconf目录下,启动时会指定这个配置文件
-
将broker.conf修改为如下(具体路径根据自己文件来)
brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH #nameServer 地址 分号分割 namesrvAddr=127.0.0.1:9876 #存储路径 storePathRootDir=D:\code\opensource\rocketmq\store #commitLog 存储路径 storePathCommitLog=D:\code\opensource\rocketmq\store\commitlog # 消费队列存储路径 storePathConsumeQueue=D:\code\opensource\rocketmq\store\consumequeue # 消息索引|存储路径 storePathindex=D:\code\opensource\rocketmq\store\index #checkpoint 文件存储路径 storeCheckpoint=D:\code\opensource\rocketmq\store\checkpoint #abort 文件存储路径 abortFile=D:\code\opensource\rocketmq\store\abort
-
将logback_namesrv.xml下所有${user.home}替换为D:/code/opensource/rocketmq/namesrv
-
将logback_broker.xml下所有${user.home}替换为D:/code/opensource/rocketmq/broker
-
部署NamesrvStartup(位置org.apache.rocketmq.namesrv.NamesrvStartup)
- 配置Program arguments:
-c D:codeopensourcerocketmqconfbroker.conf
- 配置Environment variables:
ROCKETMQ_HOME=D:codeopensourcerocketmq
-
再部署BrokerStartup(位置
org.apache.rocketmq.broker.BrokerStartup),配置同样如上
-
为了观察本地,需要把console本地启动,便于本地调试。源码地址为:https://github.com/apache/rocketmq-externals/tree/rocketmq-console-1.0.0。把console导入module进项目里
- 添加配置为Environment variables: rocketmq.config.namesrvAddr=127.0.0.1:9876
然后最后访问 http://localhost:8080



