小紫 RocketMQ — 产品特色与能力说明

贤紫优选 · 小紫基础设施系列

一、产品定位

小紫 RocketMQ 是一款面向企业自建 Apache RocketMQ 的 一站式部署与运维桌面工具。通过图形化向导与自动化脚本，把「装集群、日常维护、监控告警、备份迁移」从命令行搬到可点击、可追踪、可复现的流程里。

维度	说明
产品形态	Windows 桌面应用（Electron），通过 SSH 管理远程 Linux
目标用户	中间件运维、架构师、ISV 交付、中小企业 IT
核心价值	RocketMQ 全生命周期 — 图形化、自动化、可追溯
系列定位	与小紫 Redis、小紫 MySQL 同属「小紫基础设施」产品线
验证版本	RocketMQ 5.1.4（CentOS 7，systemd 托管）

二、六大产品特色

1. 四阶段平滑演进，一套工具走完全生命周期

不强迫企业「一步到位上多集群」。从单机试点到主从复制，再到 DLedger 高可用，最后到 多 Broker 集群 + RocketMQ 5.x Proxy，同一套产品、同一套运维登录 覆盖全路径。

单机 → 主从复制 → DLedger 高可用 → 多集群 + Proxy

2. 远程自动化部署，开箱即用的最佳实践模板

SSH 一键安装 NameServer / Broker / Proxy（yum 或本地上传安装包）
自动生成并下发 broker.conf、rmq-proxy.json、systemd 单元、防火墙规则
服务名统一：xianzi-rocketmq-namesrv / xianzi-rocketmq-broker / xianzi-rocketmq-proxy
部署过程 实时日志抽屉，支持取消、持久化，操作可追溯

3. 统一运维会话（OpsSession）

一次登录，维护、监控、巡检、扩缩容、通用工具 共用连接上下文：

自动识别拓扑：单机 / 主从 / DLedger 集群 / 多集群
从已保存部署配置 一键导入 连接信息
经跳板机执行 mqadmin、systemd 控制，敏感凭据留在主进程

4. 多集群 + Proxy 生产级运维

多 Broker 集群 独立部署（如 ClusterA / ClusterB）
Proxy 扩容/缩容，关联指定 Broker 集群
Slave 扩缩容，增量校验避免误拦无关集群状态
路由规则 查看与维护（rmq-proxy.json）
一键巡检：进程、注册、磁盘、Topic 等综合报告

5. 可观测 + 可治理 + 可审计

性能大盘：入/出 TPS、Topic 数、消费组数，ECharts 趋势图，本地 7 天落盘
后台调度：登录后每 30 秒自动采集指标，每分钟自动告警巡检与定时备份
告警中心：Broker 宕机、消费堆积、TPS 异常；支持持续时长阈值、15 分钟冷却去重
通知推送：桌面 / 钉钉 / 企业微信 / SMTP 邮件
Prometheus：本机 127.0.0.1 暴露 /metrics，供 Grafana 抓取
操作审计：Topic 管理、扩缩容、备份恢复、迁移等关键操作留痕

6. 私有化友好，能力边界清晰

适合 内网、政企、金融隔离区、交付现场 无法使用云消息服务的场景
消息体跨集群搬迁需 RocketMQ Replicator 或专业工具，本产品在 UI 与文档中 明确说明
元数据备份、Topic 同步、消费进度导出为 运维辅助，不替代专业消息迁移平台

三、四阶段架构与能力对照

阶段	架构形态	典型痛点	工具核心能力	典型场景
一：单机	NameServer + Broker	安装繁琐、目录混乱	单机部署、服务管理、Topic 管理	开发测试、POC
二：主从	Master-Slave Broker	读扩展、热备	主从批量部署、复制监控、维护	读多写少、同城灾备
三：DLedger	Raft 选主	Broker 宕机要自动切换	DLedger 部署、副本监控、扩缩容	生产核心消息链路 HA
四：多集群+Proxy	多 Broker 集群 + Proxy	多租户、多业务域、云原生接入	多集群部署、Proxy、路由规则、扩缩容、巡检	企业级消息中台、5.x 客户端经 Proxy

