創建掛載目錄

mkdir -p /app/rocketmq/logs/nameserver-a mkdir -p /app/rocketmq/logs/nameserver-b mkdir -p /app/rocketmq/store/nameserver-a mkdir -p /app/rocketmq/store/nameserver-b mkdir -p /app/rocketmq/logs/broker-a mkdir -p /app/rocketmq/logs/broker-b mkdir -p /app/rocketmq/store/broker-a mkdir -p /app/rocketmq/store/broker-b mkdir -p /app/rocketmq/broker-a/ mkdir -p /app/rocketmq/broker-b/

創建broker.conf
broker.conf是Broker的配置文件，因為此時RocketMQ鏡像還沒有拉取,所以還沒有默認的broker.conf。所以這里直接寫好，到時候通過命令替換默認的broker.conf。

因為是雙主模式部署，所以會有兩個broker.conf,這里暫且命名 broker-a.conf 和 broker-b.conf

broker-a.conf

vim /app/rocketmq/broker-a/broker-a.conf brokerClusterName = rocketmq-cluster brokerName = broker-a brokerId = 0 #這個很有講究 如果是正式環境 這里一定要填寫內網地址（安全） #如果是用于測試或者本地這里建議要填外網地址，因為你的本地代碼是無法連接到阿里云內網，只能連接外網。 brokerIP1 = 192.168.92.129 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH # 內網的(阿里云有內網IP和外網IP) namesrvAddr=172.18.0.5:9876;172.18.0.5:9877 autoCreateTopicEnable=true #Broker 對外服務的監聽端口, listenPort = 10911 #Broker角色 #- ASYNC_MASTER 異步復制Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=ASYNC_MASTER #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=ASYNC_FLUSH

這里配置的主要信息有：

1、當前Broker對外暴露的端口號
2、注冊到NameServer的地址，看到這里有兩個地址，說明NameServer也是集群部署。
3、當前Broker的角色，是主還是從，這里表示是主。

2）broker-b.conf

vim /app/rocketmq/broker-b/broker-b.conf brokerClusterName = rocketmq-cluster brokerName = broker-b brokerId = 0 brokerIP1 = 192.168.92.129 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH # 內網的(阿里云有內網IP和外網IP) namesrvAddr=172.18.0.5:9876;172.18.0.5:9877 autoCreateTopicEnable=true #Broker 對外服務的監聽端口, listenPort = 10909 #Broker角色 #- ASYNC_MASTER 異步復制Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=ASYNC_MASTER #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=ASYNC_FLUSH

這個上面并無差別，只是當前Brocker對外暴露的端口不一樣。

3、編寫 docker-compose.yml
我們可以簡單把docker-compose.yml理解成一個類似Shell的腳本，這個腳本定義了運行多容器應用程序的信息。

vim /app/docker-compose.yml version: '3.5' services:rmqnamesrv-a:image: rocketmqinc/rocketmq:4.3.0container_name: rmqnamesrv-aports:- 9876:9876volumes:- /app/rocketmq/logs/nameserver-a:/opt/logs- /app/rocketmq/store/nameserver-a:/opt/storecommand: sh mqnamesrvnetworks:rmq:aliases:- rmqnamesrv-armqnamesrv-b:image: rocketmqinc/rocketmq:4.3.0container_name: rmqnamesrv-bports:- 9877:9877volumes:- /app/rocketmq/logs/nameserver-b:/opt/logs- /app/rocketmq/store/nameserver-b:/opt/storecommand: sh mqnamesrvnetworks:rmq:aliases:- rmqnamesrv-brmqbroker-a:image: rocketmqinc/rocketmq:4.3.0container_name: rmqbroker-aports:- 10911:10911volumes:- /app/rocketmq/logs/broker-a:/opt/logs- /app/rocketmq/store/broker-a:/opt/store- /app/rocketmq/broker-a/broker-a.conf:/opt/rocketmq-4.3.0/conf/broker.conf environment:TZ: Asia/ShanghaiNAMESRV_ADDR: "rmqnamesrv-a:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"command: sh mqbroker -c /app/rocketmq-4.3.0/conf/broker.conf autoCreateTopicEnable=true &links:- rmqnamesrv-a:rmqnamesrv-a- rmqnamesrv-b:rmqnamesrv-bnetworks:rmq:aliases:- rmqbroker-armqbroker-b:image: rocketmqinc/rocketmq:4.3.0container_name: rmqbroker-bports:- 10909:10909volumes:- /app/rocketmq/logs/broker-b:/opt/logs- /app/rocketmq/store/broker-b:/opt/store- /app/rocketmq/broker-b/broker-b.conf:/opt/rocketmq-4.3.0/conf/broker.conf environment:TZ: Asia/ShanghaiNAMESRV_ADDR: "rmqnamesrv-b:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker.conf autoCreateTopicEnable=true &links:- rmqnamesrv-a:rmqnamesrv-a- rmqnamesrv-b:rmqnamesrv-bnetworks:rmq:aliases:- rmqbroker-brmqconsole:image: styletang/rocketmq-console-ngcontainer_name: rmqconsoleports:- 9001:9001environment:JAVA_OPTS: -Drocketmq.namesrv.addr=rmqnamesrv-a:9876;rmqnamesrv-b:9877 -Dcom.rocketmq.sendMessageWithVIPChannel=falsenetworks:rmq:aliases:- rmqconsole networks:rmq:name: rmqdriver: bridge

從配置文件可以大致看出幾點：

1、通過Docker總共拉取了5條鏡像記錄。rmqnamesrv-a、rmqnamesrv-b、rmqbroker-a、rmqbroker-b、rmqconsole。
2、rmqconsole是一個可視化的工具，可以通過頁面來查看RocketMQ相關信息。
3、可以看出對于broker的配置文件broker.conf已經被broker-a/b.conf替換。

關鍵一步
前面所有的操作，都是為這一步的鋪墊,通過docker-compose執行docker-compose.yml配置文件

docker-compose -f docker-compose.yml up -d

查看可視化界面
http://192.168.92.129:9001/

總結

以上是生活随笔為你收集整理的Docker RocketMQ 集群的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。