rocketmq集群配置

官網(wǎng)地址:https://rocketmq.apache.org/zh/docs/4.x/deployment/01deploy
參考文檔:
https://blog.csdn.net/wangqingjia/article/details/125408142
https://blog.csdn.net/lvxiucai/article/details/104907614

配置說明

使用倆臺機子赊时,部署同步刷新集群钧忽,slaver和master錯開部署誉己,可以防止一臺服務(wù)器宕機后囤锉,集群依然可用

ip broker
192.168.20.202 broker-a
192.168.20.202 broker-b-s
192.168.20.203 broker-b
192.168.20.203 broker-a-s

修改內(nèi)存

修改bin目錄下runserver.sh和runbroker.sh的內(nèi)存大小,網(wǎng)上有榔昔,就不做說明了

配置文件

在conf/2m-2s-sync文件夾中配置

image.png

image.png

在192.168.20.202中配置broker-a和broker-b-s
在192.168.20.203中配置broker-b和broker-a-s

1蜈项、broker-a

#下面是自帶的,可以不用動
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH

#這個是broker啟動端口晨雳,一個機子啟動多個broker一定要配置下
listenPort=10911
namesrvAddr=192.168.20.202:9876;192.168.20.203:9876

#這個是文件位置行瑞,同一機子上啟動多個broker一定要配置
storePathRootDir=/root/rocket/store-a
storePathCommitLog=/root/rocket/store-a/commitlog
storePathConsumeQueue=/root/rocket/store-a/consumequeue
storePathIndex=/root/rocket/store-a/index
storeCheckPoint=/root/rocket/store-a/checkpoint
abortFile=/root/rocket/store-a/abort

2、broker-b-s

#下面是自帶的餐禁,可以不用動
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH

#這個是broker啟動端口血久,一個機子啟動多個broker一定要配置下
listenPort=10918
namesrvAddr=192.168.20.202:9876;192.168.20.203:9876

#這個是文件位置,同一機子上啟動多個broker一定要配置
storePathRootDir=/root/rocket/store-b-s
storePathCommitLog=/root/rocket/store-b-s/commitlog
storePathConsumeQueue=/root/rocket/store-b-s/consumequeue
storePathIndex=/root/rocket/store-b-s/index
storeCheckPoint=/root/rocket/store-b-s/checkpoint
abortFile=/root/rocket/store-b-s/abort

3帮非、broker-b

brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH


listenPort=10911
namesrvAddr=192.168.20.202:9876;192.168.20.203:9876

storePathRootDir=/root/rocket/store-b
storePathCommitLog=/root/rocket/store-b/commitlog
storePathConsumeQueue=/root/rocket/store-b/consumequeue
storePathIndex=/root/rocket/store-b/index
storeCheckPoint=/root/rocket/store-b/checkpoint
abortFile=/root/rocket/store-b/abort

4氧吐、broker-a-s

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH


listenPort=10918
namesrvAddr=192.168.20.202:9876;192.168.20.203:9876


storePathRootDir=/root/rocket/store-a-s
storePathCommitLog=/root/rocket/store-a-s/commitlog
storePathConsumeQueue=/root/rocket/store-a-s/consumequeue
storePathIndex=/root/rocket/store-a-s/index
storeCheckPoint=/root/rocket/store-a-s/checkpoint
abortFile=/root/rocket/store-a-s/abort

啟動

1、啟動nameserver

分別在倆臺服務(wù)器上的rocket目錄下執(zhí)行下列命令

nohup sh bin/mqnamesrv &

通過jps命令查看到NamesrvStartup即啟動成功末盔,啟動成功會占用9876端口


image.png

2筑舅、啟動broker

1、192.168.20.202啟動主服務(wù)(broker-a)

nohup sh bin/mqbroker  -c conf/2m-2s-sync/broker-a.properties  &

2陨舱、192.168.20.203啟動主服務(wù)(broker-b)

nohup sh bin/mqbroker  -c conf/2m-2s-sync/broker-b.properties  &

3翠拣、192.168.20.202啟動從服務(wù)(broker-b-s)

nohup sh bin/mqbroker  -c conf/2m-2s-sync/broker-b-s.properties  &

4、192.168.20.203動從服務(wù)(broker-a-s)

nohup sh bin/mqbroker  -c conf/2m-2s-sync/broker-a-s.properties  &

通過jps命令查看到BrokerStartup即啟動成功


image.png

配置注意事項(一個服務(wù)器啟動多個broker才會出現(xiàn)問題)

