RocketMQ相關(guān)文件及配置信息夕吻,
鏈接:?https://pan.baidu.com/s/1kV019l1?密碼: 8ete
RocketMQ不做多介紹,自行Google凿可。本文基于CentOS7惑折, Java 1.8.0_144。
搭建機(jī)器:
192.168.100.24枯跑,192.168.100.25惨驶。兩臺(tái)機(jī)器各部署一個(gè)NameServer、BrokerServer敛助。
1粗卜、基礎(chǔ)組件準(zhǔn)備【兩臺(tái)機(jī)器】
JDK,alibaba-rocketmq-3.2.6.tar.gz纳击,rocketmq-console.war
java環(huán)境续扔、apache-tomcat自行準(zhǔn)備。
注意防火墻端口9876是否開(kāi)放焕数,不然Broker不能互通纱昧。
2、hosts添加信息【兩臺(tái)機(jī)器】
文件:/etc/hosts
192.168.100.24.rocketmq-nameserv1
192.168.100.24 rocketmq-master1
192.168.100.24 rocketmq-nameserv2
192.168.100.24 rocketmq-master2
兩臺(tái)機(jī)器添加相同配置
3堡赔、上傳alibaba-rocketmq-3.2.6.tar.gz并解壓【兩臺(tái)機(jī)器】
cd /usr/local/devTool
tar -zxvf alibaba-rocketmq-3.2.6.tar.gz
mv alibaba-rocketmq alibaba-rocketmq-3.2.6
ln -s alibaba-rocketmq-3.2.6 rocketmq
4砌些、創(chuàng)建存儲(chǔ)路徑【兩臺(tái)機(jī)器】
cd /usr/local/devTool
mkdir -p rocketmq/store/{commitlog,consumequeue,index}
5、RocketMQ配置文件【兩臺(tái)機(jī)器】
vim /usr/local/devTool/rocketmq/conf/2m-noslave/broker-a.properties
vim /usr/local/devTool/rocketmq/conf/2m-noslave/broker-b.properties
配置信息:
#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字,注意此處不同的配置文件填寫的不一樣
brokerName=broker-a|broker-b
#0 表示 Master存璃, >0 表示 Slave
brokerId=0
#nameServer地址,分號(hào)分割
namesrvAddr=192.168.100.24:9876;192.168.100.25:9876
#在發(fā)送消息時(shí)雕拼,自動(dòng)創(chuàng)建服務(wù)器不存在的topic纵东,默認(rèn)創(chuàng)建的隊(duì)列數(shù)
defaultTopicQueueNums=4
#是否允許 Broker 自動(dòng)創(chuàng)建Topic,建議線下開(kāi)啟啥寇,線上關(guān)閉
autoCreateTopicEnable=true
#是否允許 Broker 自動(dòng)創(chuàng)建訂閱組偎球,建議線下開(kāi)啟,線上關(guān)閉
autoCreateSubscriptionGroup=true
#Broker 對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=10911
#刪除文件時(shí)間點(diǎn)辑甜,默認(rèn)凌晨 4點(diǎn)
deleteWhen=04
#文件保留時(shí)間衰絮,默認(rèn) 48 小時(shí)
fileReservedTime=120
#commitLog每個(gè)文件的大小默認(rèn)1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個(gè)文件默認(rèn)存30W條,根據(jù)業(yè)務(wù)情況調(diào)整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測(cè)物理文件磁盤空間
diskMaxUsedSpaceRatio=88
#存儲(chǔ)路徑
storePathRootDir=/usr/local/devTool/rocketmq/store
#commitLog 存儲(chǔ)路徑
storePathCommitLog=/usr/local/devTool/rocketmq/store/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/usr/local/devTool/rocketmq/store/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/usr/local/devTool/rocketmq/store/index
#checkpoint 文件存儲(chǔ)路徑
storeCheckpoint=/usr/local/devTool/rocketmq/store/checkpoint
#abort 文件存儲(chǔ)路徑
abortFile=/usr/local/devTool/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 異步復(fù)制Master
#- SYNC_MASTER 同步雙寫Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盤方式
#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#發(fā)消息線程池?cái)?shù)量
#sendMessageThreadPoolNums=128
#拉消息線程池?cái)?shù)量
#pullMessageThreadPoolNums=128
6.磷醋、修改日志配置文件【兩臺(tái)機(jī)器】
mkdir -p /usr/local/devTool/rocketmq/logs
cd /usr/local/devTool/rocketmq/conf && sed -i 's#${user.home}#/usr/local/devTool/rocketmq#g' *.xml
7猫牡、修改啟動(dòng)腳本參數(shù)【兩臺(tái)機(jī)器】
7.1、修改Broker配置文件
vim /usr/local/devTool/rocketmq/bin/runbroker.sh
7.2邓线、修改NameServer配置文件
vim /usr/local/devTool/rocketmq/bin/runserver.sh
8淌友、啟動(dòng) NameServer 【兩臺(tái)機(jī)器】
cd /usr/local/devTool/rocketmq/bin
nohup sh mqnamesrv &
tail -f -n 500 /usr/local/devTool/rocketmq/logs/rocketmqlogs/namesrv.log
9、啟動(dòng) BrokerServer? A【192.168.100.24】
注意是broker-a.properties文件
cd /usr/local/devTool/rocketmq/bin
nohup sh mqbroker -c /usr/local/devTool/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &
tail -f -n 500 /usr/local/devTool/rocketmq/logs/rocketmqlogs/broker.log
10骇陈、啟動(dòng)BrokerServer B【192.168.100.25】
注意是broker-b.properties文件
cd /usr/local/devTool/rocketmq/bin
nohup sh mqbroker -c /usr/local/devTool/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &
tail -f -n 500 /usr/local/devTool/rocketmq/logs/rocketmqlogs/broker.log
11震庭、tomcat部署RocketMQ Console【任意一臺(tái)機(jī)器】
上傳rocketmq-console.war到tomcat,webapp目錄下
11.1器联、解壓unzip rocketmq-console.war
unzip rocketmq-console.war -d rocketmq-console
11.2、修改rocketmq-console配置文件
修改config.properties配置文件
rocketmq.namesrv.addr=192.168.100.24:9876;192.168.100.25:9876
11.3婿崭、啟動(dòng)tomcat
cd /usr/local/devTool/apache-tomcat-7.0.75/bin/
./startup.sh
瀏覽器訪問(wèn): http://192.168.100.24:8080/rocketmq-console/cluster/list.do
12拨拓、數(shù)據(jù)清理【兩臺(tái)機(jī)器】
cd /usr/local/devTool/rocketmq/bin
sh mqshutdown broker
sh mqshutdown namesrv
--等待NameServer/Broker停止
rm -rf /usr/local/devTool/rocketmq/store
mkdir /usr/local/devTool/rocketmq/store
mkdir /usr/local/devTool/rocketmq/store/commitlog
mkdir /usr/local/devTool/rocketmq/store/consumequeue
mkdir /usr/local/devTool/rocketmq/store/index
--如果要重啟NameServer和BrokerServer,按照上面步驟重啟NameServer與BrokerServer