RocketMQ兩主兩從部署

一晌梨、下載rocketmq
https://rocketmq.apache.org/
版本4.9.8
二送浊、安裝

#解壓授權(quán)：
unzip rocketmq-all-4.9.8-bin-release.zip 
mv rocketmq-all-4.9.8-bin-release rocketmq
chown -R rocketmq:rocketmq /mnt/rocketmq

#創(chuàng)建用戶(hù)
useradd rocketmq
#切換用戶(hù)
sudo -u rocketmq bash
=====================================================
以下操作都是rocketmq用戶(hù)
#添加環(huán)境變量
vim ~/.bashrc

export ROCKERMQ_HOME=/mnt/rocketmq
JAVA_HOME=/mnt/jdk1.8.0_401
export PATH=$ROCKERMQ_HOME/bin:$JAVA_HOME/bin:$PATH

#加載
cd ~ ; source ~/.bashrc

三博秫、修改配置
1.修改啟動(dòng)內(nèi)存參數(shù)，默認(rèn)是8g

vim /mnt/rocketmq/bin/runserver.sh
#大概在71行
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

vim /mnt/rocketmq/bin/runbroker.sh
#大概在85行
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

2.修改jdk變量异希，因?yàn)橛袝r(shí)候程序讀不到

#需要修改三個(gè)文件健盒，都是一樣的配置
vim /mnt/rocketmq/bin/runserver.sh
vim /mnt/rocketmq/bin/runbroker.sh
vim /mnt/rocketmq/bin/tools.sh
#找到這三行，更改第一行的信息称簿、注釋下面的兩行
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/mnt/jdk1.8.0_401
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

3.修改broker配置
A服務(wù)器

vim /mnt/rocketmq/conf/2m-2s-async/broker-a.properties
#所屬集群名字
brokerClusterName=rocketmq-cs
#broker名字扣癣，注意此處不同的配置文件填寫(xiě)的不一樣
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址憨降，分號(hào)分割
namesrvAddr=192.168.0.215:9876;192.168.0.222: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=false
#Broker對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=13920
#刪除文件時(shí)間點(diǎn)呜魄，默認(rèn)凌晨4點(diǎn)
deleteWhen=04
#文件保留時(shí)間，默認(rèn)48小時(shí)
fileReservedTime=48
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=75
#存儲(chǔ)路徑
storePathRootDir=/mnt/rocketmq/data/broker-a
#commitLog存儲(chǔ)路徑
storePathCommitLog=/mnt/rocketmq/data/broker-a/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/mnt/rocketmq/data/broker-a/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/mnt/rocketmq/data/broker-a/index
#checkpoint文件存儲(chǔ)路徑
storeCheckpoint=/mnt/rocketmq/data/broker-a/checkpoint
#abort文件存儲(chǔ)路徑
abortFile=/mnt/rocketmq/data/broker-a/abort
#Broker的角色
#-ASYNC_MASTER異步復(fù)制Master
#-SYNC_MASTER同步雙寫(xiě)Master
#-SLAVE
brokerRole=Master
#刷盤(pán)方式
#-ASYNC_FLUSH異步刷盤(pán)
#-SYNC_FLUSH同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#開(kāi)啟ACL認(rèn)證機(jī)制
aclEnable=true

vim /mnt/rocketmq/conf/2m-2s-async/broker-b-s.properties
#所屬集群名字 
brokerClusterName=rocketmq-cs
#broker名字莱衩，注意此處不同的配置文件填寫(xiě)的不一樣
brokerName=broker-b
#0 表示 Master爵嗅，>0 表示 Slave
brokerId=1
#nameServer地址，分號(hào)分割
namesrvAddr=192.168.0.215:9876;192.168.0.222: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=false
#Broker對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=15920
#刪除文件時(shí)間點(diǎn)册招，默認(rèn)凌晨4點(diǎn)
deleteWhen=04
#文件保留時(shí)間，默認(rèn)48小時(shí)
fileReservedTime=48
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=75
#存儲(chǔ)路徑
storePathRootDir=/mnt/rocketmq/data/broker-b
#commitLog存儲(chǔ)路徑
storePathCommitLog=/mnt/rocketmq/data/broker-b/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/mnt/rocketmq/data/broker-b/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/mnt/rocketmq/data/broker-b/index
#checkpoint文件存儲(chǔ)路徑
storeCheckpoint=/mnt/rocketmq/data/broker-b/checkpoint
#abort文件存儲(chǔ)路徑
abortFile=/mnt/rocketmq/data/broker-b/abort
#Broker的角色
#-ASYNC_MASTER異步復(fù)制Master
#-SYNC_MASTER同步雙寫(xiě)Master
#-SLAVE
brokerRole=SLAVE
#刷盤(pán)方式
#-ASYNC_FLUSH異步刷盤(pán)
#-SYNC_FLUSH同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#開(kāi)啟ACL認(rèn)證機(jī)制
aclEnable=true

