rocketmq 服务部署

# RocketMQ 服务部署总结 ## 核心配置 1. **Broker 配置** - **刷盘方式**: `flushDiskType=ASYNC_FLUSH`（异步刷盘） - **监听端口**: `listenPort`（主节点：10911，从节点：11011） - **NameServer 地址**: `namesrvAddr=192.168.166.20:9876;192.168.166.206:9876` - **主题队列数**: `defaultTopicQueueNums=8` - **自动创建Topic/订阅组**: `autoCreateTopicEnable=true`（生产环境建议关闭） 2. **存储路径** - **主节点存储路径**: `/root/rocketmq/data/store-a` - **从节点存储路径**: `/Users/gitsilence/JavaTools/rocketmq/data/store-b` 3. **文件大小配置** - **CommitLog 文件大小**: `mapedFileSizeCommitLog=1073741824`（1G） - **ConsumeQueue 文件大小**: `mapedFileSizeConsumeQueue=300000`（默认30万条） ## 部署步骤 1. **启动 NameServer** - 启动命令：`nohup /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqnamesrv >> /Users/gitsilence/JavaTools/rocketmq/logs/namesrv/namesrv.log &` - Linux 启动：`nohup /root/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqnamesrv >> /root/rocketmq/logs/namesrv/namesrv.log &` 2. **启动 Broker** - **主节点**: `nohup /root/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqbroker -c /root/rocketmq/conf/2m-2s-async/broker-b.properties >> /root/rocketmq/logs/broker/broker-b.log &` - **从节点**: `nohup /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqbroker -c /Users/gitsilence/JavaTools/rocketmq/conf/2m-2s-async/broker-a-s.properties >> /Users/gitsilence/JavaTools/rocketmq/logs/broker/broker-a.log &` 3. **关闭 Broker/NameServer** - 关闭命令：`/Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqshutdown [namesrv/broker]` ## 监控部署 1. **可视化监控** - 下载并启动 RocketMQ Console： ```bash git clone git@github.com:apache/rocketmq-externals.git cd rocketmq-externals git checkout release-rocketmq-console-1.0.0 cd rocketmq-console mvn clean package -Dmaven.test.skip=true nohup java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='192.168.166.20:9876;192.168.166.206:9876' >> /Users/gitsilence/JavaTools/rocketmq/logs/mq-console.log & ``` - 访问地址：`http://localhost:8080` ## 依赖管理 - **JAR 包**: RocketMQ 提供多个模块的 JAR 包，包括 `rocketmq-broker`, `rocketmq-client`, `rocketmq-remoting` 等。 ## 运行时注意事项 1. **日志路径** - NameServer 日志：`/Users/gitsilence/JavaTools/rocketmq/logs/namesrv/namesrv.log` - Broker 日志：`/Users/gitsilence/JavaTools/rocketmq/logs/broker/broker-a.log` 2. **内存配置** - 测试环境可调整启动脚本的内存配置，避免内存过大导致性能浪费。 3. **网络配置** - 确保 NameServer 和 Broker 的网络连通性，避免端口冲突。 4. **文件保留时间** - 默认删除时间：凌晨4点，文件保留时间：48小时。 ## 总结 RocketMQ 的部署涉及配置文件的详细设置、存储路径的规划、网络端口的分配以及监控的搭建。通过合理的配置和监控，可以确保 RocketMQ 高效稳定的运行。