首页 > 代码库 > RocketMQ 双主集群

RocketMQ 双主集群

2024-09-16 23:04:32   218人阅读

<style>* { margin: 0; padding: 0 } body { font: 13.34px helvetica, arial, freesans, clean, sans-serif; color: black; line-height: 1.4em; background-color: #F8F8F8; padding: 0.7em } p { margin: 1em 0; line-height: 1.5em } table { font-size: inherit; font: 100%; margin: 1em } table th { border-bottom: 1px solid #bbb; padding: .2em 1em } table td { border-bottom: 1px solid #ddd; padding: .2em 1em } input[type="text"],input[type="password"],input[type="image"],textarea { font: 99% helvetica, arial, freesans, sans-serif } select,option { padding: 0 .25em } optgroup { margin-top: .5em } pre,code { font: 12px Monaco, "Courier New", "DejaVu Sans Mono", "Bitstream Vera Sans Mono", monospace } pre { margin: 1em 0; font-size: 12px; background-color: #eee; border: 1px solid #ddd; padding: 5px; line-height: 1.5em; color: #444; overflow: auto; white-space: pre-wrap } pre code { padding: 0; font-size: 12px; background-color: #eee; border: none } code { font-size: 12px; background-color: #f8f8ff; color: #444; padding: 0 .2em; border: 1px solid #dedede } img { border: 0; max-width: 100% } abbr { border-bottom: none } a { color: #4183c4; text-decoration: none } a:hover { text-decoration: underline } a code,a:link code,a:visited code { color: #4183c4 } h2,h3 { margin: 1em 0 } h1,h2,h3,h4,h5,h6 { border: 0 } h1 { font-size: 170%; border-top: 4px solid #aaa; padding-top: .5em; margin-top: 1.5em } h1:first-child { margin-top: 0; padding-top: .25em; border-top: none } h2 { font-size: 150%; margin-top: 1.5em; border-top: 4px solid #e0e0e0; padding-top: .5em } h3 { margin-top: 1em } hr { border: 1px solid #ddd } ul { margin: 1em 0 1em 2em } ol { margin: 1em 0 1em 2em } ul li,ol li { margin-top: .5em; margin-bottom: .5em } ul ul,ul ol,ol ol,ol ul { margin-top: 0; margin-bottom: 0 } blockquote { margin: 1em 0; border-left: 5px solid #ddd; padding-left: .6em; color: #555 } dt { font-weight: bold; margin-left: 1em } dd { margin-left: 2em; margin-bottom: 1em }</style> <style></style>

RocketMQ 双主集群

环境：

主机名 环境 IP 角色
master1 Centos7 172.16.0.89 master1
master2 Centos7 172.16.0.221 master2

 

1.安装

安装这里选择在官网上下载源码包安装。

wget -O /data/softs/src/rocketmq.tar.gz 
tar -zxvf /data/softs/src/rocketmq.tar.gz
mv /data/softs/src/alibaba-rocketmq /data/softs/src/rocketmq
cd /data/softs/src/rocketmq && make && make install

2.修改配置

安装完成后可以在$ROCKETMQ_HOME/conf/2m-noslave 下找到所需的配置文件

需求修改的地方不多

master1 对应修改broker-a.properties文件,master2 对应修改broker-b.properties文件

brokerClusterName=rocketmq-cluster  #所属集群名字 这个名字要一致
brokerName=broker-a/broker-b    #这里2个分别对应文件名
brokerId=0
namesrvAddr=172.16.0.89:9876;172.16.0.221:9876
listenPort=10911 #Broker 对外服务的监听端口

3.启动服务

启动服务的顺序： nameserver----broker

关闭服务的顺序： broker----nameserver

对应命令：

nohup sh $ROCKETMQ_HOME/bin/mqnamesrv & #启动nameserver

nohup sh $ROCKETMQ_HOME/bin/mqbroker -n 172.16.0.89:9876 -c $ROCKETMQ_HOME/conf/2m-noslave/broker-a/b.properties &
#启动broker
###两台master 启动 指定的IP要一致,即指定到同1台nameserver上

mqadmin clusterList  -n 172.16.0.89:9876#查看集群信息

Edit By MaHua

RocketMQ 双主集群


联系
我们