RocketMQ 集群容器多机编排主主

一、主机信息

  • 多机主主编排,如果主从改另外台配置就是了
  • 如需要多宿主机做集群,只需要分离配置文件
主机 IP地址 备注
rocketmq-01 192.168.8.7
rocketmq-02 192.168.8.8

二、创建 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

DJgunS.md.png

版权声明:
作者:Akiraka
链接:https://www.akiraka.net/linux/docker/838.html
来源:Akiraka
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
海报
RocketMQ 集群容器多机编排主主
一、主机信息 多机主主编排,如果主从改另外台配置就是了 如需要多宿主机做集群,只需要分离配置文件 主机 IP地址 备注 rocketmq-01 192.168.8.7 主 ……
<<上一篇
下一篇>>
文章目录
关闭
目 录