一、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會略高。目前主宕機后，備機不能自動切換為主機，后續會支持自動切換功能。
二、環境准備
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
三、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
#所屬集群名字 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
#所屬集群名字 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
#所屬集群名字 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
#所屬集群名字 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
#所屬集群名字 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
以上配置文件需要設置不同值的選項為：
brokerId #0 表示 Master，>0 表示 Slave brokerRole #Broker 的角色 #- ASYNC_MASTER 異步復制Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerIP1 #本機提供服務的IP地址
補充一個配置:
slaveReadEnable=true #建議開啟,默認關閉
創建、編輯集群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
四、部署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/
https://juejin.im/post/5a911ea16fb9a0633f0e36a1
https://blog.csdn.net/sybnfkn040601/article/details/64920062