4. 单机RocketMQ环境搭建：使用Docker Compose部署单节点RocketMQ（NameServer + Broker）

在生产环境中，RocketMQ 通常以集群形式部署，但单节点环境是学习核心组件交互、验证配置变更、进行功能测试的基础。本章将使用 Docker Compose 在单机上快速搭建一个包含 NameServer 和 Broker 的完整 RocketMQ 实例，并验证消息的收发流程。

4.1 架构概览：单节点 RocketMQ 组件关系

在单节点部署中，NameServer 和 Broker 运行在同一台宿主机的不同容器中。NameServer 负责维护 Broker 的路由信息，而 Broker 负责消息的存储与转发。Producer 和 Consumer 通过 NameServer 发现 Broker 地址，再与 Broker 直接通信。

4.2 环境准备与目录结构

在开始部署之前，需要确保宿主机已安装 Docker 和 Docker Compose。建议使用以下版本：

创建项目目录结构如下：

rocketmq-single/
├── docker-compose.yml
├── broker.conf
├── logs/
│   ├── namesrv/
│   └── broker/
└── store/
    ├── commitlog/
    ├── consumequeue/
    └── index/

4.3 编写 Broker 配置文件

Broker 的配置文件 broker.conf 是部署的核心。单节点部署时，需要特别注意 brokerIP1 的配置，确保 Producer 和 Consumer 能够正确连接到 Broker 容器。

# broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
# 关键配置：设置为宿主机 IP，否则客户端无法连接
brokerIP1 = 192.168.1.100
# 监听端口
listenPort = 10911
# 存储路径
storePathRootDir = /home/rocketmq/store
storePathCommitLog = /home/rocketmq/store/commitlog
# 自动创建 Topic
autoCreateTopicEnable = true
# 自动创建消费组
autoCreateSubscriptionGroup = true
# 消息存储时间（小时），默认 72 小时
fileReservedTime = 72
# 磁盘空间使用率警戒线，超过则拒绝写入
diskMaxUsedSpaceRatio = 85

4.4 编写 Docker Compose 编排文件

docker-compose.yml 文件定义了 NameServer 和 Broker 两个服务。NameServer 先启动，Broker 后启动并注册到 NameServer。

version: '3.8'
services:
  namesrv:
    image: apache/rocketmq:5.1.4
    container_name: rmqnamesrv
    ports:
      - "9876:9876"
    volumes:
      - ./logs/namesrv:/home/rocketmq/logs
    environment:
      - JAVA_OPT_EXT=-Xms512m -Xmx512m -Xmn256m
    command: sh mqnamesrv
    networks:
      - rocketmq-net

  broker:
    image: apache/rocketmq:5.1.4
    container_name: rmqbroker
    ports:
      - "10911:10911"
      - "10909:10909"
    volumes:
      - ./broker.conf:/home/rocketmq/rocketmq-5.1.4/conf/broker.conf
      - ./logs/broker:/home/rocketmq/logs
      - ./store:/home/rocketmq/store
    environment:
      - JAVA_OPT_EXT=-Xms1g -Xmx1g -Xmn512m
    command: sh mqbroker -c /home/rocketmq/rocketmq-5.1.4/conf/broker.conf
    depends_on:
      - namesrv
    networks:
      - rocketmq-net

networks:
  rocketmq-net:
    driver: bridge

4.5 启动与验证

执行以下命令启动服务：

# 启动所有服务
docker-compose up -d

# 查看容器状态
docker-compose ps

# 查看 NameServer 日志
docker logs rmqnamesrv -f

# 查看 Broker 日志
docker logs rmqbroker -f

启动成功后，Broker 日志中应包含类似以下内容，表示已成功注册到 NameServer：

The broker[broker-a, 192.168.1.100:10911] boot success. serializeType=JSON
register broker to name server 172.18.0.2:9876 OK

4.6 测试消息收发

使用 RocketMQ 官方提供的工具脚本进行消息收发测试。进入 Broker 容器执行：

# 进入 Broker 容器
docker exec -it rmqbroker bash

# 发送消息（默认 Topic: TestTopic）
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

# 消费消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

如果看到类似以下输出，说明环境搭建成功：

SendResult [sendStatus=SEND_OK, msgId=...
ConsumeMessageThread_1 Receive New Messages: [MessageExt...

4.7 常见问题与排查