RocketMQ多master多salve集羣搭建

1、RocketMQ集羣模式簡介

單Master方式

風險比較大, 一旦Broker重啓或者宕機, 將致使整個環境不可用, 不建議線上使用.

多Master模式

一個集羣中沒有slave, 全是master, 例如2個master或者3個master. 
優勢:配置簡單, 性能最好，單個Master宕機或重啓對應用無影響, 磁盤配置爲RAID10時, 即便機器宕機不可恢復, 因爲RAID10磁盤很是可靠, 消息也不會丟(異步刷盤丟失少許信息, 同步刷盤一條不丟) 
缺點 : 單臺機器宕機期間, 這個機器上未被消費消息在機器恢復以前不可訂閱, 消息實時性受到影響 .

多Master多Slave模式, 異步複製

每一個 Master 配置一個 Slave，有多對Master-Slave，採用異步複製方式，主備有短暫消息延遲，毫秒級。 優勢：即便磁盤損壞，消息丟失的很是少，且消息實時性不會受影響，由於Master 宕機後，消費者仍然能夠從 Slave消費，此過程對應用透明。不須要人工干預。性能同Master 模式幾乎同樣。 缺點：Master 宕機，磁盤損壞狀況，會丟失少許消息。

多Master多Slave模式, 同步雙寫

每一個 Master 配置一個 Slave，有多對Master-Slave，採用同步雙寫方式，主備都寫成功，嚮應用返回成功。 優勢：數據與服務都無單點，Master宕機狀況下，消息無延遲，服務可用性與數據可用性都很是高 缺點：性能比異步複製模式略低，大約低 10%左右，發送單個消息的 RT會略高。目前主宕機後，備機不能自動切換爲主機，後續會支持自動切換功能。

2、環境準備

1.集羣角色及對應IP、主機環境

2.相關軟件版本

3.部署前環境準備：

1.關閉防火牆，關閉selinux(生產環境按需關閉或打開) 2.同步服務器時間，選擇公網ntpd服務器或者自建ntpd服務器 [root@es1 ~]# crontab -l #爲了方便直接使用公網服務器 #update time   */5 * * * *  /usr/bin/rdate -s time-b.nist.gov &>/dev/null 3.安裝配置Java環境 可參考此文章Java環境安裝部分https://www.cnblogs.com/panwenbin-logs/p/8138787.html
4.配置hosts(全部服務器)  172.16.150.131 rocketmq_master_01  172.16.150.132 rocketmq_master_02  172.16.150.133 rocketmq_master_03  172.16.150.134 rocketmq_slave_01  172.16.150.135 rocketmq_slave_02  172.16.150.136 rocketmq_slave_03

3、RocketMQ集羣部署

1.解壓RocketMQ到工做目錄，並建立數據及日誌目錄(若是沒有特別指定，如下操做均爲在集羣中全部機器上執行)

[root@rocketmq_master_01 ~]# tar xf alibaba-rocketmq-3.2.2.tar.gz -C /opt  #解壓至/opt目錄 [root@rocketmq_master_01 ~]# cd /opt && ln -sv alibaba-rocketmq-3.2.2  alibaba-rocketmq [root@rocketmq_master_01 ~]# mkdir -p /var/alibaba-rocketmq/{commitlog,consumequeue,index,logs,namesrv}  #數據及日誌目錄 [root@rocketmq_master_01 ~]# tree /var/alibaba-rocketmq/ [root@rocketmq_master_01 ~]# ll /opt/

2.目錄解析(根據部署的架構進入對應的目錄)

[root@rocketmq_master_01 ~]# cd /opt/alibaba-rocketmq/conf/ [root@rocketmq-master1 conf]# ll 總用量 36 drwxr-xr-x 2 root root   118 2019-03-28 17:08 2m-2s-async #多主多從異步刷新參考配置文件 drwxr-xr-x 2 root root   118 2019-03-28 17:08 2m-2s-sync　　 #多主多從同步刷新參考配置文件 drwxr-xr-x 2 root root   118 2019-06-04 10:10 2m-noslave　　 #多master參考配置文件 .... [root@rocketmq_master_01 conf]# mkdir 3m-3s-sync #因爲咱們的架構爲3主3從，因此新建一個目錄 [root@rocketmq_master_01 conf]# cd 3m-3s-sync/

