RocketMQ環(huán)境做準備

• 安裝Linux 系統(tǒng) ，配置ip為 192.168.1.100, ip對應(yīng)
• 安裝Docker環(huán)境

拉取 rocketmq 鏡像版本

docker pull rocketmqinc/rocketmq:4.4.0

注意： Rocketmq 的服務(wù)端版本與客戶端版本要一致！ 不一致可能會出現(xiàn)異常的錯誤(難以發(fā)現(xiàn))！

• docker 部署 rocketmq namesrv 服務(wù)

docker run -itd --name rocketmq_namesrv --restart=always \
           -p 9876:9876 \
           -v /etc/localtime:/etc/localtime:ro \
           -v /data/rocketmq/namesrv:/home/rocketmq \
           rocketmqinc/rocketmq:4.4.0 sh mqnamesrv autoCreateTopicEnable=true

• docker 部署 broker 服務(wù)(注意配置的路徑修改)

docker run -d -p 10911:10911 -p 10909:10909 --restart=always \
           -v /data/rocketmq/broker:/home/rocketmq:rw \
           -v /deploy/etc/rocketmq-broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf \
           -v /etc/localtime:/etc/localtime:ro \
           --name rocketmq_broker -e "NAMESRV_ADDR=192.168.1.100:9876" \
           -e "MAX_POSSIBLE_HEAP=200000000" \
           rocketmqinc/rocketmq:4.4.0 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.4.0/conf/broker.conf

rocketmq-broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = 192.168.1.100
autoCreateTopicEnable=true

• docker 部署 rocketmq console 控制臺(注意namesrv的地址)

docker run -itd --name $name -m 500m --restart=always \
           -e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.1.100:9876 \
           -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
           -p 8080:8080 -t pangliang/rocketmq-console-ng