介绍

搭建RocketMQ的name server、broker主+从、RocketMQ console监控程序。可以要的实际需求修改配置增加节点。

docker-compose.yml文件

  1. version: '3.5'
  2. services:
  3.   rmqnamesrv:
  4.     image: foxiswho/rocketmq:server
  5.     container_name: rmqnamesrv
  6.     ports:
  7.       - "9876:9876"
  8.     volumes:
  9.       - ./data/logs:/opt/logs
  10.       - ./data/store:/opt/store
  11.     networks:
  12.       rmq:
  13.         aliases:
  14.           - rmqnamesrv
  16.   rmqbroker-a:
  17.     image: foxiswho/rocketmq:broker
  18.     container_name: rmqbroker-a
  19.     ports:
  20.       - "10911:10911"
  21.     volumes:
  22.       - ./data/broker-a/logs:/opt/logs
  23.       - ./data/broker-a/store:/opt/store
  24.       - ./data/brokerconf/broker-a.conf:/etc/rocketmq/broker.conf
  25.     environment:
  26.       NAMESRV_ADDR: "rmqnamesrv:9876"
  27.       JAVA_OPTS: " -Duser.home=/opt"
  28.       JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
  29.     command: mqbroker -c /etc/rocketmq/broker.conf
  30.     depends_on:
  31.       - rmqnamesrv
  32.     networks:
  33.       rmq:
  34.         aliases:
  35.           - rmqbroker
  37.   rmqbroker-a-s:
  38.     image: foxiswho/rocketmq:broker
  39.     container_name: rmqbroker-a-s
  40.     ports:
  41.       - "10912:10912"
  42.     volumes:
  43.       - ./data/broker-a-s/logs:/opt/logs
  44.       - ./data/broker-a-s/store:/opt/store
  45.       - ./data/brokerconf/broker-a-s.conf:/etc/rocketmq/broker.conf
  46.     environment:
  47.       NAMESRV_ADDR: "rmqnamesrv:9876"
  48.       JAVA_OPTS: " -Duser.home=/opt"
  49.       JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
  50.     command: mqbroker -c /etc/rocketmq/broker.conf
  51.     depends_on:
  52.       - rmqnamesrv
  53.     networks:
  54.       rmq:
  55.         aliases:
  56.           - rmqbroker
  58.   rmqconsole:
  59.     image: styletang/rocketmq-console-ng
  60.     container_name: rmqconsole
  61.     ports:
  62.       - "8080:8080"
  63.     environment:
  64.       JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
  65.     depends_on:
  66.       - rmqnamesrv
  67.     networks:
  68.       rmq:
  69.         aliases:
  70.           - rmqconsole
  72. networks:
  73.   rmq:
  74.     name: rmq
  75.     driver: bridge

broker master节点配置文件

broker-a.conf

  1. #所属集群名字
  2. brokerClusterName=rocketmq-cluster
  3. #broker名字，注意此处不同的配置文件填写的不一样
  4. brokerName=broker-a
  5. #0 表示 Master，>0 表示 Slave
  6. brokerId=0
  7. #nameServer地址，分号分割
  8. namesrvAddr=rmqnamesrv:9876
  9. #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
  10. defaultTopicQueueNums=4
  11. #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
  12. autoCreateTopicEnable=true
  13. #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
  14. autoCreateSubscriptionGroup=true
  15. #Broker 对外服务的监听端口
  16. listenPort=10911
  17. #删除文件时间点，默认凌晨 4点
  18. deleteWhen=04
  19. #文件保留时间，默认 48 小时
  20. fileReservedTime=120
  21. #commitLog每个文件的大小默认1G
  22. mapedFileSizeCommitLog=1073741824
  23. #ConsumeQueue每个文件默认存30W条，根据业务情况调整
  24. mapedFileSizeConsumeQueue=300000
  25. #检测物理文件磁盘空间
  26. diskMaxUsedSpaceRatio=88
  27. #限制的消息大小
  28. maxMessageSize=65536
  29. #Broker 的角色
  30. #- ASYNC_MASTER 异步复制Master
  31. #- SYNC_MASTER 同步双写Master
  32. #- SLAVE
  33. brokerRole=SYNC_MASTER
  34. #刷盘方式
  35. #- ASYNC_FLUSH 异步刷盘
  36. #- SYNC_FLUSH 同步刷盘
  37. flushDiskType=SYNC_FLUSH
  38. #开启属性过滤功能
  39. enablePropertyFilter=true
  40. #使用docker时需要配置外网ip，不然将无法访问
  41. brokerIP1=192.168.1.8

broker savle节点配置文件

broker-a-s.conf

  1. #所属集群名字
  2. brokerClusterName=rocketmq-cluster
  3. #broker名字，注意此处不同的配置文件填写的不一样
  4. brokerName=broker-a
  5. #0 表示 Master，>0 表示 Slave
  6. brokerId=1
  7. #nameServer地址，分号分割
  8. namesrvAddr=rmqnamesrv:9876
  9. #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
  10. defaultTopicQueueNums=4
  11. #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
  12. autoCreateTopicEnable=true
  13. #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
  14. autoCreateSubscriptionGroup=true
  15. #Broker 对外服务的监听端口
  16. listenPort=10912
  17. #删除文件时间点，默认凌晨 4点
  18. deleteWhen=04
  19. #文件保留时间，默认 48 小时
  20. fileReservedTime=120
  21. #commitLog每个文件的大小默认1G
  22. mapedFileSizeCommitLog=1073741824
  23. #ConsumeQueue每个文件默认存30W条，根据业务情况调整
  24. mapedFileSizeConsumeQueue=300000
  25. #检测物理文件磁盘空间
  26. diskMaxUsedSpaceRatio=88
  27. #限制的消息大小
  28. maxMessageSize=65536
  29. #Broker 的角色
  30. #- ASYNC_MASTER 异步复制Master
  31. #- SYNC_MASTER 同步双写Master
  32. #- SLAVE
  33. brokerRole=SLAVE
  34. #刷盘方式
  35. #- ASYNC_FLUSH 异步刷盘
  36. #- SYNC_FLUSH 同步刷盘
  37. flushDiskType=SYNC_FLUSH
  38. #开启属性过滤功能
  39. enablePropertyFilter=true
  40. #使用docker时需要配置外网ip，不然将无法访问
  41. brokerIP1=192.168.1.8