一、环境清理与初始化

1.1 二进制服务终止

在容器化迁移前，需彻底清理可能存在的二进制残留服务。首先通过进程管理工具定位服务进程：

# 使用jps定位Java进程（推荐）
jps -l | grep -E 'NamesrvStartup|BrokerStartup'
# 或使用ps命令（兼容性更强）
ps -ef | grep -E 'org.apache.rocketmq.namesrv|org.apache.rocketmq.broker'

获取进程ID后，执行优雅终止（建议先尝试SIGTERM）：

kill -15 <PID>  # 优先尝试优雅终止
sleep 5         # 等待5秒
kill -9 <PID>   # 强制终止（仅在必要情况下使用）

1.2 环境变量重置

检查系统级环境变量配置，避免与容器环境冲突：

# 检查/etc/profile中的配置
grep -i rocketmq /etc/profile
# 若存在配置，使用sed命令批量清理
sed -i '/ROCKETMQ_HOME/d;/export PATH.*rocketmq/d' /etc/profile
source /etc/profile  # 立即生效

1.3 数据目录清理

根据实际部署情况清理持久化数据目录（谨慎操作）：

rm -rf /data/rocketmq/namesrv/*  # NameServer数据
rm -rf /data/rocketmq/broker/*   # Broker数据

二、容器平台搭建

2.1 Docker引擎安装

在CentOS/RHEL 8+系统推荐使用dnf包管理器：

# 添加官方仓库（网络良好时）
dnf config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo
# 或使用国内镜像源（推荐）
tee /etc/yum.repos.d/docker-ce.repo <<-'EOF'
[docker-ce-stable]
name=Docker CE Stable
baseurl=https://mirrors.aliyun.com/docker-ce/linux/centos/8/$basearch/stable
enabled=1
gpgcheck=0
EOF
# 安装核心组件
dnf install -y docker-ce docker-ce-cli containerd.io

2.2 服务启动与验证

systemctl enable --now docker
docker version  # 验证安装
docker run hello-world  # 测试基础功能

2.3 镜像加速配置

创建或修改/etc/docker/daemon.json文件：

{
  "registry-mirrors": [
    "https://<your-mirror-domain>",
    "https://mirror.baidubce.com"
  ],
  "exec-opts": ["native.cgroupdriver=systemd"]
}

应用配置后重启服务：

systemctl restart docker
docker info | grep -i mirror  # 验证配置生效

三、RocketMQ容器化部署

3.1 网络规划

创建专用网络实现组件隔离：

docker network create --subnet=172.18.0.0/16 rocketmq-net

3.2 NameServer部署

docker run -d --name rmq-namesrv \
  --network rocketmq-net \
  -p 9876:9876 \
  -v /data/rocketmq/namesrv:/home/rocketmq/logs \
  --restart unless-stopped \
  apache/rocketmq:5.3.2 \
  sh mqnamesrv

关键参数说明：

-v：持久化日志目录
--restart：自动重启策略
9876：默认RPC端口

3.3 Broker节点部署

docker run -d --name rmq-broker \
  --network rocketmq-net \
  -p 10909:10909 -p 10911:10911 \
  -e "NAMESRV_ADDR=rmq-namesrv:9876" \
  -v /data/rocketmq/broker:/home/rocketmq/store \
  -v /data/rocketmq/conf/broker.conf:/opt/rocketmq/conf/broker.conf \
  --restart unless-stopped \
  apache/rocketmq:5.3.2 \
  sh mqbroker -c /opt/rocketmq/conf/broker.conf

配置文件示例（broker.conf）：

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/home/rocketmq/store
storePathCommitLog=/home/rocketmq/store/commitlog
storePathConsumeQueue=/home/rocketmq/store/consumequeue
storePathIndex=/home/rocketmq/store/index

3.4 控制台部署

docker run -d --name rmq-dashboard \
  --network rocketmq-net \
  -p 8080:8080 \
  -e "JAVA_OPTS=-Drocketmq.namesrv.addr=rmq-namesrv:9876" \
  --restart unless-stopped \
  apache/rocketmq-dashboard:latest

访问http://<host-ip>:8080即可进入管理界面，可查看：

集群拓扑结构
消息生产消费统计
主题/队列详情
消费者连接状态

四、生产环境优化建议

4.1 高可用架构

建议部署双主双从架构：

# Broker节点2配置示例
docker run -d --name rmq-broker-slave \
  --network rocketmq-net \
  -e "NAMESRV_ADDR=rmq-namesrv:9876" \
  -e "BROKER_ROLE=SLAVE" \
  -e "AUTO_CREATE_TOPIC_ENABLE=true" \
  apache/rocketmq:5.3.2 \
  sh mqbroker -c /opt/rocketmq/conf/broker-slave.conf

4.2 资源限制

通过--memory和--cpus参数限制容器资源：

docker update --memory 4g --cpus 2 rmq-broker

4.3 监控集成

推荐使用Prometheus+Grafana监控方案：

部署exporter容器
配置Grafana数据源
导入RocketMQ专用仪表盘

4.4 备份策略

建议配置定时任务备份关键数据：

# 每日凌晨备份
0 0 * * * docker exec rmq-broker sh -c 'tar -czf /backup/broker-data-$(date +%Y%m%d).tar.gz /home/rocketmq/store'

五、常见问题处理

5.1 端口冲突

使用netstat -tulnp检查端口占用，修改容器映射端口或终止冲突进程。

5.2 连接拒绝

检查：

NameServer地址配置是否正确
防火墙规则是否放行相关端口
网络模式是否选择正确（建议使用bridge模式）

5.3 性能调优

根据实际负载调整以下参数：

JVM内存分配（-Xms/-Xmx）
消息存储路径（建议使用SSD）
线程池配置（根据CPU核心数调整）

通过本方案实现的容器化部署，相比传统二进制方式具有以下优势：

环境一致性保障：消除”在我机器上能运行”的问题
资源利用率提升：通过容器编排实现动态扩缩容
运维效率提高：标准化部署流程缩短交付周期
故障恢复更快：自动重启策略结合健康检查

建议生产环境至少部署2个NameServer节点和2个Broker主节点，通过负载均衡器对外提供服务，确保系统高可用性。

RocketMQ容器化部署全流程指南：从环境准备到监控运维