rocketmq如何修改存储路径

网友投稿 2351 2023-01-01

rocketmq如何修改存储路径

rocketmq如何修改存储路径

一、-rocketmq对应版本源码

修改消息存储路径需要修改rocketmq源码,因为rocketmq取的默认路径是user.home路径,也就是用户的根目录,如下所示

直接修改用户的user.home比较麻烦,我们打算直接修改源码里写死的路径,然后重新打包

-rocketmq源码可以去github,路径为https://github.com/apache/rocketmq

如果要下4.7.1版本的源码包可以选择对应release包

例如使用的rocketmq版本为4.7.1,则-路径为https://github.com/apache/rocketmq/tree/release-4.7.1

二、全局替换user.home参数为mq.store

我们用自定义参数mq.store代替默认的user.home,全局替换user.home为mq.store

三、重新打包

注意打包时要排除单元测试, 在源码根目录执行 mvn install -DskipTests

四、替换掉旧的jar包

打包完成后http://根据rocketmq运行需要替换对应的jar包,找到ROCKETMQ_HOME\lib目录,搜索rocket

根据这里的jar包名称,去刚刚打包好的项目源码目录去搜索,然后用打包好的新jar包替换掉原本的jar包,总共13个jar包需要替换,有些可能不需要替换,但是我没有仔细去排查,全部替换掉了,反正源码编译后和原来的一样

五、java启动参数新增mq.store

在项目里我们用mq.store替换掉了user.home,我们需要在启动参数里加入mq.store参数,以用于使用自定义的目录存储消息和日志

在rocketmq的bin目录下,找到并修改runbroker.cmd 和 runserver.cmd,如果是linux系统下使用,修改对应的.sh文件即可

六、修改日志文件路径

修改日志存放路径,需要修改如下文件,位于rocketmq的conf文件夹下

修改方式一样,都是在logback文件的节点里新增节点,在节点里配置rocketmq统一的日志存放路径,例如上文配置的是 D:\RocketMQ目录,

这里配置为

然后替换文件内所有的user.home,为MQ_STORE

class="ch.qos.logback.core.rolling.RollingFileAppender">

${MQ_STORE}/rocketmqlogs/broker_default.log

true

${MQ_STORE}/rocketmqlogs/otherdays/broker_default.%i.log.gz

1

10

100MB&lrJUHWYwt;/maxFileSize>

%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n

UTF-8

class="ch.qos.logback.core.rolling.RollingFileAppender">

${MQ_STORE}/rocketmqlogs/broker_default.log

true

${MQ_STORE}/rocketmqlogs/otherdays/broker_default.%i.log.gz

1

10

100MB&lrJUHWYwt;/maxFileSize>

%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n

UTF-8

class="ch.qos.logback.core.rolling.RollingFileAppender">

${MQ_STORE}/rocketmqlogs/broker.log

true

${MQ_STORE}/rocketmqlogs/otherdays/broker.%i.log.gz

1

20

128MB

%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n

UTF-8

class="ch.qos.logback.core.rolling.RollingFileAppender">

${MQ_STORE}/rocketmqlogs/broker.log

true

${MQ_STORE}/rocketmqlogs/otherdays/broker.%i.log.gz

1

20

128MB

%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n

UTF-8

......

七、编写一键启动文件

新建文本文件 start-rocketmq,修改后缀为.bat,内容如下,先后启动nameserver 和 broker

start mqnamesrv.cmd

start mqbroker.cmd -c ../conf/broker.conf namesrvAddr=127.0.0.1:9876 brokerIP1=127.0.0.1 autoCreateTopicEnable=true &

八、启动验证

记得如果要外部访问,上面的IP要改成局域网的ip,另外要对外开放 9876 10909 10911端口

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:app 跳转 小程序(app跳转小程序限制)
下一篇:一网通办工资总额申报(一网通办 工资申报)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~