3.建立配置文件

建立、編輯集羣broker配置文件

#所屬集羣名字
brokerClusterName=qgg_rocketmq-cluster

#broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b
brokerName=broker-a

#0 表示 Master，>0 表示 Slave
brokerId=0

#nameServer地址，分號分割
namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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

#檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88

#存儲路徑
storePathRootDir=/var/alibaba-rocketmq/
#commitLog 存儲路徑
storePathCommitLog=/var/alibaba-rocketmq/commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue
#消息索引存儲路徑
storePathIndex=/var/alibaba-rocketmq/index
#checkpoint 文件存儲路徑
storeCheckpoint=/var/alibaba-rocketmq/checkpoint
#abort 文件存儲路徑
abortFile=/var/alibaba-rocketmq/abort
#限制的消息大小
#maxMessageSize=65536

#刷CommitLog，至少刷幾個PAGE
#flushCommitLogLeastPages=4

#刷ConsumeQueue，至少刷幾個PAGE
#flushConsumeQueueLeastPages=2

#刷CommitLog，完全刷盤間隔時間
#flushCommitLogThoroughInterval=10000

#刷ConsumeQueue，完全刷盤間隔時間
#flushConsumeQueueThoroughInterval=60000 

#Broker 的角色
#- ASYNC_MASTER 異步複製Master
#- SYNC_MASTER 同步雙寫Master
#- SLAVE
brokerRole=SYNC_MASTER

#刷盤方式
#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=SYNC_FLUSH

#檢查事務消息,開源版本4.3以前沒有事務功能
checkTransactionMessageEnable=false
#發消息線程池數量
#sendMessageThreadPoolNums=128

#拉消息線程池數量
#pullMessageThreadPoolNums=128

#綁定IP地址，若是有多個網卡接口須要配置，不然報錯
brokerIP1=172.16.150.131

#Netty服務工做線程數量
serverWorkerThreads = 8

#Netty服務異步回調線程池線程數量
serverCallbackExecutorThreads = 2

#Netty Selector線程數量
serverSelectorThreads = 3

#控制單向的信號量 一次請求沒有響應
serverOnewaySemaphoreValue = 256

#控制異步信號量
serverAsyncSemaphoreValue = 64

#服務空閒心跳檢測時間間隔 單位秒
serverChannelMaxIdleTimeSeconds = 120

#Netty發送緩衝區大小
serverSocketSndBufSize = 65535

#Netty接受緩衝區大小
serverSocketRcvBufSize = 65535

#是否使用Netty內存池
serverPooledByteBufAllocatorEnable = true

broker-a.properties

#所屬集羣名字
brokerClusterName=qgg_rocketmq-cluster
#broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號分割
namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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=/var/alibaba-rocketmq/
#commitLog 存儲路徑
storePathCommitLog=/var/alibaba-rocketmq/commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue
#消息索引存儲路徑
storePathIndex=/var/alibaba-rocketmq/index
#checkpoint 文件存儲路徑
storeCheckpoint=/var/alibaba-rocketmq/checkpoint
#abort 文件存儲路徑
abortFile=/var/alibaba-rocketmq/abort
#限制的消息大小
#maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000 
#Broker 的角色
#- ASYNC_MASTER 異步複製Master
#- SYNC_MASTER 同步雙寫Master
#- SLAVE
brokerRole=SYNC_MASTER
#刷盤方式
#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#發消息線程池數量
#sendMessageThreadPoolNums=128
#拉消息線程池數量
#pullMessageThreadPoolNums=128
#綁定IP地址，若是有多個網卡接口須要配置，不然報錯
brokerIP1=172.16.150.132

#Netty服務工做線程數量
serverWorkerThreads = 8

#Netty服務異步回調線程池線程數量
serverCallbackExecutorThreads = 2

#Netty Selector線程數量
serverSelectorThreads = 3

#控制單向的信號量 一次請求沒有響應
serverOnewaySemaphoreValue = 256

#控制異步信號量
serverAsyncSemaphoreValue = 64

