rocketmq那些事儿之本地调试环境搭建

Posted freeorange

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketmq那些事儿之本地调试环境搭建相关的知识,希望对你有一定的参考价值。

上一篇文章中我们已经介绍过rocketmq的集群环境搭建,然而在源码的学习中我们还需要进行本地的调试和问题的定位查找,毕竟还是在本地方便些,今天就说一说如何进行源码的本地调试

下载编译

对于rocketmq源码部分的学习,我们当然要先去官网将源码下载到本地,这里笔者使用的是4.5.2版本,从github上官网上下载:

https://github.com/apache/rocketmq

rocketmq版本:4.5.2

使用clean install编译,这里最好跳过test,要不太慢了


技术图片

技术图片

编译完成之后开始本地部署调试环境

单点环境配置

本地启动和集群部署顺序相同主要是两个,先启动namesrv再启动broker ,之前我有讲解过启动脚本,如果你有印象的话,主要涉及到的2个入口类如下,找到对应的启动类:

  • namesrv: org.apache.rocketmq.namesrv.NamesrvStartup
  • broker: org.apache.rocketmq.broker.BrokerStartup

技术图片

技术图片

在启动前将distribution下的conf下的,broker.conf,logback_broker.xml,logback_namesrv.xml放置到本地对应的文件夹下,我这里放到了E: ocketmqconf下,启动时添加参数进行加载

由于程序大多数默认地址都是设置的user.home开头,我们需要进行修改,这里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=E:
ocketmqstore
#commitLog 存储路径
storePathCommitLog=E:
ocketmqstorecommitlog
消费队列存储路径
storePathConsumeQueue=E:
ocketmqstoreconsumequeue
消息索引|存储路径
storePathindex=E:
ocketmqstoreindex
#checkpoint 文件存储路径
storeCheckpoint=E:
ocketmqstorecheckpoint
#abort 文件存储路径
abortFile=E:
ocketmqstoreabort

同样注意,不要有空格,空格会导致文件路径不正确,启动不了!

logback文件同时也要进行修改,为了区分namesrv和broker日志,用了两个文件夹

在logback_namesrv.xml中修改:${user.home}修改为E:/rocketmq/namesrvlog

在logback_broker.xml中修改:${user.home}修改为E:/rocketmq/brokerlog

至此基本的配置环境已经准备完毕

单点环境启动

设置ROCKETMQ_HOME环境变量,让应用找到配置文件,不设置则报错(源码部分可看出来),另外设置时一定要注意不要有空格,有空格也报错,如下:


技术图片

idea中设置环境变量:


技术图片

启动namesrv服务:


技术图片

继续启动broker,同样设置环境变量ROCKETMQ_HOME,然后BrokerStartup run启动下,可以看到报错,已经指定了ROCKETMQ_HOME怎么还报这个?因为未指定broker.conf配置文件,在集群部署的时候脚本后面参数这里也是有这个的,这里指定:

-c E: ocketmqconfroker.conf


技术图片

技术图片

这里需要注意如果未配置namesrv也会启动成功,此时未连接namesrv,最好去看下log日志确认下是否连接成功

日志部分可去查看brokerloglogs ocketmqlogs和namesrvloglogs ocketmqlogs的日志内容,如启动有问题控制台看不出来,可以在这里查看详细的启动日志信息,或调整日志配置文件等级查看更详细的内容

接下来通过org.apache.rocketmq.example.quickstart包快速启动生产者和消费者来进行本地测试,设置namesrv地址,producer.setNamesrvAddr("127.0.0.1:9876"),启动生产者org.apache.rocketmq.example.quickstart.Producer


技术图片

消费者同样设置namesrv地址,consumer.setNamesrvAddr("127.0.0.1:9876"),启动消费者org.apache.rocketmq.example.quickstart.Consumer


技术图片

console

为了本地观察的方便,将console也进行本地启动,便于本地调试观察,源码地址为:

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

我在本地将源码中新建了个模块,将代码导入,方便本地启动


技术图片

同样添加启动配置namesrv地址:


技术图片

启动之后浏览器访问8080端口成功


技术图片

至此单点环境算是搭建完毕,之后源码学习调试可以在此基础上进行了

双master环境配置

集群环境就不搭建slave了,直接双master来本地调试就好,先进行配置文件的修改,文件放置在E: ocketmqconf2m下:

broker-a 配置文件:

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911
#nameServer 地址 分号分割
namesrvAddr=127.0.0.1:9876
#存储路径
storePathRootDir=E:
ocketmq2mstore-a
#commitLog 存储路径
storePathCommitLog=E:
ocketmq2mstore-acommitlog
消费队列存储路径
storePathConsumeQueue=E:
ocketmq2mstore-aconsumequeue
消息索引|存储路径
storePathindex=E:
ocketmq2mstore-aindex
#checkpoint 文件存储路径
storeCheckpoint=E:
ocketmq2mstore-acheckpoint
#abort 文件存储路径
abortFile=E:
ocketmq2mstore-aabort

broker-b 配置文件:

brokerClusterName = DefaultCluster
brokerName = broker-b
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10921
#nameServer 地址 分号分割
namesrvAddr=127.0.0.1:9876
#存储路径
storePathRootDir=E:
ocketmq2mstore-b
#commitLog 存储路径
storePathCommitLog=E:
ocketmq2mstore-bcommitlog
消费队列存储路径
storePathConsumeQueue=E:
ocketmq2mstore-bconsumequeue
消息索引|存储路径
storePathindex=E:
ocketmq2mstore-bindex
#checkpoint 文件存储路径
storeCheckpoint=E:
ocketmq2mstore-bcheckpoint
#abort 文件存储路径
abortFile=E:
ocketmq2mstore-babort

注意其中的配置要写不同的端口避免冲突

日志部分自行参考单点环境配置下,这里不再介绍,也可以不设置直接启动,这里先启动broker-a

-c E: ocketmqconf2mroker-a.conf


技术图片

同样的方式启动broker-b,检查下日志没有报错就可以,同时可在console中观察集群是否部署成功


技术图片

总结

本文主要针对本地调试环境搭建进行一个说明,本身而言并不复杂,凡事都要自己动手去尝试,也许中间会出现各种各样的问题,但是解决了之后会对其印象更加深刻吧

以上内容如有问题欢迎指出,笔者验证后将及时修正,谢谢

以上是关于rocketmq那些事儿之本地调试环境搭建的主要内容,如果未能解决你的问题,请参考以下文章

3RocketMQ 源码解析之 源代码环境搭建

3RocketMQ 源码解析之 源代码环境搭建

3RocketMQ 源码解析之 源代码环境搭建

RocketMQ源码本地搭建调试

RocketMQ源码本地搭建调试

Nacos的那些事儿:集群搭建