一、前言

      在前一篇部落格中，小編向大家介紹瞭如何在Centos7中安裝RocketMQ。通過這種方法我們可以搭建出來一臺母機，通過這臺母機來進行克隆搭建出我們的叢集。

二、搭建環境

• Centos7

• Jdk1.8

• Rocketmq 3.2.6

三、為什麼要搭建叢集？

      伺服器叢集就是指將很多伺服器集中起來一起進行同一種服務，在客戶端看來就像是隻有一個伺服器。叢集可以利用多個計算機進行平行計算從而獲得很高的計算速度，也可以用多個計算機做備份，從而使得任何一個機器壞了整個系統還是能正常執行。

      可以減少單點故障數量，並且實現了群集化資源的高可用性

      一、集群系統可解決所有的伺服器硬體故障，當某一臺伺服器出現任何故障，如：硬碟、記憶體、CPU、主機板、I/O板以及電源故障，執行在這臺伺服器上的應用就會切換到其它的伺服器上。

      二、集群系統可解決軟體系統問題，我們知道，在計算機系統中，使用者所使用的是應用程式和資料，而應用系統執行在作業系統之上，作業系統又執行在伺服器上。這樣，只要應用系統、作業系統、伺服器三者中的任何一個出現故障，系統實際上就停止了向客戶端提供服務，比如我們常見的軟體宕機，就是這種情況之一，儘管伺服器硬體完好，但伺服器仍舊不能向客戶端提供服務。而叢集的最大優勢在於對故障伺服器的監控是基於應用的，也就是說，只要伺服器的應用停止執行，其它的相關伺服器就會接管這個應用，而不必理會應用停止執行的原因是什麼。

      三、集群系統可以解決人為失誤造成的應用系統停止工作的情況，例如，當管理員對某臺伺服器操作不當導致該伺服器停機，因此執行在這臺伺服器上的應用系統也就停止了執行。由於叢集是對應用進行監控，因此其它的相關伺服器就會接管這個應用。

四、Roctmq網路部署圖

      我們部署的mq叢集架構是：雙主雙從。

      RocketMQ 網路部署特點：

• Name Server 是一個幾乎無狀態節點，可叢集部署，節點之間無任何資訊同步。

• Broker 部署相對複雜，Broker 分為 Master 與Slave，一個 Master 可以對應多個 Slave，但是一個 Slave 只能對應一個 Master， Master 與Slave 的對應關係通過指定相同的 BrokerName，不同的 BrokerId 來定義， BrokerId 為 0 表示 Master，非 0 表示 Slave。 Master 也可以部署多個。每個 Broker 與Name Server 叢集中的所有節點建立長連線，定時註冊 Topic 資訊到所有 Name Server。

• Producer 與 Name Server 叢集中的其中一個節點（隨機選擇）建立長連線，定期從 Name Server 取Topic 路由資訊，並向提供 Topic 服務的 Master 建立長連線，且定時向 Master 傳送心跳。 Producer 完全無狀態，可
  叢集部署。

• Consumer 與 Name Server 叢集中的其中一個節點（隨機選擇）建立長連線，定期從 Name Server 取 Topic 路由資訊，並向提供 Topic 服務的 Master、 Slave 建立長連線，且定時向 Master、 Slave 傳送心跳。 Consumer既可以從 Master 訂閱訊息，也可以從 Slave 訂閱訊息，訂閱規則由 Broker 配置決定。

五、搭建過程

      根據《Centos7安裝RocketMQ》我們可以搭建一臺可以提供服務的mq。以這臺做母機，進行克隆。

      母機資訊如下：

      在前面的時候我們搭建好了一臺RocketMQ伺服器:

5.1 克隆其他的機器，並修改ip-mac等資訊

      通過這一臺主機克隆出三臺機器，修改相應的資訊如下：

5.2 設定hosts資訊

      依次修改每臺主機的hosts檔案：

vim /etc/hosts

      新增如下資訊：

192.168.137.4 mqnameserver1
192.168.137.5 mqnameserver2
192.168.137.6 mqnameserver3
192.168.137.7 mqnameserver4

5.3 修改broker的資訊

      Master1 - 192.168.137.4的配置：

[[email protected] bin]# vim broker.p

namesrvAddr=mqnameserver1:9876;mqnameserver2:9876;mqnameserver3:9876;mqnameserver4:9876
brokerIP1=192.168.137.4
brokerName=AresBroker1
brokerClusterName=AresCluster
brokerId=0
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
rejectTransactionMessage=false
fetchNamesrvAddrByAddressServer=false
storePathRootDir=/root/store
storePathCommitLog=/root/store/commitlog
flushIntervalCommitLog=1000
flushCommitLogTimed=false
deleteWhen=04
fileReservedTime=72
maxTransferBytesOnMessageInMemory=262144
maxTransferCountOnMessageInMemory=32
maxTransferBytesOnMessageInDisk=65536
maxTransferCountOnMessageInDisk=8
accessMessageInMemoryMaxRatio=40
messageIndexEnable=true
messageIndexSafe=false
haMasterAddress=
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
cleanFileForciblyEnable=true

      Slave1 - 192.168.137.5的配置（是Master1的從機）：

      說明：

