rocketMq集羣環境搭建

RocketMq:
    分佈式隊列中間件，高可用
    可以保證嚴格的消息順序
    提供豐富的消息拉取模式
    高效的訂閱者水平擴展模式
    實時消息訂閱機制
    億級消息堆積能力
    消息失敗重試機制
    消息能夠查詢

RocketMq環境搭建：
    機器，xupan001,xupan002，xupan003，xupan004分別加入如下：

192.168.0.118 xupan001
192.168.0.119 xupan002
192.168.0.120 xupan003
192.168.0.38 xupan004

上傳 alibaba-rocketmq-3.2.6.tar.gz 到 /usr/local/devtools/rocketmq/     解壓

建立存儲路徑，說明（這裏能夠不建立，啓動的時候會自動建立）
    cd usr/local/devtools/rocketmq 建立存儲目錄： mkdir store logs
    cd usr/local/devtools/rocketmq/store  建立存儲目錄： mkdir commitlog consumequeue index

修改配置文件：
    cd /usr/local/devtools/rocketmq/alibaba-rocketmq/conf/2m-noslave

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

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

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

#nameServer地址，分號分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2: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/devtools/rocketmq/store

#commitLog 存儲路徑 
storePathCommitLog=/usr/local/devtools/rocketmq/store/commitlog 

#消費隊列存儲路徑存儲路徑 
storePathConsumeQueue=/usr/local/devtools/rocketmq/store/consumequeue

#消息索引存儲路徑
storePathIndex=/usr/local/devtools/rocketmq/store/index

#checkpoint 文件存儲路徑 
storeCheckpoint=/usr/local/devtools/rocketmq/store/checkpoint 

#abort 文件存儲路徑 
abortFile=/usr/local/devtools/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

============================================================================

替換配置文件：
    cd /usr/local/devtools/rocketmq/alibaba-rocketmq/conf 
     sed -i 's#${user.home}#/usr/local/devtools/rocketmq#g' *.xml

修改JVM：vim bin/runbroker.sh
    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m - XX:PermSize=128m -XX:MaxPermSize=320m"

編寫啓動腳本startNameServer.sh  1，2，3，4臺機器
#!/bin/bash
nohup sh mqnamesrv &

編寫腳本startBrokerServer.sh
xupan001:
nohup sh mqbroker -c /usr/local/devtools/rocketmq/alibaba-rocketmq/conf/2m-2s-async/broker-a.properties >/dev/null 2>&1 &

xupan002:
nohup sh mqbroker -c /usr/local/devtools/rocketmq/alibaba-rocketmq/conf/2m-2s-async/broker-b.properties >/dev/null 2>&1 &

xupan003:
nohup sh mqbroker -c /usr/local/devtools/rocketmq/alibaba-rocketmq/conf/2m-2s-async/broker-a-s.properties >/dev/null 2>&1 & 

xupan004:
nohup sh mqbroker -c /usr/local/devtools/rocketmq/alibaba-rocketmq/conf/2m-2s-async/broker-b-s.properties >/dev/null 2>&1 &

[root@xupan004 bin]# jps
2633 Jps
2588 BrokerStartup
2482 NamesrvStartup
[root@xupan004 bin]# 

 

 

 

xupan004控制檯：

rocketmq-console-ng-1.0.0.jar

[root@xupan004 console]# cat startConsole.sh 
java -jar rocketmq-console-ng-1.0.0.jar --server.port=8888 --com.rocketmq.sendMessageWithVIPChannel=false  --rocketmq.config.namesrvAddr=xupan001:9876;xupan002:9876;xupan003:9876;xupan004:987

rocketMq-console [root@xupan004 console]# pwd /usr/local/devtools/rocketmq/console