實(shí)踐RocketMQ雙Master-Slave集群架構(gòu)搭

準(zhǔn)備材料：
- Linux操作環(huán)境( 假設(shè)兩臺(tái)服務(wù)器ip為：192.168.74.130和192.168.74.131)；
- RocketMQ
- JDK 1.8+
分別修改兩臺(tái)服務(wù)RockerMQ的配置文件，路徑為：rocketmq-4.6.1/conf/2m-2s-async（這里以異步為例）

broker-a.properties（broker a的Master配置文件） broker-a-s.properties（broker a的Slave配置文件）

broker-b.properties（broker b的Master配置文件） broker-b-s.properties（broker b的Slave配置文件）

專(zhuān)注于為中小企業(yè)提供網(wǎng)站設(shè)計(jì)制作、成都網(wǎng)站設(shè)計(jì)服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)大姚免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了上千余家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

130服務(wù)器修改 a的master 與 b 的slave配置文件，131服務(wù)器修改 b的master 與 a 的slave配置文件；

這里以130的配置文件為例：
master文件：

                                    brokerClusterName=DefaultCluster
                                    #broker 名稱(chēng)
                                    brokerName=broker-a
                                    # broker id 0-Master 其他-Slave
                                    brokerId=0
                                    deleteWhen=04
                                    fileReservedTime=48
                                    brokerRole=ASYNC_MASTER
                                    flushDiskType=ASYNC_FLUSH
                                    #namesrv地址列表，多個(gè)用，或；分割                           
                                    namesrvAddr=192.168.74.130:9876;192.168.74.131:9876
                                    #監(jiān)聽(tīng)端口，默認(rèn)為10911，多個(gè)broker 端口不能相同
                                    listenPort=10911
                                    #日志 同一臺(tái)服務(wù)器上多個(gè)broker的配置路徑不能為相同，否則報(bào)錯(cuò)：服務(wù)已經(jīng)啟動(dòng)
                                    storePathRootDir=/data/rocketmq/store/rootdir-a
                                    storePathCommitLog=/data/rocketmq/store/commitlog-a

slave文件：

                                    brokerClusterName=DefaultCluste
                                    brokerName=broker-b
                                    brokerId=1
                                    deleteWhen=04
                                    fileReservedTime=48
                                    brokerRole=SLAVE
                                    flushDiskType=ASYNC_FLUS
                                    listenPort=10921
                                    namesrvAddr=192.168.74.130:9876,192.168.74.131:9876
                                    storePathRootDir=/data/rocketmq/store/rootdir-b-s
                                    storePathCommitLog=/data/rocketmq/store/commitlog-b-s

啟動(dòng)步驟
- 分別啟動(dòng)兩臺(tái)服務(wù)器的NameSrv （默認(rèn)端口號(hào)為9876）
  nohup sh bin/mqnamesrv &；
- 分別啟動(dòng)兩天服務(wù)器的master broker -c 參數(shù)指定啟動(dòng)時(shí)讀取的配置文件的路徑，不加讀取默認(rèn)的配置文件
  nohup sh bin/mqbroker -c ./conf/2m-2s-async/broker-a.properties & //130上執(zhí)行啟動(dòng)a broker的master
  nohup sh bin/mqbroker -c ./conf/2m-2s-async/broker-b.properties & //131上執(zhí)行啟動(dòng)b broker的master
- 分別啟動(dòng)兩臺(tái)服務(wù)器的slave broker
  nohup sh bin/mqbroker -c ./conf/2m-2s-async/broker-b-s.properties & //130上執(zhí)行啟動(dòng)b broker的slave
  nohup sh bin/mqbroker -c ./conf/2m-2s-async/broker-b.properties & //131上執(zhí)行啟動(dòng)a broker的slave
使用 jps 命令進(jìn)行查看服務(wù)是否啟動(dòng)
[root@localhost bin]# jps
5329 Jps
3161 NamesrvStartup
3401 BrokerStartup
4509 BrokerStartup
到這里就成功的啟動(dòng)起來(lái)了。
其他命令
關(guān)閉broker ： sh bin/mqshutdown broker
關(guān)閉namesrv：sh bin/mqshutdown namesrv
問(wèn)題總結(jié)：
1.啟動(dòng)broker時(shí)報(bào)jvm內(nèi)存不足
原因：默認(rèn)jvm 內(nèi)存配置高于物理內(nèi)存配置
解決方法：修改bin目錄下runbroker.sh、runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m"
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
2.broker 無(wú)法注冊(cè)另外一臺(tái)namesrv
原因：
1. 網(wǎng)絡(luò)不可達(dá) （檢查網(wǎng)絡(luò)）
2. 檢查防火墻是否開(kāi)啟（關(guān)閉防火墻命令 systemctl stop firewalld）
  3.啟動(dòng)多個(gè)broker時(shí)報(bào)broker已啟動(dòng)
  原因：
  1.啟動(dòng)時(shí)沒(méi)有指定配置文件或未修改配置文件監(jiān)聽(tīng)端口，導(dǎo)致端口沖突；
  2.未指定日志文件路徑或路徑一致；

網(wǎng)頁(yè)標(biāo)題：實(shí)踐RocketMQ雙Master-Slave集群架構(gòu)搭
標(biāo)題網(wǎng)址：http://weahome.cn/article/gecsgd.html

真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

實(shí)踐RocketMQ雙Master-Slave集群架構(gòu)搭

其他資訊

網(wǎng)站制作

企業(yè)服務(wù)

網(wǎng)站建設(shè)

服務(wù)器托管