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

hosts配置

兩臺(tái)機(jī)器添加相同配置

查看是否能ping通

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

修改Broker配置文件

7.2邓线、修改NameServer配置文件

vim /usr/local/devTool/rocketmq/bin/runserver.sh

修改NameServer配置文件

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

啟動(dòng)NameServer

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

啟動(dòng) BrokerServer? A

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

啟動(dòng) BrokerServer ?B

11震庭、tomcat部署RocketMQ Console【任意一臺(tái)機(jī)器】

上傳rocketmq-console.war到tomcat，webapp目錄下

上傳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