1 概述

多Master叢集模式指的是一個叢集無Slave，全是Maste。

優點：配置簡單，單個Master宕機或重啟維護對應用無影響，在磁碟配置為RAID10 時，即使機器宕機不可恢復情
由於RAID10 磁碟非常可靠，訊息也不會丟（非同步刷盤丟失少量訊息，同步刷盤一條不丟）。效能最高。

缺點：單臺機器宕機期間，這臺機器上未被消費的訊息在機器恢復之前不可訂閱，訊息實時性會受到受到影響。

1 環境資訊

2 安裝前準備工作

2.1 /etc/hosts配置

cat >> /etc/hosts << EOF
192.168.3.41       rocketmq-nameserver1
192.168.3.41       rocketmq-master1
192.168.3.42       rocketmq-nameserver2
192.168.3.42       rocketmq-master2
EOF
 

2.2 Java環境部署

在/usr/目錄下建立java目錄

mkdir /usr/local/java 
cd /usr/local/java 

下載jdk,然後解壓

curl -O http://download.oracle.com/otn-pub/java/jdk/8u171-b11/512cd62ec5174c3487ac17c61aaa89e8/jdk-8u171-linux-x64.tar.gz
tar -zxvf jdk-8u171-linux-x64.tar.gz -C /usr/local/java

設定環境變數

cat >> /etc/profile << EOF
#set java environment 
 

JAVA_HOME=/usr/local/java/jdk1.8.0_171
JRE_HOME=/usr/java/jdk1.8.0_171/jre 
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib 
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin 
export JAVA_HOME JRE_HOME CLASS_PATH PATH
EOF

讓修改生效

source /etc/profile

驗證JDK有效性

java -version 
java version "1.8.0_171"
Java(TM) SE Runtime Environment (build 1.8.0_171-b11)
Java HotSpot(TM) 64-Bit Server VM (build 25.171-b11, mixed mode)

3 安裝rocketmq

3.1 上傳解壓【兩臺機器操作】

mkdir /usr/local/rocketmq4.2
cd /usr/local/rocketmq4.2
curl -O https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip
unzip rocketmq-all-4.2.0-bin-release.zip
rm -f rocketmq-all-4.2.0-bin-release.zip
cd /usr/local
ln -s rocketmq4.2 rocketmq
ll /usr/local

3.2 建立儲存路徑【兩臺機器操作】

mkdir /usr/local/rocketmq/store
mkdir /usr/local/rocketmq/store/commitlog
mkdir /usr/local/rocketmq/store/consumequeue
mkdir /usr/local/rocketmq/store/index

3.3 RocketMQ配置檔案配置【兩臺機器】

vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties
vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties

broker-a.properties配置檔案內容如下：

#所屬叢集名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此處不同的配置檔案填寫的不一樣
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號分割
namesrvAddr=192.168.3.41:9876;192.168.3.42: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/alibaba-rocketmq/store
#commitLog 儲存路徑
storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog
#消費佇列儲存路徑儲存路徑
storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue
#訊息索引儲存路徑
storePathIndex=/usr/local/alibaba-rocketmq/store/index
#checkpoint 檔案儲存路徑
storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint
#abort 檔案儲存路徑
abortFile=/usr/local/alibaba-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
#發訊息執行緒池數量
#sendMessageThreadPoolNums=128
#拉訊息執行緒池數量
#pullMessageThreadPoolNums=128

broker-b.properties配置檔案內容如下：

#所屬叢集名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此處不同的配置檔案填寫的不一樣
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號分割
namesrvAddr=192.168.3.41:9876;192.168.3.42: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/alibaba-rocketmq/store
#commitLog 儲存路徑
storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog
#消費佇列儲存路徑儲存路徑
storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue
#訊息索引儲存路徑
storePathIndex=/usr/local/alibaba-rocketmq/store/index
#checkpoint 檔案儲存路徑
storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint
#abort 檔案儲存路徑
abortFile=/usr/local/alibaba-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
#發訊息執行緒池數量
#sendMessageThreadPoolNums=128
#拉訊息執行緒池數量
#pullMessageThreadPoolNums=128

3.4 修改日誌配置檔案【兩臺機器】

mkdir -p /usr/local/rocketmq/logs
cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml

3.5 修改啟動指令碼引數【兩臺機器】

cd /usr/local/rocketmq/bin
vim runbroker.sh
#將JAVA_OPT修改為
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

vim runserver.sh
#將JAVA_OPT修改為
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

3.6 啟動NameServer【兩臺機器】

cd /usr/local/rocketmq/bin
nohup sh mqnamesrv &

3.7 啟動BrokerServer A【192.168.3.41】

cd /usr/local/rocketmq/bin
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties > /dev/null 2>&1 &
netstat -ntlp
jps
tail -500f  /usr/local/rocketmq/logs/rocketmqlogs/broker.log
tail -500f  /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

3.8 啟動BrokerServer B【192.168.3.42】

cd /usr/local/rocketmq/bin
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties > /dev/null 2>&1 &
netstat -ntlp
jps
tail -500f /usr/local/rocketmq/logs/rocketmqlogs/broker.log
tail -500f /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

下面的是我的公眾號二維碼，歡迎關注。文章轉載請註明出處www.leexide.com