阶段演进示意

┌─────────────┐    ┌─────────────┐    ┌─────────────┐    ┌──────────────────────┐
│  阶段一     │    │  阶段二     │    │  阶段三     │    │  阶段四              │
│  单机       │ ─► │  主从复制   │ ─► │  DLedger    │ ─► │  多集群 + Proxy      │
│  快速验证   │    │  读扩展     │    │  自动选主   │    │  多业务域 + gRPC     │
└─────────────┘    └─────────────┘    └─────────────┘    └──────────────────────┘

四、功能能力全景（按模块）

4.1 部署模块

能力	说明
单机部署	CentOS 远程安装 NameServer + Broker，目录规划、systemd、卸载
主从复制部署	1 主 N 从，同步/异步复制，批量节点
DLedger 部署	基于 Raft 的 Broker 高可用，多副本
多集群 + Proxy 部署	多 Broker 集群、多 Proxy 节点，RocketMQ 5.x
本地上传安装	支持离线环境上传 `rocketmq-all-*.zip`、OpenJDK 包
部署日志	流式输出、进度条、可取消、可清空

4.2 运维模块（按拓扑）

能力	单机	主从	DLedger	多集群
运维登录	✅	✅	✅	✅
维护（服务控制）	✅	✅	✅	✅
监控概览	✅	✅	✅	✅
扩缩容	—	—	✅ 副本	✅ Slave/Proxy
巡检	—	—	—	✅
路由规则	—	—	—	✅

4.3 通用工具

菜单	能力	说明
RocketMQ 管理	Topic / 消费组 CRUD	基于 `mqadmin`
日志管理	多节点扫描、tail、清空	NameServer / Broker / Proxy
性能大盘	TPS 趋势、集群规模	30s 自动采集 + 手动刷新
消息堆积	`consumerProgress` 解析	按堆积量排序、热点统计
告警中心	规则 / 历史 / 通知 / Prometheus	后台定时巡检 + 推送
深度诊断	进程、注册、磁盘、Topic	一键体检报告
备份恢复	元数据备份 + 定时策略	Topic、消费组、消费进度原文
消息迁移	跨集群 Topic 元数据同步	预检 + 执行 + 历史
操作审计	关键操作留痕	操作人、时间、结果

4.4 平台与安全

能力	说明
贤紫优选账号登录	企业软件统一门禁
免责协议	首次使用确认
进程隔离	Main / Preload / Renderer，凭据不暴露给页面
IPC 白名单	敏感操作需已建立运维会话
配置持久化	部署配置、指标、告警、备份、审计本地保存

五、告警与可观测能力详解

5.1 内置告警规则

规则类型	默认说明	持续时长
Broker 进程停止	systemd 检测 Broker 未 active	可配置（默认 1 分钟）
消费堆积超阈值	`consumerProgress` 总堆积	可配置（默认 5 分钟）
TPS 长期为 0	有 Topic 但入/出 TPS 均为 0	可配置（默认 10 分钟）

触发后：写入本地告警历史 + 推送通知（桌面/钉钉/企微/邮件），同规则 15 分钟内不重复推送。

5.2 后台调度器

任务	周期	条件
指标采集	30 秒	已运维登录且监控未暂停
告警巡检	1 分钟	同上
定时备份	1 分钟（Cron 匹配）	已运维登录

5.3 Prometheus 指标

启用后监听 http://127.0.0.1:{port}/metrics，示例指标：

xianzi_rocketmq_in_tps
xianzi_rocketmq_out_tps
xianzi_rocketmq_topic_count
xianzi_rocketmq_consumer_group_count
xianzi_rocketmq_broker_in_tps / broker_out_tps（按 Broker 标签）

六、备份与迁移说明

6.1 备份内容

每次备份包含：

topics.json — Topic 列表
consumer-groups.json — 消费组摘要
consumer-progress.txt — consumerProgress 原始输出
consumer-backlog.json — 堆积快照
cluster-list.txt — 集群注册信息
session.json — 运维会话摘要

支持 Cron 定时备份（如 0 2 * * * 每天凌晨 2 点）。

6.2 恢复边界