B服務(wù)器

vim /mnt/rocketmq/conf/2m-2s-async/broker-a-s.properties
brokerClusterName=rocketmq-cs
brokerName=broker-a
brokerId=1
#nameServer地址勒极，分號(hào)分割
namesrvAddr=192.168.0.215:9876;192.168.0.222: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=false
#Broker對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=15920
#刪除文件時(shí)間點(diǎn)，默認(rèn)凌晨4點(diǎn)
deleteWhen=04
#文件保留時(shí)間匾七，默認(rèn)48小時(shí)
fileReservedTime=48
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=75
#存儲(chǔ)路徑
storePathRootDir=/mnt/rocketmq/data/broker-a
#commitLog存儲(chǔ)路徑
storePathCommitLog=/mnt/rocketmq/data/broker-a/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/mnt/rocketmq/data/broker-a/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/mnt/rocketmq/data/broker-a/index
#checkpoint文件存儲(chǔ)路徑
storeCheckpoint=/mnt/rocketmq/data/broker-a/checkpoint
#abort文件存儲(chǔ)路徑
abortFile=/mnt/rocketmq/data/broker-a/abort
#Broker的角色
#-ASYNC_MASTER異步復(fù)制Master
#-SYNC_MASTER同步雙寫(xiě)Master
#-SLAVE
brokerRole=SLAVE
#刷盤(pán)方式
#-ASYNC_FLUSH異步刷盤(pán)
#-SYNC_FLUSH同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#開(kāi)啟ACL認(rèn)證機(jī)制
aclEnable=true

vim /mnt/rocketmq/conf/2m-2s-async/broker-b.properties 
brokerClusterName=rocketmq-cs
brokerName=broker-b
brokerId=0
#nameServer地址絮短，分號(hào)分割
namesrvAddr=192.168.0.215:9876;192.168.0.222: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=false
#Broker對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=13920
#刪除文件時(shí)間點(diǎn)邑贴，默認(rèn)凌晨4點(diǎn)
deleteWhen=04
#文件保留時(shí)間席里，默認(rèn)48小時(shí)
fileReservedTime=48
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=75
#存儲(chǔ)路徑
storePathRootDir=/mnt/rocketmq/data/broker-b
#commitLog存儲(chǔ)路徑
storePathCommitLog=/mnt/rocketmq/data/broker-b/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/mnt/rocketmq/data/broker-b/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/mnt/rocketmq/data/broker-b/index
#checkpoint文件存儲(chǔ)路徑
storeCheckpoint=/mnt/rocketmq/data/broker-b/checkpoint
#abort文件存儲(chǔ)路徑
abortFile=/mnt/rocketmq/data/broker-b/abort
#Broker的角色
#-ASYNC_MASTER異步復(fù)制Master
#-SYNC_MASTER同步雙寫(xiě)Master
#-SLAVE
brokerRole=Master
#刷盤(pán)方式
#-ASYNC_FLUSH異步刷盤(pán)
#-SYNC_FLUSH同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#開(kāi)啟ACL認(rèn)證機(jī)制
aclEnable=true

4.修改acl配置,根據(jù)需求添加白名單

vim /mnt/rocketmq/conf/plain_acl.yml
globalWhiteRemoteAddresses:
  - 192.168.0.*

