RocketMQ4.3 双master模式搭建
一 环境说明：
主机1 centos7 192.168.214.130
主机2 centos7 192.168.214.132
RocketMQ4.3 源码获取地址：http://rocketmq.apache.org/release_notes/release-notes-4.3.0/
二 准备工作
（1）修改两台服务器的hosts文件
vim /etc/hosts
加入以下内容
192.168.214.130 rocketmq-nameserver1
192.168.214.130 rocketmq-master1
192.168.214.132 rocketmq-nameserver2
192.168.214.132 rocketmq-master2
（2）重启网络，关闭防火墙
systemctl network restart #重启网络
systemctl stop firewalld.service # 关闭防火墙
（3）测试网络是否相通
三 环境搭建
1.下载rocketmq源码后，在本地解压然后，用cmd 进入解压后的根目录
2.用maven命令进行打包
mvn -Prelease-all -DskipTests clean install -U
执行后，在源码文件distribution/target/apache-rocketmq的目录下，可以查看到打好的tar包
然后将apache-rocketmq.tar.gz 上传至两台服务器
3.在两台服务器的 /usr/local 路径创建apache-rocketmq 文件夹(两台服务器)
cd /usr/local
mkdir apache-rocketmq
4 将apache-rocketmq.tar.gz解压到 /usr/local/apache-rocketmq 路径下(两台服务器)
tar -zxvf apache-rocketmq.tar.gz -C /usr/local/apahce-rocketmq
5 创建存储文件夹(两台服务器)：
mkdir /usr/local/apache-rocketmq/store
mkdir /usr/local/apache-rocketmq/store/commitlog
mkdir /usr/local/apache-rocketmq/store/consumequeue
mkdir /usr/local/apache-rocketmq/store/index
6、修改两台机器的配置文件：
（1）192.168.214.130 修改broker-a.properties 这个配置文件
cd /usr/local/apache-rocketmq/conf/2m-noslave/
vim /usr/local/apache-rocketmq/conf/2m-noslave/broker-a.properties
删除文件中的原有内容，并添加以下内容
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a #0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/usr/local/apache-rocketmq/store
#commitLog 存储路径
storePathCommitLog=/usr/local/apache-rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/apache-rocketmq/store/consumequeue
#消息索引存储路径
storePathIndex=/usr/local/apache-rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/usr/local/apache-rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/usr/local/apache-rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
（2）192.168.214.132这台服务器 修改broker-b.properties 这个配置文件
cd /usr/local/apache-rocketmq/conf/2m-noslave/
vim /usr/local/apache-rocketmq/conf/2m-noslave/broker-b.properties
与borker-a.properties 一样删除原有内容，并添加上面的内容，注意:要把brokerName=broker-a 改为
brokerName=broker-b
修改日志配置文件：
mkdir -p /usr/local/rocketmq/logs
cd /usr/local/apache-rocketmq/conf && sed -i 's#${user.home}#/usr/local/apache-rocketmq#g' *.xml
7.Jvm 参数优化（两台服务器）
（1）broker启动脚本参数优化（根据自己的机器内存大小调整，楼主两台服务器内存大小都是1g）
vim /usr/local/apache-rocketmq/bin/runbroker.sh
(2) nameserver启动脚本参数优化
vim /usr/local/apache-rocketmq/bin/runserver.sh
7.环境搭建好了，下面启动（先启动nameserver后启动broker）
（1）nameserver启动（两台服务器）
cd /usr/local/apache-rocketmq/bin
nohup sh mqnamesrv &
查看nameserver启动日志
tail -f -n 500 /usr/local/apache-rocketmq/logs/rocketmqlogs/namesrv.log
（2）broker启动
#192.168.214.130 启动broker-a
nohup sh mqbroker -c /usr/local/apache-rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &
#192.168.214.132 启动broker-b
nohup sh mqbroker -c /usr/local/apache-rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &
查看broker启动日志
tail -f -n 500 /usr/local/apache-rocketmq/logs/rocketmqlogs/broker.log
输入jps 可以看到会有NamesrvStartup 和 BrokerStartup 这两个进程
OK，结束啦
参考文章：https://blog.****.net/jianghuiyun/article/details/77971136