rocketmq 服务部署

• 语言: 中文（简体）
• 格式: .pdf
• 来源: b3logfile.com

摘要

本文档详细介绍了RocketMQ服务的部署过程，包括单机部署、可视化监控的搭建、配置文件的编辑、集群部署以及启动命令等内容。文档首先介绍了RocketMQ的基本概念和部署环境，然后详细说明了如何配置和启动NameServer与Broker服务，包括主从节点的配置与启动。此外，文档还提供了集群部署的步骤和注意事项，包括双主双从异步复制模式的配置，并通过示例展示了如何使用mqadmin工具检查集群状态。

AI总结

《RocketMQ 服务部署》总结：

### 1. 部署概述
- **RocketMQ** 是一个分布式消息队列系统，支持高并发、大规模集群部署。
- 本文档主要介绍了 RocketMQ 的单机部署、可视化监控部署以及集群部署（双主双从异步复制模式）。

---

### 2. 配置文件说明
#### Master 节点配置（`broker-a.properties`）
- **集群名称**：`mq-broker-cluster`
- **角色**：`ASYNC_MASTER`（异步复制主节点）
- **端口**：`listenPort=10911`
- **NameServer 地址**：`namesrvAddr=192.168.166.20:9876;192.168.166.206:9876`
- **存储路径**：
- `storePathRootDir=/root/rocketmq/data/store-a`
- `storePathCommitLog=/root/rocketmq/data/store-a/commitlog`
- `storePathConsumerQueue=/root/rocketmq/data/store-a/consumequeue`
- `storePathIndex=/root/rocketmq/data/store-a/index`

#### Slave 节点配置（`broker-a-s.properties`）
- **角色**：`SLAVE`
- **端口**：`listenPort=11011`
- **刷盘方式**：`flushDiskType=ASYNC_FLUSH`（异步刷盘）
- **NameServer 地址**：`namesrvAddr=192.168.166.20:9876;192.168.166.206:9876`

---

### 3. 集群部署
- **架构**：双主双从异步复制模式，两台机器（Mac 和 CentOS）组成集群。
- **端口要求**：
- NameServer：`9876`
- Broker：`10911`（主节点）、`11011`（从节点）
- **注意事项**：
- 确保机器在同一网段，防火墙开放相关端口。
- 启动顺序：先启动 Master 节点，再启动 Slave 节点。

---

### 4. 启动步骤
#### 启动 Master 节点（Mac）

nohup /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqbroker -c /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/conf/2m-2s-async/broker-a.properties > /Users/gitsilence/JavaTools/rocketmq/logs/broker/master-broker-a.log &

#### 启动 Slave 节点（Linux）

nohup sh /root/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqbroker -c /root/rocketmq/rocketmq-4.9.2-SNAPSHOT/conf/2m-2s-async/broker-a-s.properties > /root/rocketmq/logs/broker/slave-broker-a.log &

#### 启动 NameServer

nohup /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqnamesrv > /Users/gitsilence/JavaTools/rocketmq/logs/namesrv/namesrv.log &

---

### 5. 可视化监控部署
- **步骤**：
1. 克隆 RocketMQ-Console 仓库：`git clone [e-mail]:apache/rocketmq-externals.git`
2. 切换到 `release-rocketmq-console-1.0.0` 分支。
3. 构建：`mvn clean package -Dmaven.test.skip=true`
4. 启动：`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`

---

### 6. 其他注意事项
- **日志警告**：文档中提到 `RocketMQLog:WARN No appenders could be found for logger`，需确保日志系统初始化配置正确。
- **存储路径**：根据业务需求调整 `mappedSizeCommitLog` 和 `mappedSizeConsumeQueue`。
- **关闭自动创建**：生产环境建议关闭 `autoCreateTopicEnable` 和 `autoCreateSubscriptionGroup`。

---

### 7. 启动后检查
- 使用 `mqadmin clusterList` 检查集群状态。
- 使用 `jps` 查看进程是否启动成功。

---

总结：本文档详细介绍了 RocketMQ 的部署流程，包括单机部署、集群部署和可视化监控的实现，适用于需要快速搭建 RocketMQ 集群的场景。