accounts:
  - accessKey: RocketMQ
    secretKey: 12345678
    whiteRemoteAddress:
    admin: false
    defaultTopicPerm: DENY
    defaultGroupPerm: SUB
    topicPerms:
      - topicA=DENY
      - topicB=PUB|SUB
      - topicC=SUB
    groupPerms:
      # the group should convert to retry topic
      - groupA=DENY
      - groupB=PUB|SUB
      - groupC=SUB

  - accessKey: rocketmq2
    secretKey: 12345678
    whiteRemoteAddress: 192.168.1.*
    # if it is admin, it could access all resources
    admin: true

四、根據(jù)配置創(chuàng)建目錄

mkdir -pv /mnt/rocketmq/data/broker-{a,b}/{commitlog,consumequeue,index}
mkdir -pv /mnt/rocketmq/conf/acl
mkdir -pv /mnt/rocketmq/log

五拢驾、啟動(dòng)奖磁、關(guān)閉、查看集群狀態(tài)

#啟動(dòng)
#A服務(wù)器
cd /mnt/rocketmq/bin

nohup sh mqnamesrv >/mnt/rocketmq/log/mqnamesrv.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-a.properties >/mnt/rocketmq/log/broker-a.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-b-s.properties >/mnt/rocketmq/log/broker-b-s.log &

#B服務(wù)器
cd /mnt/rocketmq/bin
nohup sh mqnamesrv >/mnt/rocketmq/log/mqnamesrv.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-a-s.properties >/mnt/rocketmq/log/broker-a-s.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-b.properties >/mnt/rocketmq/log/broker-b.log &

#關(guān)閉（先關(guān)閉broker）
cd /mnt/rocketmq/bin/

sh mqshutdown broker

sh mqshutdown namesrv

#查看集群狀態(tài)
cd /mnt/rocketmq/bin/
sh mqadmin clusterList -n 192.168.0.215:9876
#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
rocketmq-cs       broker-a                0     192.168.0.215:13920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-a                1     192.168.0.222:15920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-b                0     192.168.0.222:13920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-b                1     192.168.0.215:15920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100

六繁疤、添加主題和查看主題

#添加topic
sh mqadmin updatetopic -n 192.168.0.215:9876 -t CENTER-DATA-CENTER-INVENTORY -c rocketmq-cs

