RocketMQ3.2.6環(huán)境搭建

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

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末逛球,一起剝皮案震驚了整個(gè)濱河市千元,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌颤绕,老刑警劉巖幸海,帶你破解...
    沈念sama閱讀 216,843評(píng)論 6 502
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異奥务,居然都是意外死亡物独,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,538評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門氯葬,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)挡篓,“玉大人,你說(shuō)我怎么就攤上這事」傺校” “怎么了复局?”我有些...
    開(kāi)封第一講書(shū)人閱讀 163,187評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵我磁,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我,道長(zhǎng)惨险,這世上最難降的妖魔是什么倍宾? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,264評(píng)論 1 292
  • 正文 為了忘掉前任消约,我火速辦了婚禮趋惨,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘酷宵。我一直安慰自己亥贸,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,289評(píng)論 6 390
  • 文/花漫 我一把揭開(kāi)白布浇垦。 她就那樣靜靜地躺著炕置,像睡著了一般。 火紅的嫁衣襯著肌膚如雪溜族。 梳的紋絲不亂的頭發(fā)上讹俊,一...
    開(kāi)封第一講書(shū)人閱讀 51,231評(píng)論 1 299
  • 那天,我揣著相機(jī)與錄音煌抒,去河邊找鬼仍劈。 笑死,一個(gè)胖子當(dāng)著我的面吹牛寡壮,可吹牛的內(nèi)容都是我干的贩疙。 我是一名探鬼主播,決...
    沈念sama閱讀 40,116評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼况既,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼这溅!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起棒仍,我...
    開(kāi)封第一講書(shū)人閱讀 38,945評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤悲靴,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后莫其,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體癞尚,經(jīng)...
    沈念sama閱讀 45,367評(píng)論 1 313
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,581評(píng)論 2 333
  • 正文 我和宋清朗相戀三年乱陡,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了浇揩。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,754評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡憨颠,死狀恐怖胳徽,靈堂內(nèi)的尸體忽然破棺而出积锅,到底是詐尸還是另有隱情,我是刑警寧澤养盗,帶...
    沈念sama閱讀 35,458評(píng)論 5 344
  • 正文 年R本政府宣布缚陷,位于F島的核電站,受9級(jí)特大地震影響爪瓜,放射性物質(zhì)發(fā)生泄漏蹬跃。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,068評(píng)論 3 327
  • 文/蒙蒙 一铆铆、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧丹喻,春花似錦薄货、人聲如沸。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,692評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至鳍悠,卻和暖如春税娜,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背藏研。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 32,842評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工敬矩, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人蠢挡。 一個(gè)月前我還...
    沈念sama閱讀 47,797評(píng)論 2 369
  • 正文 我出身青樓弧岳,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親业踏。 傳聞我的和親對(duì)象是個(gè)殘疾皇子禽炬,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,654評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容