RocketMQ双Master集群搭建

一般情况下，双Master集群 就够用了！单机很简单，现在就直接说双master

 a 服务器：

121.43.181.101 

b 服务器： 

47.114.41.151

1, 下载安装包 （a,b）

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip
unzip rocketmq-all-4.3.0-bin-release.zip -d ~
cd ~
mv rocketmq-all-4.3.0-bin-release rocketmq

　　

2.可以对runserver.sh和runbroker.sh进行修，降低配置 （a,b）

#进入bin目录
cd /usr/local/rocketMQ/rocketmq-4.7/bin/

#编辑runserver.sh
vim runserver.sh 
#找到JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
#修改成可接受范围
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx521m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
 
#编辑runbroker.sh
vim runbroker.sh 
#找到JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
#修改成可接受范围
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"

3，修改配置文件rocketmq/conf/2m-noslave/broker-a.properties  （a） ip换自己的。存储目录自己建立自己的，然后指定。

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

namesrvAddr=121.43.181.101:9876;47.114.41.151:9876
# 是否允许 broker 自动创建topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许 broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true

# broker 对外服务的监听端口
listenPort=10911
brokerIP1=121.43.181.101

# 存储路径
storePathRootDir=/lbian/rocketmq/store
# commitLog 存储路径
storePathCommitLog=/lbian/rocketmq/store/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/lbian/rocketmq/store/consumequeue
# 消息索引存储路径
storePathIndex=/lbian/rocketmq/store/index
# checkpoint 文件存储路径
storeCheckpoint=/lbian/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/lbian/rocketmq/store/abort
# 限制的消息大小
maxMessageSize=65536

4，修改配置文件rocketmq/conf/2m-noslave/broker-b.properties （b） ip换自己的。存储目录自己建立自己的，然后指定。

brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

namesrvAddr=121.43.181.101:9876;47.114.41.151:9876

# 是否允许 broker 自动创建topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许 broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true

# broker 对外服务的监听端口
listenPort=10911
brokerIP1=47.114.41.151

# 存储路径
storePathRootDir=/lbian/rocketmq/store
# commitLog 存储路径
storePathCommitLog=/lbian/rocketmq/store/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/lbian/rocketmq/store/consumequeue
# 消息索引存储路径
storePathIndex=/lbian/rocketmq/store/index
# checkpoint 文件存储路径
storeCheckpoint=/lbian/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/lbian/rocketmq/store/abort
# 限制的消息大小
maxMessageSize=65536

5, 启动：

　　

启动 路径： cd /lbian/rocketmq/rocketmq-all-4.7.1-bin-release/bin

a , b 执行

nohup sh mqnamesrv >/lbian/rocketmq/logs/namesrv.log 2>&1 &


a 执行

nohup sh mqbroker -n 127.0.0.1:9876 autoCreateTopicEnable=true -c /lbian/rocketmq/rocketmq-all-4.7.1-bin-release/conf/2m-noslave/broker-a.properties &>/lbian/rocketmq/logs/broker.log 2>&1 &


b 执行

nohup sh mqbroker -n 127.0.0.1:9876 autoCreateTopicEnable=true -c /lbian/rocketmq/rocketmq-all-4.7.1-bin-release/conf/2m-noslave/broker-b.properties &>/lbian/rocketmq/logs/broker.log 2>&1 &

　　

6，服务停止

sh mqshutdown broker
sh mqshutdown namesrv

参考博文：

https://blog.csdn.net/qiushisoftware/article/details/78944579?utm_medium=distribute.pc_relevant.none-task-blog-title-3&spm=1001.2101.3001.4242

https://www.cnblogs.com/WangHaiMing/p/7565181.html

https://blog.csdn.net/herovictor_/article/details/106071924

http://www.chinacion.cn/article/4225.html