create topic to 192.168.0.215:13920 success.
create topic to 192.168.0.222:13920 success.
TopicConfig [topicName=CENTER-DATA-CENTER-INVENTORY, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

#查看topic
sh mqadmin topiclist -n 192.168.0.215:9876 -c

#Cluster Name         #Topic                                            #Consumer Group                                 
rocketmq-cs           SCHEDULE_TOPIC_XXXX                                                                                                               
rocketmq-cs           RMQ_SYS_TRANS_HALF_TOPIC                                                                                                          
rocketmq-cs           CENTER-DATA-CENTER-INVENTORY                                                                                                      
rocketmq-cs           broker-b                                                                                                                          
rocketmq-cs           BenchmarkTest                                                                                                                     
rocketmq-cs           OFFSET_MOVED_EVENT                                                                                                                
rocketmq-cs           rocketmq-cs                                                                                                                       
rocketmq-cs           rocketmq-cs_REPLY_TOPIC                                                                                                           
rocketmq-cs           broker-a                                                                                                                          
rocketmq-cs           SELF_TEST_TOPIC 
#剛才創(chuàng)建的是第三個(gè)######################################

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者

人面猴
序言：七十年代末咖为，一起剝皮案震驚了整個(gè)濱河市，隨后出現(xiàn)的幾起案子稠腊，更是在濱河造成了極大的恐慌案疲，老刑警劉巖，帶你破解...
沈念sama閱讀 218,755評(píng)論 6贊 507
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件麻养，死亡現(xiàn)場(chǎng)離奇詭異，居然都是意外死亡诺舔，警方通過(guò)查閱死者的電腦和手機(jī)鳖昌，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 93,305評(píng)論 3贊 395
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門(mén)备畦，熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)，“玉大人许昨，你說(shuō)我怎么就攤上這事懂盐。” “怎么了糕档？”我有些...
開(kāi)封第一講書(shū)人閱讀 165,138評(píng)論 0贊 355
道士緝兇錄：失蹤的賣(mài)姜人
文/不壞的土叔我叫張陵莉恼，是天一觀的道長(zhǎng)。經(jīng)常有香客問(wèn)我速那，道長(zhǎng)俐银，這世上最難降的妖魔是什么？我笑而不...
開(kāi)封第一講書(shū)人閱讀 58,791評(píng)論 1贊 295
?港島之戀（遺憾婚禮）
正文為了忘掉前任端仰，我火速辦了婚禮捶惜，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘荔烧。我一直安慰自己吱七，他們只是感情好，可當(dāng)我...
茶點(diǎn)故事閱讀 67,794評(píng)論 6贊 392
惡毒庶女頂嫁案：這布局不是一般人想出來(lái)的
文/花漫我一把揭開(kāi)白布鹤竭。她就那樣靜靜地躺著踊餐，像睡著了一般。火紅的嫁衣襯著肌膚如雪臀稚。梳的紋絲不亂的頭發(fā)上吝岭，一...
開(kāi)封第一講書(shū)人閱讀 51,631評(píng)論 1贊 305
城市分裂傳說(shuō)
那天，我揣著相機(jī)與錄音烁涌，去河邊找鬼苍碟。笑死，一個(gè)胖子當(dāng)著我的面吹牛撮执，可吹牛的內(nèi)容都是我干的微峰。我是一名探鬼主播，決...
沈念sama閱讀 40,362評(píng)論 3贊 418
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開(kāi)眼抒钱，長(zhǎng)吁一口氣：“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼蜓肆！你這毒婦竟也來(lái)了？” 一聲冷哼從身側(cè)響起谋币，我...
開(kāi)封第一講書(shū)人閱讀 39,264評(píng)論 0贊 276
萬(wàn)榮殺人案實(shí)錄
序言：老撾萬(wàn)榮一對(duì)情侶失蹤仗扬，失蹤者是張志新（化名）和其女友劉穎，沒(méi)想到半個(gè)月后蕾额，有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體早芭，經(jīng)...
沈念sama閱讀 45,724評(píng)論 1贊 315
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 37,900評(píng)論 3贊 336
?白月光啟示錄
正文我和宋清朗相戀三年诅蝶，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了退个。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片募壕。...
茶點(diǎn)故事閱讀 40,040評(píng)論 1贊 350
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡，死狀恐怖语盈，靈堂內(nèi)的尸體忽然破棺而出刀荒，到底是詐尸還是另有隱情缠借，我是刑警寧澤溶锭，帶...
沈念sama閱讀 35,742評(píng)論 5贊 346
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布霹疫，位于F島的核電站丽蝎，受9級(jí)特大地震影響屠阻，放射性物質(zhì)發(fā)生泄漏国觉。R本人自食惡果不足惜痕寓，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 41,364評(píng)論 3贊 330
男人毒藥：我在死后第九天來(lái)索命
文/蒙蒙一呻引、第九天我趴在偏房一處隱蔽的房頂上張望。院中可真熱鬧，春花似錦、人聲如沸。這莊子的主人今日做“春日...
開(kāi)封第一講書(shū)人閱讀 31,944評(píng)論 0贊 22
一樁弒父案粒氧，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽(yáng)。三九已至，卻和暖如春箱熬，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背糕伐。一陣腳步聲響...
開(kāi)封第一講書(shū)人閱讀 33,060評(píng)論 1贊 270
情欲美人皮
我被黑心中介騙來(lái)泰國(guó)打工亏较，沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留遵岩，地道東北人舍哄。一個(gè)月前我還...
沈念sama閱讀 48,247評(píng)論 3贊 371
代替公主和親
正文我出身青樓丧靡，卻偏偏與公主長(zhǎng)得像温治，于是被迫代替她去往敵國(guó)和親。傳聞我的和親對(duì)象是個(gè)殘疾皇子，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 44,979評(píng)論 2贊 355

RocketMQ兩主兩從部署

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