docker单机部署rocketmq主主集群

╰半橙微兮° 2022-01-12 10:59 881阅读 0赞

在docker部署单机版的基础上,部署集群,都是基于内网ip部署

  1. 创建几个目录
  2. mkdir -p  /opt/rocketmq/logs/nameserver-a
  3. mkdir -p  /opt/rocketmq/logs/nameserver-b
  4. mkdir -p /opt/rocketmq/store/nameserver-a
  5. mkdir -p /opt/rocketmq/store/nameserver-b
  6. mkdir -p /opt/rocketmq/logs/broker-a
  7. mkdir -p /opt/rocketmq/logs/broker-b
  8. mkdir -p /opt/rocketmq/store/broker-a
  9. mkdir -p /opt/rocketmq/store/broker-b
  10. mkdir -p /home/rocketmq/broker-a/
  11. mkdir -p /home/rocketmq/broker-b/

编写broker.conf
broker-a.conf

  1. brokerClusterName = rocketmq-cluster
  2. brokerName = broker-a
  3. brokerId = 0
  4. # 这个ip配置为内网访问，让mq只能内网访问，不配置默认为内网
  5. #brokerIP1 = xxxxx
  6. deleteWhen = 04
  7. fileReservedTime = 48
  8. brokerRole = ASYNC_MASTER
  9. flushDiskType = ASYNC_FLUSH
  10. # 内网的
  11. namesrvAddr=172.17.0.1:9876;172.17.0.1:9877
  12. autoCreateTopicEnable=true
  13. #Broker 对外服务的监听端口,
  14. listenPort = 11911
  15. #Broker角色
  16. #- ASYNC_MASTER 异步复制Master
  17. #- SYNC_MASTER 同步双写Master
  18. #- SLAVE
  19. brokerRole=ASYNC_MASTER
  20. #刷盘方式
  21. #- ASYNC_FLUSH 异步刷盘
  22. #- SYNC_FLUSH 同步刷盘
  23. flushDiskType=ASYNC_FLUSH

broker-b.conf

  1. brokerClusterName = rocketmq-cluster
  2. brokerName = broker-b
  3. brokerId = 0
  4. # 这个ip配置为内网访问，让mq只能内网访问,不配置默认为内网
  5. #brokerIP1 = xxxxx
  6. deleteWhen = 04
  7. fileReservedTime = 48
  8. brokerRole = ASYNC_MASTER
  9. flushDiskType = ASYNC_FLUSH
  10. # 内网的
  11. namesrvAddr=172.17.0.1:9876;172.17.0.1:9877
  12. autoCreateTopicEnable=true
  13. #Broker 对外服务的监听端口,
  14. listenPort = 11911
  15. #Broker角色
  16. #- ASYNC_MASTER 异步复制Master
  17. #- SYNC_MASTER 同步双写Master
  18. #- SLAVE
  19. brokerRole=ASYNC_MASTER
  20. #刷盘方式
  21. #- ASYNC_FLUSH 异步刷盘
  22. #- SYNC_FLUSH 同步刷盘
  23. flushDiskType=ASYNC_FLUSH

编写docker-compose.yml文件
多节点部署rocketmq集群，把下边的 nameserver和broker拆出来部署即可

  1. version: '3.5'
  2. services:
  3.   rmqnamesrv-a:
  4.     image: rocketmqinc/rocketmq:4.3.0
  5.     container_name: rmqnamesrv-a
  6.     ports:
  7.       - 9876:9876
  8.     volumes:
  9.       - /opt/rocketmq/logs/nameserver-a:/opt/logs
  10.       - /opt/rocketmq/store/nameserver-a:/opt/store
  11.     command: sh mqnamesrv
  12.     networks:
  13.         rmq:
  14.           aliases:
  15.             - rmqnamesrv-a
  17.   rmqnamesrv-b:
  18.     image: rocketmqinc/rocketmq:4.3.0
  19.     container_name: rmqnamesrv-b
  20.     ports:
  21.       - 9877:9876
  22.     volumes:
  23.       - /opt/rocketmq/logs/nameserver-b:/opt/logs
  24.       - /opt/rocketmq/store/nameserver-b:/opt/store
  25.     command: sh mqnamesrv
  26.     networks:
  27.         rmq:
  28.           aliases:
  29.             - rmqnamesrv-b
  31.   rmqbroker-a:
  32.     image: rocketmqinc/rocketmq:4.3.0
  33.     container_name: rmqbroker-a
  34.     ports:
  35.       - 11909:10909
  36.       - 11911:10911
  37.     volumes:
  38.       - /opt/rocketmq/logs/broker-a:/opt/logs
  39.       - /opt/rocketmq/store/broker-a:/opt/store
  40.       - /home/rocketmq/broker-a/broker-a.conf:/opt/rocketmq-4.3.0/conf/broker.conf 
  41.       #- /home/rocketmq/broker-a/broker.conf:/opt/rocketmq-4.3.0/conf/broker.conf
  42.     environment:
  43.         TZ: Asia/Shanghai
  44.         NAMESRV_ADDR: "rmqnamesrv-a:9876"
  45.         JAVA_OPTS: " -Duser.home=/opt"
  46.         JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
  47.     command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker.conf autoCreateTopicEnable=true &
  48.     links:
  49.       - rmqnamesrv-a:rmqnamesrv-a
  50.       - rmqnamesrv-b:rmqnamesrv-b
  51.     networks:
  52.       rmq:
  53.         aliases:
  54.           - rmqbroker-a
  56.   rmqbroker-b:
  57.     image: rocketmqinc/rocketmq:4.3.0
  58.     container_name: rmqbroker-b
  59.     ports:
  60.       - 10909:10909
  61.       - 10911:10911
  62.     volumes:
  63.       - /opt/rocketmq/logs/broker-b:/opt/logs
  64.       - /opt/rocketmq/store/broker-b:/opt/store
  65.       - /home/rocketmq/broker-b/broker-b.conf:/opt/rocketmq-4.3.0/conf/broker.conf 
  66.       #- /home/rocketmq/broker-b:/opt/rocketmq-4.3.0/conf
  67.     environment:
  68.         TZ: Asia/Shanghai
  69.         NAMESRV_ADDR: "rmqnamesrv-b:9876"
  70.         JAVA_OPTS: " -Duser.home=/opt"
  71.         JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
  72.     command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker.conf autoCreateTopicEnable=true &
  73.     links:
  74.       - rmqnamesrv-a:rmqnamesrv-a
  75.       - rmqnamesrv-b:rmqnamesrv-b
  76.     networks:
  77.       rmq:
  78.         aliases:
  79.           - rmqbroker-b
  80.   rmqconsole:
  81.     image: styletang/rocketmq-console-ng
  82.     container_name: rmqconsole
  83.     ports:
  84.       - 9001:8080
  85.     environment:
  86.         JAVA_OPTS: -Drocketmq.namesrv.addr=rmqnamesrv-a:9876;rmqnamesrv-b:9877 -Dcom.rocketmq.sendMessageWithVIPChannel=false
  87.     networks:
  88.       rmq:
  89.         aliases:
  90.           - rmqconsole
  91. networks:
  92.   rmq:
  93.     name: rmq
  94.     driver: bridge

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

  1. java端的配置文件添加地址   namesrvAddr: ip:9876;ip:9877

发表评论

表情：
评论列表 （有 0 条评论，881人围观）

还没有评论，来说两句吧...

相关阅读