#服務空閒心跳檢測時間間隔 單位秒
serverChannelMaxIdleTimeSeconds = 120

#Netty發送緩衝區大小
serverSocketSndBufSize = 65535

#Netty接受緩衝區大小
serverSocketRcvBufSize = 65535

#是否使用Netty內存池
serverPooledByteBufAllocatorEnable = true

broker-b.properties

#所屬集羣名字 brokerClusterName=qgg_rocketmq-cluster #broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b brokerName=broker-c #0 表示 Master，>0 表示 Slave brokerId=0 #nameServer地址，分號分割 namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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=/var/alibaba-rocketmq/ #commitLog 存儲路徑 storePathCommitLog=/var/alibaba-rocketmq/commitlog #消費隊列存儲路徑存儲路徑 storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue #消息索引存儲路徑 storePathIndex=/var/alibaba-rocketmq/index #checkpoint 文件存儲路徑 storeCheckpoint=/var/alibaba-rocketmq/checkpoint #abort 文件存儲路徑 abortFile=/var/alibaba-rocketmq/abort #限制的消息大小 #maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=SYNC_MASTER #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #發消息線程池數量 #sendMessageThreadPoolNums=128 #拉消息線程池數量 #pullMessageThreadPoolNums=128 brokerIP1=172.16.150.133

broker-c.properties

#所屬集羣名字 brokerClusterName=qgg_rocketmq-cluster #broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b brokerName=broker-a #0 表示 Master，>0 表示 Slave brokerId=1 #nameServer地址，分號分割 namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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=/var/alibaba-rocketmq/ #commitLog 存儲路徑 storePathCommitLog=/var/alibaba-rocketmq/commitlog #消費隊列存儲路徑存儲路徑 storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue #消息索引存儲路徑 storePathIndex=/var/alibaba-rocketmq/index #checkpoint 文件存儲路徑 storeCheckpoint=/var/alibaba-rocketmq/checkpoint #abort 文件存儲路徑 abortFile=/var/alibaba-rocketmq/abort #限制的消息大小 #maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=SLAVE #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #發消息線程池數量 #sendMessageThreadPoolNums=128 #拉消息線程池數量 #pullMessageThreadPoolNums=128 brokerIP1=172.16.150.134

broker-a-s.properties

#所屬集羣名字 brokerClusterName=qgg_rocketmq-cluster #broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b brokerName=broker-b #0 表示 Master，>0 表示 Slave brokerId=1 #nameServer地址，分號分割 namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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=/var/alibaba-rocketmq/ #commitLog 存儲路徑 storePathCommitLog=/var/alibaba-rocketmq/commitlog #消費隊列存儲路徑存儲路徑 storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue #消息索引存儲路徑 storePathIndex=/var/alibaba-rocketmq/index #checkpoint 文件存儲路徑 storeCheckpoint=/var/alibaba-rocketmq/checkpoint #abort 文件存儲路徑 abortFile=/var/alibaba-rocketmq/abort #限制的消息大小 #maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=SLAVE #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #發消息線程池數量 #sendMessageThreadPoolNums=128 #拉消息線程池數量 #pullMessageThreadPoolNums=128 brokerIP1=172.16.150.135

broker-b-s.properties

#所屬集羣名字 brokerClusterName=qgg_rocketmq-cluster #broker名字，注意此處不一樣的配置文件填寫的不同，a.properties,就寫broker-a，b的就填寫b brokerName=broker-c #0 表示 Master，>0 表示 Slave brokerId=1 #nameServer地址，分號分割 namesrvAddr=rocketmq_master_01:9876;rocketmq_master_02:9876;rocketmq_master_03: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=/var/alibaba-rocketmq/ #commitLog 存儲路徑 storePathCommitLog=/var/alibaba-rocketmq/commitlog #消費隊列存儲路徑存儲路徑 storePathConsumeQueue=/var/alibaba-rocketmq/consumequeue #消息索引存儲路徑 storePathIndex=/var/alibaba-rocketmq/index #checkpoint 文件存儲路徑 storeCheckpoint=/var/alibaba-rocketmq/checkpoint #abort 文件存儲路徑 abortFile=/var/alibaba-rocketmq/abort #限制的消息大小 #maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=SLAVE #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #發消息線程池數量 #sendMessageThreadPoolNums=128 #拉消息線程池數量 #pullMessageThreadPoolNums=128 brokerIP1=172.16.150.136

