RocketMQ的集群部署方式有多種，其中包括單個Master、多個Master、多Master多Slave模式（異步復制）以及多Master多Slave模式（同步雙寫）。本次以多Master集群模式為例搭建一個雙機Master的RocketMQ集群環境。
1、雙機Master服務器環境
序號 ip 用戶名 密碼 角色 模式
(1) 10.43.98.34 root nameServer1,brokerServer1 Master1
(2) 10.43.98.38 root nameServer1,brokerServer1 Master2
2、Host添加信息
對兩台機器同時執行vi /etc/hosts 輸入如下圖所示的信息
這里我們是將nameServer和broker部署在同一台機器上的，同樣也可以分開部署。
重啟網卡：service network restart
相互ping一下，在34機器上ping 10.43.98.38 ping rocketmq-nameserver2 ping rocketmq-master2 。 37機器上也一樣。
然后就是將RocketMQ的壓縮包進行解壓，解壓到/opt目錄下，並創建軟連接ln -s RocketMQ rocketmq
3、創建數據存儲路徑（兩台機器都要創建）
我是在/tmp目錄下來存儲產生的數據的，因此進入到/tmp目錄下
mkdir rocketmq
mkdir rocketmq/data
mkdir rocketmq/data/commitlog
mkdir rocketmq/data/consumerqueue
mkdir rocketmq/data/index
4、修改RocketMQ的配置文件:broker-a.properties broker-b.properties
配置文件位置：cd /opt/RocketMQ/conf/2m-noslave/
因為有兩個master主節點，所以主節點1啟動依賴broker-a.properties，主節點2啟動依賴broker-b.properties，如果是三個Master，那么還會有一個broker-c.properties，以此類推。
#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此處不同的配置文件填寫的不一樣
brokerName=broker-a|broker-b
#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
#刪除文件時間點，默認凌晨 0點
deleteWhen=00
#文件保留時間，默認 48 小時
fileReservedTime=120
#commitLog每個文件的大小默認1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個文件默認存30W條，根據業務情況調整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
#存儲路徑
storePathRootDir=/opt/rocketmq/data
#commitLog 存儲路徑
storePathCommitLog=/opt/rocketmq/data/commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=/opt/rocketmq/data/consumequeue
#消息索引存儲路徑
storePathIndex=/opt/rocketmq/data/index
#checkpoint 文件存儲路徑
storeCheckpoint=/opt/rocketmq/data/checkpoint
#abort 文件存儲路徑
abortFile=/opt/rocketmq/data/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
#發消息線程池數量
#sendMessageThreadPoolNums=128
#拉消息線程池數量
#pullMessageThreadPoolNums=128
brokerId=0表示是master，大於0則表示是slave；
另外BrokerName=broker-a要對應；在34機器上是broker-a，在第二台機器37上則是broker-b。分別在34和37上修改broker-a.properties和broker-b.properties。
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876。這個要和之前配置的名稱相互對應。
對外服務的通信端口是9876。
文件默認大小是1G，當寫滿后再自動創建。#commitLog每個文件的大小默認1G
5、修改日志配置文件
在創建的軟連接文件夾rocketmq下創建一個logs目錄 mkdir /opt/rocketmq/logs
然后執行cd /opt/rocketmq/conf && sed -i 's#${user.home}#/opt/rocketmq#g' *.xml進行日志文件的替換，sed是linux的替換命令。兩台機器同樣操作。
6、修改啟動腳本參數（JVM參數的調優）
因為我們之前將nameServer和broker放在了同一台機器上，所以需要分別對nameServer和broker進行jvm的性能調優。生產環境默認即可不要修改。
1）broker的調優
vi /opt/rocketmq/bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m - XX:PermSize=128m -XX:MaxPermSize=320m"
2）nameserver的調優
vi /opt/rocketmq/bin/runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m - XX:PermSize=128m -XX:MaxPermSize=320m"
7、啟動兩台機器的NameServer：先啟動兩台機器的NameServer，再啟動兩台機器的Borker，關機的時候順序相反，先關閉兩台機器的Broker，再關閉兩台機器的Nameserver。
# cd /opt/rocketmq/bin
# nohup sh mqnamesrv &
上面這條命令nohup是起一個守護線程。
mqadnin是管理員命令，mqfiltersrv是rocketmq的單獨組件，mqnamesrv是NameServer，mqbroker是Broker。
jps 查看進程
# tail -f -n 500 /opt/rocketmq/logs/rocketmqlogs/broker.log
# tail -f -n 500 /opt/rocketmq/logs/rocketmqlogs/namesrv.log
查看狀態。
8、啟動BrokerServer A 10.43.98.34和BrokerServer B 10.43.98.37
BrokerServer A 10.43.98.34
nohup sh mqbroker -c /opt/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &
netstat -ntlp
jps
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log
BrokerServer B 10.43.98.37
nohup sh mqbroker -c /opt/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &
netstat -ntlp
jps
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log