┌─────────────────┐
│  生產(chǎn)者(宿主機(jī))  │
└────────┬────────┘
         │ 查詢路由
         ↓
┌─────────────────┐
│  NameServer     │ → 返回 brokerIP=172.18.0.3
└─────────────────┘
         │
         │ 嘗試連接 172.18.0.3:10911 ? (不可達(dá))
         ↓
┌─────────────────┐
│ Broker 容器      │ 實(shí)際可訪問: 宿主機(jī)IP:10911
│ IP: 172.18.0.3  │
└─────────────────┘

# 在宿主機(jī)創(chuàng)建配置文件
cat > /usr/local/rocketmq/broker/conf/broker.conf << 'EOF'
brokerIP1=你的宿主機(jī)IP
autoCreateTopicEnable=true
EOF

# 停止并刪除舊容器
docker stop mqbroker && docker rm mqbroker
# 重新運(yùn)行，掛載配置文件
docker run -d --name mqbroker \
  -p 10911:10911 -p 10909:10909 \
  --network rocketmq \
  -v /usr/local/rocketmq/broker/logs:/root/logs \
  -v /usr/local/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-5.1.0/conf/broker.conf \
  -e "MAX_HEAP_SIZE=512M" \
  -e "HEAP_NEWSIZE=256M" \
  apache/rocketmq:5.1.0 sh mqbroker -n mqnamesrv:9876 \
  -c /home/rocketmq/rocketmq-5.1.0/conf/broker.conf

# 查看 Console 中的 Broker 信息
# 應(yīng)該看到 brokerIP1 已經(jīng)顯示為宿主機(jī) IP

Error connecting to Broker: Connection refused

┌─────────────────┐
│ Console 容器     │ → 訪問 mqbroker:10911 (容器網(wǎng)絡(luò))
└─────────────────┘
        │
        │ NameServer 返回: 宿主機(jī)IP:10911
        ↓
┌─────────────────┐
│ Broker 注冊(cè)地址  │ = 宿主機(jī)IP:10911
└─────────────────┘
        │
        │ Console 嘗試連接 宿主機(jī)IP:10911
        ↓
┌─────────────────┐
│ 網(wǎng)絡(luò)路由問題      │ 容器內(nèi)訪問宿主機(jī)IP需要特殊配置
└─────────────────┘

# 停止并刪除舊 Console
docker stop mqconsole && docker rm mqconsole
# 使用 host 網(wǎng)絡(luò)模式重新部署
docker run -d --name mqconsole --network host \
  -e "JAVA_OPTS=-Xmx256M -Xms256M -Xmn128M \
  -Drocketmq.namesrv.addr=127.0.0.1:9876 \
  -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
  styletang/rocketmq-console-ng

# 不再需要端口映射，直接訪問宿主機(jī)端口
# 假設(shè) Console 默認(rèn)端口是 8080
http://<宿主機(jī)IP>:8080

# 啟用本地路由轉(zhuǎn)發(fā)
sysctl -w net.ipv4.conf.all.route_localnet=1
# 放通防火墻規(guī)則
iptables -I INPUT -d <宿主機(jī)IP> -p tcp --dport 10911 -j ACCEPT

