RocketMQ 5.3.2 Windows 单机部署：3步启动与端口占用排查（附防火墙规则）

RocketMQ 5.3.2 Windows 单机部署：3步极简启动与端口占用排查指南

1. 环境准备与快速部署方案

对于需要在Windows本地开发环境搭建RocketMQ的Java开发者来说，5.3.2版本带来了更简化的部署体验。我们将通过三个核心步骤完成基础环境搭建：

系统要求检查清单：

• 操作系统：Windows 10/11 64位
• JDK版本：1.8+（建议OpenJDK 11）
• 磁盘空间：至少500MB可用空间
• 内存：建议4GB以上空闲内存

部署前置操作：

1. 下载二进制发行包（推荐使用清华镜像加速）：

curl -O https://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/5.3.2/rocketmq-all-5.3.2-bin-release.zip

2. 解压到不含中文和空格的路径，例如：

tar -zxvf rocketmq-all-5.3.2-bin-release.zip -C C:\dev_tools\

2. 三步骤快速启动方案

2.1 一键启动NameServer

创建start_namesrv.cmd脚本文件，内容如下：

@echo off set ROCKETMQ_HOME=C:\dev_tools\rocketmq-all-5.3.2-bin-release start "RocketMQ NameServer" %ROCKETMQ_HOME%\bin\mqnamesrv.cmd

2.2 代理集成模式启动Broker

创建start_broker.cmd脚本文件：

@echo off set ROCKETMQ_HOME=C:\dev_tools\rocketmq-all-5.3.2-bin-release start "RocketMQ Broker" %ROCKETMQ_HOME%\bin\mqbroker.cmd -n 127.0.0.1:9876 --enable-proxy autoCreateTopicEnable=true

2.3 验证服务状态

创建check_status.cmd验证脚本：

@echo off tail -f %ROCKETMQ_HOME%\logs\rocketmqlogs\namesrv.log tail -f %ROCKETMQ_HOME%\logs\rocketmqlogs\proxy.log

关键日志确认点：

• NameServer成功日志：

The Name Server boot success...

• Broker成功日志：

The broker[broker-a,192.168.1.2:10911] boot success...

3. Windows特有问题解决方案

3.1 端口占用排查流程图

graph TD A[服务启动失败] --> B{检查端口占用} B -->|9876端口| C[netstat -ano | findstr 9876] B -->|10911端口| D[netstat -ano | findstr 10911] C --> E[taskkill /PID <占用进程ID> /F] D --> E E --> F[重新启动服务]

3.2 防火墙配置指南

使用管理员权限执行以下PowerShell命令：

New-NetFirewallRule -DisplayName "RocketMQ Ports" -Direction Inbound -LocalPort 9876,10909,10911,8080 -Protocol TCP -Action Allow

端口作用说明表：

3.3 内存调整方案

对于8GB以下内存设备，修改runbroker.cmd：

set "JAVA_OPT=%JAVA_OPT% -Xms1g -Xmx1g -Xmn512m"

调整为：

set "JAVA_OPT=%JAVA_OPT% -Xms512m -Xmx512m -Xmn256m"

4. 验证与基础测试

4.1 命令行测试

set NAMESRV_ADDR=localhost:9876 :: 生产者测试 tools.cmd org.apache.rocketmq.example.quickstart.Producer :: 消费者测试 tools.cmd org.apache.rocketmq.example.quickstart.Consumer

4.2 Java客户端测试

创建Maven项目并添加依赖：

<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>5.3.2</version> </dependency>

生产者示例代码：

public class SimpleProducer { public static void main(String[] args) throws Exception { DefaultMQProducer producer = new DefaultMQProducer("DemoProducerGroup"); producer.setNamesrvAddr("localhost:9876"); producer.start(); Message msg = new Message("TestTopic", "TagA", ("Hello RocketMQ").getBytes(StandardCharsets.UTF_8)); SendResult result = producer.send(msg); System.out.println("Send result: " + result); producer.shutdown(); } }

消费者示例代码：

public class SimpleConsumer { public static void main(String[] args) throws Exception { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("DemoConsumerGroup"); consumer.setNamesrvAddr("localhost:9876"); consumer.subscribe("TestTopic", "*"); consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> { msgs.forEach(msg -> { System.out.println("Received: " + new String(msg.getBody())); }); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }); consumer.start(); System.out.println("Consumer started."); } }

5. 管理控制台部署

5.1 控制台快速安装

git clone https://github.com/apache/rocketmq-dashboard.git cd rocketmq-dashboard mvn clean package -DskipTests java -jar target/rocketmq-dashboard-1.0.0.jar

关键配置项：

server.port=8080 rocketmq.config.namesrvAddrs=localhost:9876

5.2 控制台功能速览

• 集群概览监控
• 主题管理界面
• 消费者组追踪
• 消息轨迹查询
• 运维操作入口

6. 生产环境注意事项

性能调优参数表：

日志维护建议：

• 定期清理~/logs/rocketmqlogs/目录
• 配置日志轮转策略（使用logrotate工具）
• 敏感信息过滤：避免在日志中打印消息内容

7. 版本升级指南

从4.x迁移到5.x的关键变更点：

1. 代理层(Proxy)的引入
2. gRPC协议支持
3. 消息轨迹功能增强
4. 新的客户端API（推荐使用）
5. 增强的ACL控制

兼容性矩阵：

8. 排错工具箱

常见错误代码速查表：

诊断命令集合：

:: 查看NameServer状态 mqadmin.cmd clusterList -n localhost:9876 :: 检查Topic路由 mqadmin.cmd topicRoute -n localhost:9876 -t TestTopic :: 消费者进度查询 mqadmin.cmd consumerProgress -n localhost:9876 -g DemoConsumerGroup