自动恢复：Topic 元数据（updateTopic）
消费位点：备份保留原文，需使用 mqadmin resetOffset 按组手动恢复
消息体：不在备份范围内

6.3 消息迁移

支持：跨集群 Topic 元数据 在目标 NameServer 创建/更新
不支持：消息体搬迁（请使用 RocketMQ Replicator 或厂商方案）
流程：配置目标 → 预检 → 执行 → 历史记录

七、适用行业与典型客户画像

行业/领域	典型诉求	推荐阶段	工具价值
互联网 / SaaS	订单、通知、异步解耦	二～四	主从/DLedger 保可用，多集群隔离业务域
电商 / 零售	大促流量、消息堆积治理	二、三、四	堆积分析、告警、扩缩容
政企 / 信创	内网隔离、不可上云 MQ	一～四	全链路私有化 SSH 交付
金融 / 支付	账务通知、对账链路	三、四	DLedger HA + 审计留痕
制造 / IoT	设备上报、边缘汇聚	一、二	单机/主从快速落地
ISV / 集成商	客户现场交付	一～四	可视化部署日志、可复现步骤
研发测试	快速起环境	一	单机一键部署

八、与同类方案对比（简表）

维度	手工脚本	云消息服务	RocketMQ Dashboard	小紫 RocketMQ
学习成本	高	低	中	中低（向导）
私有化	✅	❌ 或受限	✅	✅
四阶段一体	❌	部分	❌	✅
部署可追溯	看脚本	云审计	❌	DeployLog 全记录
多集群+Proxy 部署	需自研	控制台	部分	内置向导
告警推送	自研	云监控	弱	多渠道 + 定时巡检
操作审计	无	云审计	无	本地审计日志

九、技术栈与运行环境

项目	说明
客户端	Windows 10/11，Electron 桌面安装包
服务端	推荐 CentOS 7，SSH + systemd
RocketMQ	5.1.4（5.x Proxy 模式）
Java	OpenJDK 8（远程自动检测/安装）
技术栈	Electron · React · TypeScript · Ant Design · ssh2 · ECharts · node-cron

用户数据目录（示例）

%APPDATA%/xianzi-rocketmq/
├── config/          # 部署配置
├── metrics/         # TPS 时序（按集群 key）
├── alerts/          # 告警规则、历史、通知配置
├── backups/rocketmq/# 元数据备份
├── audit/           # 操作审计
└── logs/            # 应用日志

十、能力成熟度说明（诚实边界）

已具备（v1.0）	需外部方案或手动
四阶段部署 + 卸载	消息体跨集群搬迁（Replicator）
全拓扑维护 / 监控 / 巡检	消费位点一键自动恢复
多集群 Slave/Proxy 扩缩容	K8s Operator 式全自动运维
Topic/消费组管理	消息轨迹 Trace 深度分析
堆积分析 / 深度诊断	多用户 RBAC / 云端协同
告警规则 + 推送 + 定时巡检
性能大盘 + Prometheus
元数据备份 + 定时策略 + 审计

十一、一句话总结

小紫 RocketMQ = 私有化场景下的 RocketMQ 全生命周期工作台：从单机装起，到主从扛读、DLedger 扛宕机、多集群+Proxy 扛规模，部署可追踪、运维可登录、告警可推送、操作可审计。

附录：菜单能力速查

菜单	对应能力
部署 · 单机	阶段一
部署 · 主从	阶段二
部署 · DLedger	阶段三
部署 · 多集群	阶段四
运维登录	四种拓扑统一入口
维护 / 监控 / 巡检 / 扩缩容 / 路由规则	多集群运维
RocketMQ 管理	Topic / 消费组
日志管理	远程日志扫描与清理
性能大盘	TPS 趋势（自动采集）
消息堆积	消费组堆积分析
告警中心	规则 + 推送 + Prometheus
深度诊断	一键体检
备份恢复	元数据备份 + 定时策略
消息迁移	Topic 元数据跨集群
操作审计	关键操作留痕

贤紫优选 · 小紫基础设施系列 · v1.0

Releases: 17741421897/xiaozi-rocketmq

Release list

小紫 RocketMQ v1.0.0