1游盲、啟動主服務(wù)沒有問題误墓,啟動從服務(wù)器報rocketmq已存在錯誤

這種就是文件路徑一致導(dǎo)致的,只需要在配置文件中將以下配置文件路徑設(shè)置成不一樣即可

storePathRootDir=/root/rocket/store-a-s
storePathCommitLog=/root/rocket/store-a-s/commitlog
storePathConsumeQueue=/root/rocket/store-a-s/consumequeue
storePathIndex=/root/rocket/store-a-s/index
storeCheckPoint=/root/rocket/store-a-s/checkpoint
abortFile=/root/rocket/store-a-s/abort

2益缎、啟動從服務(wù)器報端口占用問題

將listenPort配置盡量拉開优烧,我發(fā)現(xiàn)配置listenPort后會服務(wù)會在占用listenPort端口后,自動占用另倆個端口链峭,一個是listenPort+1畦娄,一個是listenPort-2。(具體作用參考:https://blog.csdn.net/yucaifu1989/article/details/127983899

舉一個列子弊仪,broker-a的listenPort配置10911熙卡,broker-b-s的listenPort配置10912,broker-a占用三個端口為10909励饵、10911驳癌、10912,broker-b-s占用三個端口為10910役听、10912颓鲜、10913表窘,那么倆個服務(wù)都會爭10912,就會報端口占用甜滨,服務(wù)啟動不了乐严。

所以我上面配置的時候listenPort一個配置10911,一個配置了10918衣摩,所以端口占用如下


image.png
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末昂验,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子艾扮,更是在濱河造成了極大的恐慌既琴,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,627評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件泡嘴,死亡現(xiàn)場離奇詭異甫恩,居然都是意外死亡,警方通過查閱死者的電腦和手機酌予,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,180評論 3 399
  • 文/潘曉璐 我一進(jìn)店門磺箕,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人霎终,你說我怎么就攤上這事滞磺∩恚” “怎么了莱褒?”我有些...
    開封第一講書人閱讀 169,346評論 0 362
  • 文/不壞的土叔 我叫張陵,是天一觀的道長涎劈。 經(jīng)常有香客問我广凸,道長,這世上最難降的妖魔是什么蛛枚? 我笑而不...
    開封第一講書人閱讀 60,097評論 1 300
  • 正文 為了忘掉前任谅海,我火速辦了婚禮,結(jié)果婚禮上蹦浦,老公的妹妹穿的比我還像新娘扭吁。我一直安慰自己,他們只是感情好盲镶,可當(dāng)我...
    茶點故事閱讀 69,100評論 6 398
  • 文/花漫 我一把揭開白布侥袜。 她就那樣靜靜地躺著,像睡著了一般溉贿。 火紅的嫁衣襯著肌膚如雪枫吧。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,696評論 1 312
  • 那天宇色,我揣著相機與錄音九杂,去河邊找鬼颁湖。 笑死,一個胖子當(dāng)著我的面吹牛例隆,可吹牛的內(nèi)容都是我干的甥捺。 我是一名探鬼主播,決...
    沈念sama閱讀 41,165評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼裳擎,長吁一口氣:“原來是場噩夢啊……” “哼涎永!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起鹿响,我...
    開封第一講書人閱讀 40,108評論 0 277
  • 序言:老撾萬榮一對情侶失蹤羡微,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后惶我,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體妈倔,經(jīng)...
    沈念sama閱讀 46,646評論 1 319
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,709評論 3 342
  • 正文 我和宋清朗相戀三年绸贡,在試婚紗的時候發(fā)現(xiàn)自己被綠了盯蝴。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,861評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡听怕,死狀恐怖捧挺,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情尿瞭,我是刑警寧澤闽烙,帶...
    沈念sama閱讀 36,527評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站声搁,受9級特大地震影響黑竞,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜疏旨,卻給世界環(huán)境...
    茶點故事閱讀 42,196評論 3 336
  • 文/蒙蒙 一很魂、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧檐涝,春花似錦遏匆、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,698評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至惰爬,卻和暖如春喊暖,著一層夾襖步出監(jiān)牢的瞬間闯割,已是汗流浹背兽愤。 一陣腳步聲響...
    開封第一講書人閱讀 33,804評論 1 274
  • 我被黑心中介騙來泰國打工县匠, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留肥缔,地道東北人。 一個月前我還...
    沈念sama閱讀 49,287評論 3 379
  • 正文 我出身青樓巩掺,卻偏偏與公主長得像偏序,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子胖替,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,860評論 2 361

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