broker-c-s.properties

以上配置文件須要設置不一樣值的選項爲：

brokerId      #0 表示 Master，>0 表示 Slave brokerRole #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerIP1 #本機提供服務的IP地址 

建立、編輯集羣nameserver配置文件

[root@rocketmq_master_01 conf]# cat namesrv.properties listenPort = 9876 serverWorkerThreads = 8 serverCallbackExecutorThreads = 2 serverSelectorThreads = 3 serverOnewaySemaphoreValue = 256 serverAsyncSemaphoreValue = 64 serverChannelMaxIdleTimeSeconds = 120 serverSocketSndBufSize = 65535 serverSocketRcvBufSize = 65535 serverPooledByteBufAllocatorEnable = true kvConfigPath=/var/alibaba-rocketmq/namesrv/

4.修改log及數據路徑

[root@rocketmq_master_01 3m-3s-sync]# cd /opt/alibaba-rocketmq/conf/ [root@rocketmq_master_01 conf]# sed -i 's#${user.home}#/var/alibaba-rocketmq#g' *.xml    #默認路徑爲用戶家目錄下

5.修改服務啓動腳本參數 

[root@rocketmq_master_01 conf]# cd ../bin/ [root@rocketmq_master_01 bin]# pwd /opt/alibaba-rocketmq/bin [root@rocketmq_master_01]# vim runbroker.sh #broker的啓動腳本

[root@rocketmq_master_01 bin]# vim runserver.sh  #nameserver啓動腳本

6.先依次啓動nameserver服務(必須)

[root@rocketmq_master_01 bin]# cd /opt/alibaba-rocketmq/bin [root@rocketmq_master_01 bin]# nohup sh mqnamesrv &   #啓動服務
[root@rocketmq_master_01 bin]# tailf /var/alibaba-rocketmq/logs/rocketmqlogs/namesrv.log  #查看打印日誌是否異常

7.啓動broker服務

[root@rocketmq_master_01 bin]#nohup sh mqbroker -c /opt/alibaba-rocketmq/conf/3m-3s-sync/broker-a.properties &  #注意，每臺服務啓動時指定的配置文件也要同時改變
[root@rocketmq_master_01 bin]# tailf /var/alibaba-rocketmq/logs/rocketmqlogs/broker.log

4、部署rockmq-console

因爲當前rocketmq版本較低，使用最新的rocketmq-console會有部分信息丟失的狀況，只能使用較低版本的，這裏使用的版本爲rocketmq-console-3.2.6，依賴Tomcat容器，具體操做步驟爲，：

1.unzip解壓war包 -d指定到某個目錄， 2.進入解壓目錄下WEB-INF/classes/目錄中 3.修改config.properties配置文件，添加name server地址，格式IP(域名):port 若是有多個，已;爲分割 4.將目錄移動到Tomcat docBase目錄下，並啓動

資源連接地址：

連接：https://pan.baidu.com/s/10NeEeBH8eugdYcDn6e02aQ 提取碼：aq1t 

界面展現：

經過console能夠看到，當前共有三個broker，每一個broker有兩臺服務器

注意事項：

1.配置文件名稱和服務器對應，a:master1 b:master2 .. 2.注意不一樣主機配置文件名稱不一樣，brokerNam也不一樣 3.每臺briker服務啓動時，注意要指定正確的配置文件 4.建議生產每一個服務使用screen命令啓動，不要使用nohup

參考文檔：

https://github.com/apache/rocketmq-externals/tree/release-rocketmq-console-1.0.0/rocketmq-console

https://github.com/apache/rocketmq-externals/blob/master/rocketmq-console/doc/1_0_0/UserGuide_CN.md

http://rocketmq.apache.org/docs/quick-start/

http://www.javashuo.com/article/p-ajjuqahi-br.html

https://blog.csdn.net/sybnfkn040601/article/details/64920062