RocketMQ 集群容器多机编排主主

一、主机信息

• 多机主主编排，如果主从改另外台配置就是了
• 如需要多宿主机做集群，只需要分离配置文件

二、创建 RocketMQ 编排文件

2.1、创建相关目录

• 2台机器均需要操作

#   创建 rocketmq 文件夹，放置编排文件
mkdir -p /data/compose/rocketmq
#   创建 rocketmq 文件夹，放置配置文件
mkdir -p /data/rocketmq/conf

2.2、创建容器网络

• 2台机器均需要操作

docker network create aka-network

2.3、创建 rocketmq 编排文件

• 2台机器均需要操作
• extra_hosts 配置主机名这个地方更具实际情况修改

cat <<'EOF'> /data/compose/rocketmq/docker-compose.yaml
version: '3.5'
services:
  namesrv:
    image: foxiswho/rocketmq:4.7.0
    container_name: namesrv
    command: ["sh","mqnamesrv"]
    volumes:
      - /data/rocketmq/namesvr/logs:/opt/logs
      - /data/rocketmq/namesvr/store:/opt/store
    ports:
      - 9876:9876
  rocketmq-master:
    image: foxiswho/rocketmq:4.7.0
    container_name: rocketmq-master
    command: mqbroker -c /etc/rocketmq/broker.conf
    extra_hosts:
      namesrv-01: 192.168.8.7
      namesrv-02: 192.168.8.8
    environment:
      NAMESRV_ADDR: "namesrv-01:9876;namesrv-02:9876;"
      JAVA_OPTS: " -Duser.home=/opt"
      JAVA_OPT_EXT: "-server -Xms256m -Xmx2048m -Xmn512m"
    volumes:
      - /data/rocketmq/broker-master/logs:/opt/logs
      - /data/rocketmq/broker-master/store:/opt/store
      - /data/rocketmq/conf/master-broker.conf:/etc/rocketmq/broker.conf
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    depends_on:
      - namesrv
  rocketmq-console-ng:
    image: styletang/rocketmq-console-ng
    container_name: rocketmq-console
    extra_hosts:
      namesrv-01: 192.168.8.7
      namesrv-02: 192.168.8.8
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=namesrv-01:9876;namesrv-02:9876; -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    ports:
      - 8080:8080
    depends_on:
      - namesrv
networks:
  default:
    driver: bridge
EOF

三、创建 Rocketmq 配置文件

3.1、创建环境变量

1) 在 192.168.8.7 机器上添加环境变量

# broker名称，不能重复
brokerName=broker-a
# 获取当前主机地址
hostsip=$(ip add | egrep -A 3 "enp0s3|eth0|em0" | grep -w inet | awk '{print $2}' | awk -F/ '{print $1}' | tr '.' '.')

2) 在 192.168.8.8 机器上添加环境变量

# broker名称，不能重复
brokerName=broker-b
# 获取当前主机地址
hostsip=$(ip add | egrep -A 3 "enp0s3|eth0|em0" | grep -w inet | awk '{print $2}' | awk -F/ '{print $1}' | tr '.' '.')

3.2、创建 master-broker 配置文件

• 2台机器均需要操作

cat > /data/rocketmq/conf/master-broker.conf <<EOF
#所属集群名字
brokerClusterName=DefaultCluster
#broker名字，注意此处不同的配置文件填写的不一样，如果在broker-a.properties使用:broker-a,
#0 表示Master，>0 表示Slave
brokerId=0
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭 ！！！这里仔细看是false，false，false
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨4点
deleteWhen=04
#文件保留时间，默认48小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#限制的消息大小
maxMessageSize=65536
#Broker 的角色,ASYNC_MASTER 异步复制Master,SYNC_MASTER 同步双写Master,SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式:ASYNC_FLUSH 异步刷盘,SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#在broker-b.properties使用:broker-b
brokerName=${brokerName}
# 主机ip地址
brokerIP1=${hostsip}
EOF

四、启动 RocketMQ 集群

4.1、启动 RocketMQ 集群

• 开放端口 8080 用于管理界面
• 2台机器均需要操作

#   进入 RocketMQ 容器编排目录
cd /data/compose/rocketmq
#   启动 docker-compose
docker-compose up -d

4.2、通过 WEB RocketMQ 集群

• 开放端口 8080 用于管理界面
• 访问方式，ip:8080