rocketmq集羣部署（多master多slave異步）

1、最近公司在作隊列的技術選型，通過調研，決定使用rocketmq做爲整個架構的隊列層，咱們以前的公司是用RabbitMQ，集羣部署參考我以前的文章：RabbitMQ集羣部署；rocketmq集羣由NameServer和Broker兩種角色組成，NameServer是無狀態的能夠橫向部署多臺達到消除單點的目的；Broker分多master、多master多slave同步、多master多slave異步這三種部署方案，通常生產環境都使用的是多master多slave異步這種方案，關於這三種方案的優缺點對好比下：
多Master模式（2m-noslave） ：
一個集羣無Slave，全是Master，例如2個Master或者3個Master
優勢：配置簡單，單個Master宕機或重啓維護對應用無影響，在磁盤配置爲RAID10時，即便機器宕機不可恢復狀況下，因爲RAID10磁盤很是可靠，消息也不會丟（異步刷盤丟失少許消息，同步刷盤一條不丟）。性能最高。
缺點：單臺機器宕機期間，這臺機器上未被消費的消息在機器恢復以前不可訂閱，消息實時性會受到受到影響。
多Master多Slave模式，異步複製（2m-2s-async） ：
每一個Master配置一個Slave，有多對Master-Slave，HA採用異步複製方式，主備有短暫消息延遲，毫秒級。
優勢：即便磁盤損壞，消息丟失的很是少，且消息實時性不會受影響，由於Master宕機後，消費者仍然能夠從Slave消費，此過程對應用透明。不須要人工干預。性能同多Master模式幾乎同樣。
缺點：Master宕機，磁盤損壞狀況，會丟失少許消息。
多Master多Slave模式，同步雙寫（2m-2s-sync）
每一個Master配置一個Slave，有多對Master-Slave，HA採用同步雙寫方式，主備都寫成功，嚮應用返回成功。
優勢：數據與服務都無單點，Master宕機狀況下，消息無延遲，服務可用性與數據可用性都很是高
缺點：性能比異步複製模式略低，大約低10%左右，發送單個消息的RT會略高。目前主宕機後，備機不能自動切換爲主機，後續會支持自動切換功能。
2、環境
一、版本
JDK版本 ：openjdk version "1.8.0_161"
rocketmq版本：4.2.0
rocketmq-console-ng版本：1.0.0
二、角色
rocketmq-console-ng(監控管理)：
192.168.54.26:8080
NameServer：
192.168.47.183:9876
192.168.47.184:9876
broker：
192.168.47.183:10911 master broker-a
192.168.47.184:10911 slave broker-a
192.168.47.185:10911 master broker-b
192.168.47.186:10911 slave broker-b
3、部署
一、下載二進制包並解壓

mkdir /chj/app/rocketmq -p;cd /chj/app/rocketmq
wget http://mirrors.shu.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip

unzip rocketmq-all-4.2.0-bin-release.zip
二、撰寫配置文件，默認的配置不能知足咱們的需求，須要咱們本身添加定製相關的參數，因爲咱們要部署的是多master多slave的異步方案，因此咱們修改或者添加/chj/app/rocketmq/conf/2m-2s-async目錄下的配置文件便可（建議在broker的一臺節點上把全部的配置文件都撰寫好，統一分發到全部節點，保持全部節點的配置文件一致，起服務的時候不一樣的節點使用不一樣的配置文件便可，方便後期維護）
A、4個文件的差別配置

vim broker-a.properties

brokerName=broker-a
brokerId=0
brokerRole=ASYNC_MASTER

vim broker-a-s.properties

brokerName=broker-a
brokerId=1
brokerRole=SLAVE

vim broker-b.properties

brokerName=broker-b
brokerId=0
brokerRole=ASYNC_MASTER

vim broker-b-s.properties

brokerName=broker-b
brokerId=1
brokerRole=SLAVE

B、初了上面的配置每一個配置文件不同，下面的配置都同樣

#所屬集羣名字
brokerClusterName=rocketmq-cluster-test
#broker名字，注意此處不一樣的配置文件填寫的不同，
#brokerName=broker-a
#0 表示 Master，>0 表示 Slave
#brokerId=0
#nameServer地址，分號分割
namesrvAddr=192.168.47.183:9876;192.168.47.184: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=/chj/data/rocketmq/store
#commitLog 存儲路徑
storePathCommitLog=/chj/data/rocketmq/store/commitlog
#消費隊列存儲路徑存儲路徑
storePathConsumeQueue=/chj/data/rocketmq/store/consumequeue
#消息索引存儲路徑
storePathIndex=/chj/data/rocketmq/store/index
#checkpoint 文件存儲路徑
storeCheckpoint=/chj/data/rocketmq/store/checkpoint
#abort 文件存儲路徑
abortFile=/chj/data/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

三、啓動服務
NameServer啓動（兩個節點的啓動方法同樣）
cd /chj/app/rocketmq/&& nohup ./bin/mqnamesrv &
192.168.47.183上啓動Broker
cd /chj/app/rocketmq/&& nohup sh /chj/app/rocketmq/bin/mqbroker -c /chj/app/rocketmq/conf/2m-2s-async/broker-a.properties >/chj/log/rocketmq/broker-a.log >/dev/null 2>&1 &
192.168.47.184上啓動Broker
cd /chj/app/rocketmq/&& nohup sh /chj/app/rocketmq/bin/mqbroker -c /chj/app/rocketmq/conf/2m-2s-async/broker-a-s.properties >/chj/log/rocketmq/broker-a-s.log >/dev/null 2>&1 &
192.168.47.185上啓動Broker
cd /chj/app/rocketmq/&& nohup sh /chj/app/rocketmq/bin/mqbroker -c /chj/app/rocketmq/conf/2m-2s-async/broker-b.properties >/chj/log/rocketmq/broker-b.log >/dev/null 2>&1 &
192.168.47.186上啓動Broker
cd /chj/app/rocketmq/&& nohup sh /chj/app/rocketmq/bin/mqbroker -c /chj/app/rocketmq/conf/2m-2s-async/broker-b-s.properties >/chj/log/rocketmq/broker-b-s.log >/dev/null 2>&1 &
4、rocketmq-console-ng部署
rocketmq-console-ng是rocketmq的一個可視化的監控工具，項目地址：github地址，它能夠用傳統的部署方式也可使用docker的部署方式，咱們選擇docker這種方式部署。

docker pull styletang/rocketmq-console-ng
docker run  -itd -e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.47.183:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t styletang/rocketmq-console-ng

訪問192.168.54.26:8080，查看cluster狀態

PS：參考連接
http://blog.csdn.net/lovesomnus/article/details/51769977
http://blog.csdn.net/jayjjb/article/details/70140667