一、单机部署RocketMQ集群的核心价值

在开发测试或资源受限场景下，单机部署RocketMQ集群可通过多进程模拟实现高可用架构验证。相比单节点部署，集群模式支持消息复制、故障自动转移等核心功能，为后续生产环境迁移提供可靠验证路径。典型应用场景包括：

开发环境功能验证：避免因单点故障导致测试中断
预发布环境压力测试：模拟生产级消息吞吐量
边缘计算场景：在资源受限设备上构建轻量级消息总线

二、架构设计与组件配置

2.1 组件拓扑规划

采用1主1从+双NameServer架构，通过端口区分不同服务实例：

┌─────────────┐    ┌─────────────┐
│ NameServer  │    │ NameServer  │
│  9876/9877  │    │  9878/9879  │
└─────────────┘    └─────────────┘
       │                   │
       ▼                   ▼
┌───────────────────────────────┐
│           Broker Cluster       │
│ ┌─────────┐    ┌─────────┐   │
│ │ Master  │    │ Slave   │   │
│ │10911/10 │    │10921/10 │   │
│ │9091/10  │    │9092/10  │   │
│ └─────────┘    └─────────┘   │
└───────────────────────────────┘

2.2 配置文件详解

NameServer配置（namesrv.properties）

# 双实例配置示例
listenPort=9876  # 主实例端口
clusterName=RocketMQ-Cluster

Broker主节点配置（broker-a.properties）

brokerClusterName=RocketMQ-Cluster
brokerName=broker-a
brokerId=0  # 0表示Master
namesrvAddr=127.0.0.1:9876;127.0.0.1:9878
listenPort=10911
nettyServerPort=10909
storePathRootDir=/opt/rocketmq/store-a
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER  # 异步复制模式

Broker从节点配置（broker-b.properties）

brokerClusterName=RocketMQ-Cluster
brokerName=broker-a  # 必须与主节点相同
brokerId=1  # 1表示Slave
namesrvAddr=127.0.0.1:9876;127.0.0.1:9878
listenPort=10921
nettyServerPort=10919
storePathRootDir=/opt/rocketmq/store-b
haListenPort=10912  # 主从同步端口

三、部署实施步骤

3.1 环境准备

安装JDK 1.8+并配置JAVA_HOME
下载RocketMQ 4.9.4+稳定版本

配置系统参数（/etc/sysctl.conf）：

vm.max_map_count=655360
vm.overcommit_memory=1

3.2 服务启动流程

# 启动双NameServer
nohup sh mqnamesrv -c conf/namesrv1.properties >/dev/null 2>&1 &
nohup sh mqnamesrv -c conf/namesrv2.properties >/dev/null 2>&1 &
# 启动Broker主节点
nohup sh mqbroker -c conf/broker-a.properties >/dev/null 2>&1 &
# 启动Broker从节点
nohup sh mqbroker -c conf/broker-b.properties >/dev/null 2>&1 &

3.3 集群验证

使用mqadmin检查集群状态：
```
sh mqadmin clusterList -n 127.0.0.1:9876
```
预期输出应显示两个Broker实例，且Slave状态为RUNNING
发送测试消息验证复制：
```bash

生产者发送

export NAMESRV_ADDR=127.0.0.1:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

消费者验证

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer


# 四、生产环境适配建议
## 4.1 资源隔离方案
1. 使用cgroups限制每个Broker实例的CPU/内存：
```bash
# 创建资源控制组
cgcreate -g memory,cpu:rocketmq_group
# 限制主节点内存
cgset -r memory.limit_in_bytes=4G rocketmq_group/broker-a

文件系统隔离：

mount -o remount,noexec /opt/rocketmq/store-a

4.2 监控体系构建

Prometheus+Grafana监控方案：

# prometheus.yml配置片段
scrape_configs:
- job_name: 'rocketmq'
 metrics_path: '/metrics'
 static_configs:
   - targets: ['localhost:10911']

关键监控指标：

消息堆积量（mq_queue_msg_count）
同步延迟（mq_broker_sync_delay）
磁盘使用率（mq_disk_usage）

五、故障模拟与恢复演练

5.1 主节点宕机测试

# 模拟主节点故障
kill -9 $(ps aux|grep 'broker-a'|grep -v grep|awk '{print $2}')
# 观察从节点自动切换
tail -f /opt/rocketmq/store-b/log/rocketmq_slave_sync.log

5.2 数据恢复流程

修复后重新启动主节点：

rm -rf /opt/rocketmq/store-a/checkpoint
sh mqbroker -c conf/broker-a.properties &

验证数据一致性：

sh mqadmin printMsg -n 127.0.0.1:9876 -t TopicTest

六、性能调优参数

6.1 关键JVM参数

# broker.conf
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g"
JAVA_OPT="${JAVA_OPT} -XX:+UseG1GC -XX:G1HeapRegionSize=16m"
JAVA_OPT="${JAVA_OPT} -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5"

6.2 网络优化配置

# broker配置
nettyServerPort=10909
nettyClientPort=10911
sendMessageThreadPoolNums=16
pullMessageThreadPoolNums=32

七、常见问题解决方案

7.1 端口冲突处理

# 检查端口占用
netstat -tulnp|grep 9876
# 修改冲突端口后，需同步更新：
# 1. namesrvAddr配置
# 2. 防火墙规则
# 3. 系统服务绑定

7.2 存储空间不足

配置自动清理策略：

# broker配置
deleteWhen=04  # 每天4点删除
fileReservedTime=72  # 保留72小时
diskMaxUsedSpaceRatio=85  # 磁盘使用率超过85%触发告警

扩展存储路径：

mkdir -p /data/rocketmq/commitlog
ln -s /data/rocketmq/commitlog /opt/rocketmq/store/commitlog

通过上述架构设计与实施策略，开发者可在单台服务器上构建具备生产环境特性的RocketMQ集群，有效平衡资源限制与高可用需求。实际部署时应根据具体业务场景调整复制模式（ASYNC/SYNC）、消息保留策略等关键参数，并通过持续监控保障系统稳定性。

单机部署RocketMQ集群：单节点环境下的高可用实践指南