1. RocketMQ 5.3.2单机部署环境准备在开始部署RocketMQ 5.3.2之前我们需要确保系统环境满足基本要求。我建议使用CentOS 7或Ubuntu 18.04及以上版本作为操作系统这些系统经过广泛测试兼容性较好。以下是具体环境要求Java环境RocketMQ 5.3.2需要JDK 1.8或更高版本。我推荐使用Oracle JDK 1.8.0_361这个版本在生产环境中表现稳定。可以通过以下命令检查Java版本java -version系统资源内存至少2GB可用内存实际生产环境建议4GB以上磁盘空间至少10GB可用空间CPU双核以上网络配置确保9876NameServer端口和10911Broker端口未被占用如果启用了防火墙需要开放相应端口注意虽然RocketMQ官方文档中建议的JVM内存配置较高如Xms4g但在单机测试环境下我们可以适当降低内存配置。这也是为什么后续我们需要修改启动脚本中的JVM参数。2. 下载与安装RocketMQ 5.3.22.1 获取安装包RocketMQ官方提供了二进制发行版我们可以直接从Apache镜像站点下载。我建议创建一个专门的目录来存放安装文件保持系统整洁mkdir -p /opt/soft/rocketmq cd /opt/soft/rocketmq wget https://archive.apache.org/dist/rocketmq/5.3.2/rocketmq-all-5.3.2-bin-release.zip2.2 解压与目录结构下载完成后解压压缩包并移动到合适的安装位置unzip rocketmq-all-5.3.2-bin-release.zip mv rocketmq-all-5.3.2-bin-release /opt/rocketmq-5.3.2解压后的目录结构如下/opt/rocketmq-5.3.2/ ├── bin/ # 启动脚本和工具 ├── conf/ # 配置文件 ├── lib/ # 依赖库 └── logs/ # 日志文件启动后生成3. 关键配置调整3.1 JVM参数优化RocketMQ默认的JVM内存配置针对生产环境设计对于单机测试来说过高。我们需要修改bin目录下的三个关键脚本runserver.shNameServer配置# 修改前 JAVA_OPT${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m # 修改后 JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320mrunbroker.shBroker配置# 修改前 JAVA_OPT${JAVA_OPT} -server -Xms8g -Xmx8g # 修改后 JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256mtools.sh工具脚本配置# 修改前 JAVA_OPT${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn256m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize128m # 修改后 JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize128m经验分享在实际操作中我发现即使降低了内存配置RocketMQ仍能稳定运行。但要注意如果日志中出现内存不足的警告可以适当增加Xms和Xmx的值。3.2 Broker核心配置编辑conf/broker.conf文件配置Broker的基本参数brokerClusterName DefaultCluster brokerName broker-a brokerId 0 deleteWhen 04 fileReservedTime 48 brokerRole ASYNC_MASTER flushDiskType ASYNC_FLUSH namesrvAddr 127.0.0.1:9876 brokerIP1 你的服务器IP autoCreateTopicEnabletrue关键参数说明namesrvAddrNameServer地址单机部署时设为127.0.0.1:9876autoCreateTopicEnable是否自动创建Topic测试环境可以开启生产环境建议关闭flushDiskType刷盘方式ASYNC_FLUSH性能更好但可能丢失少量数据4. 启动与验证4.1 启动NameServerNameServer是RocketMQ的注册中心需要首先启动cd /opt/rocketmq-5.3.2/bin nohup ./mqnamesrv -c ../conf/broker.conf ../logs/mqnamesrv.log 21 检查启动日志tail -f ../logs/mqnamesrv.log看到The Name Server boot success表示启动成功。4.2 启动BrokerBroker是消息存储和转发的核心组件nohup ./mqbroker -c ../conf/broker.conf ../logs/mqbroker.log 21 验证Broker状态tail -f ../logs/mqbroker.log看到The broker[broker-a, IP:10911] boot success表示启动成功。4.3 基础功能测试发送测试消息export NAMESRV_ADDRlocalhost:9876 ./tools.sh org.apache.rocketmq.example.quickstart.Producer消费测试消息export NAMESRV_ADDRlocalhost:9876 ./tools.sh org.apache.rocketmq.example.quickstart.Consumer5. 管理控制台部署虽然命令行工具已经足够管理RocketMQ但可视化控制台能提供更直观的操作体验。5.1 下载控制台RocketMQ官方提供了一个基于Spring Boot的控制台应用wget https://github.com/apache/rocketmq-dashboard/releases/download/rocketmq-dashboard-1.0.0/rocketmq-dashboard-1.0.0.jar -O /opt/rocketmq-5.3.2/rocketmq-dashboard.jar5.2 启动控制台cd /opt/rocketmq-5.3.2 nohup java -jar -Drocketmq.config.namesrvAddrlocalhost:9876 -Dserver.port8080 rocketmq-dashboard.jar dashboard.log 21 访问地址http://服务器IP:80806. 常见问题排查6.1 启动时报内存不足现象启动时出现insufficient memory错误解决方案确认已按照3.1节修改了JVM参数检查系统可用内存free -m如果确实内存不足可以尝试进一步降低Xms和Xmx的值6.2 控制台无法连接现象控制台启动后无法显示Broker信息排查步骤检查NameServer地址配置是否正确确认防火墙已开放9876和10911端口查看控制台日志tail -f dashboard.log6.3 消息发送/消费失败现象Producer或Consumer报连接错误可能原因NameServer未启动Broker未启动网络连接问题验证方法netstat -tulnp | grep 9876 # 检查NameServer端口 netstat -tulnp | grep 10911 # 检查Broker端口7. 生产环境注意事项虽然本文介绍的是单机部署但如果你计划将这套环境用于生产还需要考虑以下方面高可用部署至少部署2个NameServer和2个Broker主从持久化配置确保消息数据存储在可靠的磁盘上监控告警集成Prometheus和Grafana监控关键指标定期维护设置日志轮转和磁盘空间监控我在实际项目中遇到过因为磁盘空间不足导致Broker挂掉的情况建议设置一个cron任务定期检查磁盘使用率# 每天检查一次磁盘空间 0 0 * * * df -h /opt/rocketmq-5.3.2/store /tmp/rocketmq_disk.log最后RocketMQ 5.3.2相比早期版本在事务消息和延迟消息方面有了很大改进如果你需要这些高级功能可以参考官方文档进行更深入的配置。
