17 Rocketmq集群雙主雙從同步搭建-有解無憂

基于前面一主一從同步搭建

我們企業級開發，一般采用的是雙主雙從同步，以及異步刷盤；

同步訊息保證訊息不丟失，異步刷盤提高吞吐量；

我們VM里再克隆兩臺機器；

192.168.0.110 機器作為m1主節點

192.168.0.103 機器作為s1從節點

192.168.0.111 機器作為m2主節點

192.168.0.112 機器作為s2從節點

首先，我們把namesrvAddr配置修改，每個broker都要注冊到所有nameserver；

namesrvAddr=192.168.0.110:9876;192.168.0.103:9876;192.168.0.111:9876;192.168.0.112:9876;

刷盤機制都改成異步：

#- ASYNC_FLUSH 異步刷盤
#- SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH

192.168.0.111 機器作為m2主節點從m1主節點的broker-a.properties復制內容到broker-b.properties檔案；

修改broker-b.properties組態檔；

修改內容如下：

brokerName=broker-b

192.168.0.112 機器作為s2主節點從s1主節點的broker-a-s.properties復制內容到broker-b-s.properties檔案；

修改broker-b-s.properties組態檔；

修改內容如下：

brokerName=broker-b

然后分別啟動四個機器；

先啟動nameserver:

nohup sh mqnamesrv &

再啟動broker：

192.168.0.110 機器作為m1主節點

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

192.168.0.103 機器作為s1從節點

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

192.168.0.111 機器作為m2主節點

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

192.168.0.112 機器作為s2從節點

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

可視化控制臺專案namesrvAddr配置改下：

$[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-8kqRgQAt-1631929516466)(C:\Users\java1234\Desktop\RocketMQ\課件\RocketMQ分布式訊息佇列課件.assets\image-20210905002631199.png)]$

啟動控制臺專案：

$[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-DZZ1e3mW-1631929516469)(C:\Users\java1234\Desktop\RocketMQ\課件\RocketMQ分布式訊息佇列課件.assets\image-20210905002707640.png)]$

專案代碼，生產端和消費端name-server都改下；

$[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-sf9bXnyU-1631929516470)(C:\Users\java1234\Desktop\RocketMQ\課件\RocketMQ分布式訊息佇列課件.assets\image-20210905002726813.png)]$

啟動測驗：

$[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-WwP5gd9I-1631929516471)(C:\Users\java1234\Desktop\RocketMQ\課件\RocketMQ分布式訊息佇列課件.assets\image-20210905002800148.png)]$

兩個主節點一起分擔訊息處理；

我們模擬下，讓a主節點broker掛掉；

sh mqshutdown broker

$[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-Qdre69RW-1631929516473)(C:\Users\java1234\Desktop\RocketMQ\課件\RocketMQ分布式訊息佇列課件.assets\image-20210905003044496.png)]$

再運行代碼測驗，發現b主節點承擔了所有訊息接收和處理；實作了高可用；

說明：這個是鋒哥的RocketMQ備課筆記，等備課完，會發布配套的視頻教程，如有需要，可以先加鋒哥WX：java1239 歡迎白嫖

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/301233.html

標籤：其他

上一篇：Kettle連接不上資料庫及中文亂碼問題解決

下一篇：神器！五分鐘完成大型爬蟲專案！