192.168.137.5是192.168.137.4的從機，所以設定
brokerName=AresBroker1是相同的，
brokerId=1 要大於0，表示是從機，
brokerRole=SLAVE表示身份是從機。

[[email protected] bin]# vim broker.p 

namesrvAddr= mqnameserver1:9876; mqnameserver2:9876;mqnameserver3:9876; mqnameserver4:9876
brokerIP1=192.168.137.5
brokerName=AresBroker1
brokerClusterName=AresCluster
brokerId=1
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
rejectTransactionMessage=false
fetchNamesrvAddrByAddressServer=false
storePathRootDir=/root/store
storePathCommitLog=/root/store/commitlog
flushIntervalCommitLog=1000
flushCommitLogTimed=false
deleteWhen=04
fileReservedTime=72
maxTransferBytesOnMessageInMemory=262144
maxTransferCountOnMessageInMemory=32
maxTransferBytesOnMessageInDisk=65536
maxTransferCountOnMessageInDisk=8
accessMessageInMemoryMaxRatio=40
messageIndexEnable=true
messageIndexSafe=false
haMasterAddress=
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
cleanFileForciblyEnable=true 

      Master2-192.168.137.6的配置

      說明：

192.168.137.6是另一臺主機，
brokerName=AresBroker2 設定名字和另一個主機不一樣，
brokerId=0表示為主機，
brokerRole=ASYNC_MASTER表示是主機。

[[email protected] bin]# vim broker.p

namesrvAddr=mqnameserver1:9876;mqnameserver2:9876;mqnameserver3:9876;mqnameserver4:9876
brokerIP1=192.168.137.6
brokerName=AresBroker2
brokerClusterName=AresCluster
brokerId=0
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
rejectTransactionMessage=false
fetchNamesrvAddrByAddressServer=false
storePathRootDir=/root/store
storePathCommitLog=/root/store/commitlog
flushIntervalCommitLog=1000
flushCommitLogTimed=false
deleteWhen=04
fileReservedTime=72
maxTransferBytesOnMessageInMemory=262144
maxTransferCountOnMessageInMemory=32
maxTransferBytesOnMessageInDisk=65536
maxTransferCountOnMessageInDisk=8
accessMessageInMemoryMaxRatio=40
messageIndexEnable=true
messageIndexSafe=false
haMasterAddress=
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
cleanFileForciblyEnable=true

      Slave2-192.168.137.7配置：
      說明：

192.168.137.7是192.168.137.6的從機，配置中，
brokerName=AresBroker2配置的是broker的名字，要和192.168.137.6的brokerName相同，brokerId=1表示是從機，
brokerRole=SLAVE表示從機。

[[email protected] bin]# vim broker.p


namesrvAddr= mqnameserver1:9876; mqnameserver2:9876;mqnameserver3:9876; mqnameserver4:9876
brokerIP1=192.168.137.7
brokerName=AresBroker2
brokerClusterName=AresCluster
brokerId=1
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
rejectTransactionMessage=false
fetchNamesrvAddrByAddressServer=false
storePathRootDir=/root/store
storePathCommitLog=/root/store/commitlog
flushIntervalCommitLog=1000
flushCommitLogTimed=false
deleteWhen=04
fileReservedTime=72
maxTransferBytesOnMessageInMemory=262144
maxTransferCountOnMessageInMemory=32
maxTransferBytesOnMessageInDisk=65536
maxTransferCountOnMessageInDisk=8
accessMessageInMemoryMaxRatio=40
messageIndexEnable=true
messageIndexSafe=false
haMasterAddress=
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
cleanFileForciblyEnable=true

5.4 依次執行

      調整目錄到alibaba-rocketmq/bin下，

cd /usr/src/rocketmq/alibaba-rocketmq/bin

      然後通過

./play.sh

      執行，通過執行jps檢視服務啟動情況。如果兩個服務都啟動，就可以了。

      如果只有NamesrvStartup啟動了，可以通過如下命令啟動BrokerStartup：

nohup sh mqbroker -c broker.p

5.5 執行結果

      通過執行rocketmq-console控制檯可以看到：表示搭建成功。

四、小結

      個人理解，只要搭建了一臺伺服器，就可以很輕鬆的搭建出叢集，通過克隆虛擬機器就可以得到相似的機器，然後通過修改broker.p從而達到配置的目的。

      再次強調Master 與Slave 的對應關係通過指定相同的 BrokerName，不同的 BrokerId 來定義， BrokerId 為 0 表示 Master，非 0 表示 Slave。

      下一篇部落格將向大家介紹RocketMQ的使用，包括髮送和接收等。