# docker-compose-cluster.yml
version: '3.8'
services:
  # ========== NameServer 集群 ==========
  namesrv1:
    image: apache/rocketmq:5.1.4
    container_name: rocketmq-namesrv1
    command: sh mqnamesrv
    ports:
      - "9876:9876"
    environment:
      - JAVA_OPT_EXT=-Xms512m -Xmx512m

  namesrv2:
    image: apache/rocketmq:5.1.4
    container_name: rocketmq-namesrv2
    command: sh mqnamesrv
    ports:
      - "9877:9876"
    environment:
      - JAVA_OPT_EXT=-Xms512m -Xmx512m

  # ========== Broker-A Master ==========
  broker-a-m:
    image: apache/rocketmq:5.1.4
    container_name: rocketmq-broker-a-m
    command: sh mqbroker -c /home/rocketmq/conf/broker-a-m.conf
    ports:
      - "11911:11911"   # remoting
      - "11909:11909"   # VIP channel
    volumes:
      - ./conf/broker-a-m.conf:/home/rocketmq/rocketmq-5.1.4/conf/broker-a-m.conf
      - ./data/broker-a-m:/home/rocketmq/store
    environment:
      - JAVA_OPT_EXT=-Xms2g -Xmx2g

  # ========== Broker-A Slave ==========
  broker-a-s:
    image: apache/rocketmq:5.1.4
    container_name: rocketmq-broker-a-s
    command: sh mqbroker -c /home/rocketmq/conf/broker-a-s.conf
    ports:
      - "12911:12911"
      - "12909:12909"
    volumes:
      - ./conf/broker-a-s.conf:/home/rocketmq/rocketmq-5.1.4/conf/broker-a-s.conf
      - ./data/broker-a-s:/home/rocketmq/store
    environment:
      - JAVA_OPT_EXT=-Xms2g -Xmx2g

  # ========== Dashboard ==========
  dashboard:
    image: apacherocketmq/rocketmq-dashboard:1.0.1
    container_name: rocketmq-dashboard
    ports:
      - "8080:8080"
    environment:
      - JAVA_OPTS=-Drocketmq.namesrv.addr=namesrv1:9876;namesrv2:9876

# conf/broker-a-m.conf —— Master-A
brokerClusterName = DefaultCluster
brokerName = broker-a           # Broker组名——同一组的Master和Slave用同一个名字
brokerId = 0                    # 0=Master, 非0=Slave
brokerRole = SYNC_MASTER        # 同步主从
flushDiskType = ASYNC_FLUSH     # 异步刷盘（可靠性交给主从同步）
namesrvAddr = namesrv1:9876;namesrv2:9876   # 两个 NameServer
listenPort = 11911
storePathRootDir = /home/rocketmq/store
storePathCommitLog = /home/rocketmq/store/commitlog
autoCreateTopicEnable = false   # 生产环境关闭——Topic 必须手动创建

# conf/broker-a-s.conf —— Slave-A
brokerClusterName = DefaultCluster
brokerName = broker-a           # 和 Master 同一个 brokerName
brokerId = 1                    # 非 0 表示 Slave
brokerRole = SLAVE
flushDiskType = ASYNC_FLUSH
namesrvAddr = namesrv1:9876;namesrv2:9876
listenPort = 12911
storePathRootDir = /home/rocketmq/store

# 进入 Broker 容器创建 Topic
docker exec -it rocketmq-broker-a-m sh mqadmin updateTopic \
  -n namesrv1:9876 \
  -t order-topic \          # Topic 名称
  -c DefaultCluster \       # 集群名
  -w 8 \                    # 写 Queue 数
  -r 8                      # 读 Queue 数（通常和写一致）

# 验证
docker exec -it rocketmq-broker-a-m sh mqadmin topicList \
  -n namesrv1:9876

# Broker 的 JVM 参数（docker-compose 中 environment 段）
JAVA_OPT_EXT=-Xms4g -Xmx4g \
  -XX:+UseG1GC \                           # 用 G1 GC（低延迟）
  -XX:G1HeapRegionSize=16m \               # G1 region 大小
  -XX:MaxGCPauseMillis=200 \               # 目标 GC 停顿 < 200ms
  -XX:InitiatingHeapOccupancyPercent=45 \  # 堆使用 45% 开始并发标记
  -XX:+PrintGCDetails \
  -XX:+PrintGCDateStamps

# 虚拟内存——防止 CommitLog 写入时 OOM
sysctl -w vm.min_free_kbytes=1048576

# 最大文件句柄数——CommitLog 和 ConsumeQueue 需要大量文件描述符
ulimit -n 65536

rocketmq:
  name-server: namesrv1:9876;namesrv2:9876
  producer:
    group: order-producer-group
    # 发送超时（ms）——同步发送时最关键
    send-message-timeout: 5000
    # 重试次数——生产端重试，不是消费端
    retry-times-when-send-failed: 3
    retry-times-when-send-async-failed: 3
    # 客户端线程池大小
    compress-message-body-threshold: 4096
    # 消息体超过此大小自动压缩
    max-message-size: 4194304

@RocketMQMessageListener(
    topic = "order-topic",
    consumerGroup = "order-consumer-group",
    consumeThreadNumber = 30,           // 消费线程数——不是越大越好
    consumeMessageBatchMaxSize = 32,    // 每次拉取最多 32 条
    maxReconsumeTimes = 5              // 最大重试次数——不要总用默认 16 次
)