#!/bin/bash
# ========== 配置區(qū) ==========
BROKER_IP="192.168.1.100"  # 修改為你的宿主機(jī) IP
# ===========================
# 1. 創(chuàng)建網(wǎng)絡(luò)
docker network create rocketmq 2>/dev/null || echo "網(wǎng)絡(luò)已存在"
# 2. 創(chuàng)建目錄
mkdir -p /usr/local/rocketmq/nameserver/logs
mkdir -p /usr/local/rocketmq/broker/logs
mkdir -p /usr/local/rocketmq/broker/conf
chmod 777 -R /usr/local/rocketmq/*
# 3. 創(chuàng)建 Broker 配置文件
cat > /usr/local/rocketmq/broker/conf/broker.conf << EOF
brokerIP1=$BROKER_IP
autoCreateTopicEnable=true
namesrvAddr=mqnamesrv:9876
EOF
# 4. 啟動(dòng) NameServer
docker run -d --name mqnamesrv -p 9876:9876 --network rocketmq \
  -v /usr/local/rocketmq/nameserver/logs:/home/rocketmq/logs \
  -e "MAX_HEAP_SIZE=256M" \
  -e "HEAP_NEWSIZE=128M" \
  apache/rocketmq:5.1.0 sh mqnamesrv
# 等待 NameServer 啟動(dòng)
sleep 5
# 5. 啟動(dòng) Broker
docker run -d --name mqbroker \
  -p 10911:10911 -p 10909:10909 \
  --network rocketmq \
  -v /usr/local/rocketmq/broker/logs:/root/logs \
  -v /usr/local/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-5.1.0/conf/broker.conf \
  -e "MAX_HEAP_SIZE=512M" \
  -e "HEAP_NEWSIZE=256M" \
  apache/rocketmq:5.1.0 sh mqbroker -n mqnamesrv:9876 \
  -c /home/rocketmq/rocketmq-5.1.0/conf/broker.conf
# 等待 Broker 啟動(dòng)
sleep 10
# 6. 啟動(dòng) Console（使用 host 網(wǎng)絡(luò)）
docker run -d --name mqconsole --network host \
  -e "JAVA_OPTS=-Xmx256M -Xms256M -Xmn128M \
  -Drocketmq.namesrv.addr=127.0.0.1:9876 \
  -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
  styletang/rocketmq-console-ng
echo "========== 部署完成 =========="
echo "NameServer: localhost:9876"
echo "Broker: $BROKER_IP:10911"
echo "Console: http://localhost:8080"
echo "============================"

# application.yml
rocketmq:
  name-server: localhost:9876
  producer:
    group: hotel-booking-producer-group
    send-message-timeout: 3000
    retry-times-when-send-failed: 2

// 發(fā)送消息示例
@Service
public class OrderService {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    public void sendOrderMessage(Order order) {
        rocketMQTemplate.syncSend(
            "hotel-booking-test-topic:TEST_TAG",
            order,
            3000  // 超時(shí)時(shí)間 3 秒
        );
    }
}

# 檢查容器狀態(tài)
docker ps -a | grep mq
# 查看 NameServer 日志
docker logs mqnamesrv
# 查看 Broker 日志
docker logs mqbroker
# 測(cè)試生產(chǎn)者連接
telnet <宿主機(jī)IP> 10911
# 查看 Console 中的 Broker 狀態(tài)
# 訪問 http://<宿主機(jī)IP>:8080，檢查 "Broker" 菜單

version: '3.8'
services:
  namesrv:
    image: apache/rocketmq:5.1.0
    container_name: mqnamesrv
    ports:
      - "9876:9876"
    environment:
      - MAX_HEAP_SIZE=256M
      - HEAP_NEWSIZE=128M
    networks:
      - rocketmq
    command: sh mqnamesrv
    volumes:
      - ./data/namesrv/logs:/home/rocketmq/logs
  broker:
    image: apache/rocketmq:5.1.0
    container_name: mqbroker
    ports:
      - "10911:10911"
      - "10909:10909"
    environment:
      - MAX_HEAP_SIZE=512M
      - HEAP_NEWSIZE=256M
    networks:
      - rocketmq
    command: sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/rocketmq-5.1.0/conf/broker.conf
    volumes:
      - ./data/broker/logs:/root/logs
      - ./data/broker/conf/broker.conf:/home/rocketmq/rocketmq-5.1.0/conf/broker.conf
    depends_on:
      - namesrv
  console:
    image: styletang/rocketmq-console-ng
    container_name: mqconsole
    network_mode: host
    environment:
      - JAVA_OPTS=-Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false
    depends_on:
      - namesrv
      - broker
networks:
  rocketmq:
    driver: bridge

# 確保 broker.conf 中的 brokerIP1 已配置
docker-compose up -d