RocketMQ双master集群搭建及控制台

野性酷女 2022-05-14 09:36 264阅读 0赞

*  RocketMQ双master集群搭建

服务器：172.16.101.36、172.16.101.37

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;"> 上传rocketmq-3.5.8.tar.gz&nbsp; 到&nbsp; /home/jyapp tar &nbsp;zxvf &nbsp;rocketmq-3.5.8.tar.gz mv &nbsp;alibaba-rocketmq &nbsp;rocketmq-3.5.8 ln &nbsp;-s &nbsp;rocketmq-3.5.8 &nbsp;rocketmq &nbsp; &nbsp; 添加 /etc/hosts（使用root用户）【 两台机器】 172.16.101.36 &nbsp;rocketmq-nameserver1 172.16.101.36 &nbsp;rocketmq-master1 172.16.101.37 &nbsp;rocketmq-nameserver2 172.16.101.37 &nbsp;rocketmq-master2 &nbsp; &nbsp; 创建存储路径【 两台机器】 mkdir &nbsp;/home/jyapp/rocketmq/store mkdir &nbsp;/home/jyapp/rocketmq/store/commitlog mkdir &nbsp;/home/jyapp/rocketmq/store/consumequeue mkdir &nbsp;/home/jyapp/rocketmq/store/index &nbsp; &nbsp; 修改conf/2m-noslave下配置文件【 两台机器】 备份原本的broker-a.properties、broker-b.properties cp&nbsp; &nbsp;broker-a.properties&nbsp; &nbsp;broker-a.properties.default cp&nbsp; &nbsp;broker-b.properties&nbsp; &nbsp;broker-b.properties.default 上传新的broker-a.properties、broker-b.properties &nbsp; &nbsp; 修改conf下所有logback的日志输出目录 mkdir &nbsp;/home/jyapp/rocketmq/logs cd &nbsp;/home/jyapp/rocketmq/conf sed -i 's#${user.home}#/home/jyapp/rocketmq#g' *.xml &nbsp; &nbsp; 修改bin下的runbroker.sh、runserver.sh，调整JVM内存和gc log输出目录 cd &nbsp;/home/jyapp/rocketmq/bin mkdir &nbsp;/home/jyapp/rocketmq/logs/gclogs runbroker.sh 调整为 -Xms8g &nbsp;-Xmx8g &nbsp;-Xmn4g -Xloggc:/home/jyapp/rocketmq/logs/gclogs/rmq_bk_gc.log 增加 -XX:+PrintGCDateStamps runserver.sh 调整为&nbsp; -Xms4g&nbsp; -Xmx4g&nbsp; -Xmn2g -Xloggc:/home/jyapp/rocketmq/logs/gclogs/rmq_srv_gc.log 增加 -XX:+PrintGCDateStamps &nbsp; &nbsp; 启动nameserver【两台服务器】 nohup sh mqnamesrv &gt;/dev/null 2&gt;&amp;1 &amp; 启动BrokerServer A （172.16.101.36） nohup sh mqbroker -c /home/jyapp/rocketmq/conf/2m-noslave/broker-a.properties &gt;/dev/null 2&gt;&amp;1 &amp; 启动BrokerServer B （172.16.101.37） nohup sh mqbroker -c /home/jyapp/rocketmq/conf/2m-noslave/broker-b.properties &gt;/dev/null 2&gt;&amp;1 &amp; &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

# 二、安装rocketmq-console控制台 #

## 1、老版rocketmq-console ##

部署在 172.16.101.36

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;"> 将rocketmq-console-3.2.6.war上传到tomcat/webapps下 mv &nbsp;rocketmq-console-3.2.6.war &nbsp;rocketmq-console.war mkdir &nbsp;rocketmq-console unzip &nbsp;rocketmq-console.war &nbsp;-d &nbsp;rocketmq-console rm &nbsp;-f &nbsp;rocketmq-console.war &nbsp; &nbsp; 修改 rocketmq-console/WEB-INF/classes/config.properties rocketmq.namesrv.addr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876 throwDone=true &nbsp; 启动tomcat &nbsp; 访问： http://172.16.101.36:8080/rocketmq-console </td> 
 </tr> 
 </tbody> 
</table>

## 2、新版rocketmq-console ##

部署在 172.16.101.37

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;"> 上传&nbsp; rocketmq_console_ng.tar.gz&nbsp; 到&nbsp; /home/jyapp tar&nbsp; zxvf&nbsp; rocketmq_console_ng.tar.gz 检查 application.properties、logback.xml &nbsp; 启动 ./ startRocketMQConsole.sh 停止 stopRocketMQConsole.sh &nbsp; 访问： http://172.16.101.37:8081 </td> 
 </tr> 
 </tbody> 
</table>