一、单机部署适用场景与优势

RocketMQ作为Apache顶级消息中间件，单机部署模式在开发测试、小型业务系统及资源受限环境中具有显著价值。相较于集群模式，单机部署具有三大核心优势：其一，资源占用低，仅需单台服务器即可运行完整服务；其二，部署简单，省去集群协调与网络配置复杂度；其三，维护成本低，适合预算有限的初创团队或个人开发者。典型应用场景包括本地开发环境搭建、CI/CD流水线集成测试、小型业务系统的异步处理等。

二、环境准备与依赖检查

1. 基础环境要求

操作系统：推荐CentOS 7+/Ubuntu 18.04+ LTS版本，需关闭SELinux（setenforce 0）
Java环境：JDK 1.8+（推荐OpenJDK或Oracle JDK），通过java -version验证
磁盘空间：至少预留20GB可用空间（存储日志与消息数据）
内存配置：建议8GB+内存，生产环境需根据消息吞吐量调整

2. 关键依赖安装

# 安装基础工具链
sudo yum install -y wget curl net-tools vim
# 配置NTP时间同步（避免时钟漂移导致消息顺序问题）
sudo yum install -y ntp
sudo systemctl enable ntpd
sudo systemctl start ntpd
# 创建专用用户（安全最佳实践）
sudo useradd -m -s /bin/bash rocketmq
sudo passwd rocketmq  # 设置密码

三、RocketMQ安装与配置

1. 下载与解压

# 下载最新稳定版（以5.1.0为例）
wget https://dist.apache.rocketmq.com/rocketmq/5.1.0/rocketmq-all-5.1.0-bin-release.zip
# 解压到指定目录
unzip rocketmq-all-5.1.0-bin-release.zip -d /opt
sudo chown -R rocketmq:rocketmq /opt/rocketmq-all-5.1.0-bin-release

2. 核心配置文件优化

修改conf/broker.conf关键参数：

# 基础配置
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
namesrvAddr = 127.0.0.1:9876  # 单机模式使用本地NameServer
# 存储配置
storePathRootDir = /data/rocketmq/store
storePathCommitLog = /data/rocketmq/store/commitlog
storePathConsumeQueue = /data/rocketmq/store/consumequeue
storePathIndex = /data/rocketmq/store/index
# 性能调优
deleteWhen = 04  # 每天4点删除过期文件
fileReservedTime = 72  # 文件保留72小时
mapedFileSizeCommitLog = 1073741824  # 1GB CommitLog文件
mapedFileSizeConsumeQueue = 300000  # 消费队列映射大小
diskMaxUsedSpaceRatio = 0.9  # 磁盘使用率阈值

3. 内存参数调整

编辑bin/runbroker.sh和bin/runserver.sh，根据服务器配置调整JVM参数：

# runserver.sh示例（NameServer）
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
# runbroker.sh示例（Broker）
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

四、启动与验证流程

1. 服务启动顺序

# 1. 启动NameServer（后台运行）
nohup sh bin/mqnamesrv &
# 2. 启动Broker（需指定配置文件）
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
# 3. 验证服务状态
jps | grep NamesrvStartup  # 应显示NamesrvStartup进程
jps | grep BrokerStartup   # 应显示BrokerStartup进程

2. 客户端连接测试

// 生产者示例
public class ProducerDemo {
    public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("test_group");
        producer.setNamesrvAddr("localhost:9876");
        producer.start();
        Message msg = new Message("TestTopic", "Hello RocketMQ".getBytes());
        producer.send(msg);
        producer.shutdown();
    }
}
// 消费者示例
public class ConsumerDemo {
    public static void main(String[] args) throws Exception {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("test_group");
        consumer.setNamesrvAddr("localhost:9876");
        consumer.subscribe("TestTopic", "*");
        consumer.registerMessageListener((msgs, context) -> {
            for (MessageExt msg : msgs) {
                System.out.println("Received: " + new String(msg.getBody()));
            }
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });
        consumer.start();
    }
}

3. 管理控制台部署（可选）

# 下载控制台
git clone https://github.com/apache/rocketmq-dashboard.git
cd rocketmq-dashboard
mvn clean package -Dmaven.test.skip=true
# 启动控制台（默认端口8080）
java -jar target/rocketmq-dashboard-1.0.1.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876

五、生产环境优化建议

持久化存储：使用SSD磁盘提升I/O性能，配置RAID10增强可靠性
监控告警：集成Prometheus+Grafana监控消息积压、磁盘空间等关键指标
日志管理：配置logback.xml实现日志轮转，避免日志文件过大
参数调优：
- 调整sendMessageThreadPoolNums（默认8）提升发送吞吐量
- 优化pullRequestHoldTimeout（默认5s）平衡延迟与资源占用
安全加固：
- 启用ACL权限控制（修改conf/plain_acl.yml）
- 限制控制台访问IP范围

六、常见问题解决方案

OOM错误：检查JVM内存配置，确保-Xmx不超过物理内存的70%
消息堆积：增加消费者实例数，或调整consumeThreadMin/Max参数
NameServer不可用：检查防火墙设置（默认9876端口），确认namesrvAddr配置正确
Broker启动失败：检查storePathRootDir目录权限，确保有读写权限

通过以上步骤，您可完成RocketMQ单机环境的完整部署。对于生产环境，建议定期备份commitlog目录，并制定滚动升级策略。单机模式虽简单，但需严格监控资源使用情况，当业务量增长至单机无法支撑时，可参考官方文档平滑迁移至集群模式。

RocketMQ单机部署全指南：从环境准备到生产调优