Skip to content

小紫 RocketMQ v1.0.0

Pre-release
Pre-release

Choose a tag to compare

View all tags
@17741421897 17741421897 released this 05 Jul 20:39
v1.0.0
d4087b4
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

小紫 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

Assets 3
Loading