产品简介
# 前言
本文档为金蝶Apusic分布式消息队列for RocketMQ(Apusic Distributed Message Queue for RocketMQ,简称:ADMQ for RocketMQ)的产品介绍,帮助用户快速了解ADMQ for RocketMQ产品的功能、技术特性及典型应用场景。
# 适用对象
本文档适用于IT信息化业务负责人、研发经理、软件项目经理、软件架构师、运维工程师。
# 相关文档
了解更多 ADMQ for RocketMQ 产品相关的信息,请参阅以下产品手册文档集:
| 序号 | 手册文档 | 说明 |
|---|---|---|
| 1 | 金蝶Apusic分布式消息队列for RocketMQ 快速使用手册 | 简单介绍了如何快速上手使用ADMQ for RocketMQ 。 |
| 2 | 金蝶Apusic分布式消息队列for RocketMQ 安装手册 | 详细介绍如何在各操作系统上安装ADMQ for RocketMQ,以及ADMQ for RocketMQ服务启停等操作。 |
| 3 | 金蝶Apusic分布式消息队列for RocketMQ 消息引擎用户手册 | 详细介绍 ADMQ for RocketMQ 消息引擎相关功能的使用、配置、管理及配套工具的使用方法。 |
| 4 | 金蝶Apusic分布式消息队列for RocketMQ 管控台用户手册 | 详细介绍ADMQ for RocketMQ管控台相关功能的使用和操作说明。 |
| 5 | 金蝶Apusic分布式消息队列for RocketMQ 开发手册 | 详细介绍基于各开发语言进行ADMQ for RocketMQ客户端应用开发的说明。 |
| 6 | 金蝶Apusic分布式消息队列for RocketMQ 迁移手册 | 详细介绍从RocketMQ迁移到ADMQ for RocketMQ的说明。 |
| 7 | 金蝶Apusic分布式消息队列for RocketMQ 运维手册 | 详细介绍ADMQ for RocketMQ的监控、运维、安全加固等运维说明。 |
| 8 | 金蝶Apusic分布式消息队列for RocketMQ 性能优化手册 | 详细介绍ADMQ for RocketMQ性能调优的说明。 |
# 技术支持
ADMQ for RocketMQ产品提供全面的技术支持服务,您可以通过以下方式获得技术支持:
- 网址:www.apusic.com
- 电话:400-855-5800
- 邮箱:support@apusic.com
- 金蝶云社区:https://vip.kingdee.com/?productId=73&productLineId=14&lang=zh-CN
您在取得技术支持时,请提供如下信息:
您的姓名
公司信息与联系方式
操作系统及其版本
产品版本号
出现异常及错误的日志、截图等详细信息
# 产品简介
# 产品定位
金蝶Apusic分布式消息队列for RocketMQ(Apusic Distributed Message Queue,简称:ADMQ for RocketMQ)是专为RocketMQ用户打造的信创替代型云原生消息中间件,完全遵循 RocketMQ 核心架构设计与协议规范,实现协议、客户端、生态工具、业务场景的全兼容,无需改造即可替换原有 RocketMQ 集群,满足信创项目落地需求。
# 核心价值
遵循 RocketMQ 分布式、高可靠、低延迟、支持丰富消息类型的核心特性,同时适配信创软硬件环境,提供更稳定的运行保障、更便捷的运维支持及更全面的安全能力,成为 RocketMQ 信创替代的优选方案。
# 核心能力
| 核心能力 | 解释 |
|---|---|
| RocketMQ 协议完全兼容 | 完整实现 RocketMQ 生产消费协议、NameServer 路由协议、消息存储协议等核心协议,行为与原生 RocketMQ 一致。 |
| 全版本客户端适配 | 支持 Java、Go、Python、C++ 等 RocketMQ 官方客户端(4.x-5.x 版本)及第三方开源客户端,无代码改造即可接入。 |
| 生态工具无缝复用 | 兼容 mqadmin、RocketMQ Console 等原生工具,支持消息轨迹、监控告警等生态能力。 |
| 信创环境深度适配 | 适配主流信创操作系统(麒麟、统信等)、信创芯片(ARM、RISC-V 等),兼容信创数据库及中间件生态。 |
| RocketMQ 核心特性继承 | 支持顺序消息、事务消息、定时/延时消息、广播消费、消息轨迹、消息过滤等 RocketMQ 原生核心特性。 |
# 产品架构
# 架构概述
ADMQ for RocketMQ产品采用 RocketMQ 经典分布式架构,完全遵循 RocketMQ 通信协议与存储模型。产品整体架构分为管控台、核心引擎等模块,具备高可靠、高可用、可扩展的特性。
# 管控台(Console)
- 管控台是面向运维人员和管理员的可视化操作界面,提供全生命周期管理能力:
- 集群管理:对消息集群节点进行接入和状态监控。
- 命名空间管理:管理:创建、删除、配置命名空间。
- Topic 管理:创建、删除、配置消息主题(Topic),管理读写队列数。
- 订阅组管理:管理订阅组组(Consumer Group)、订阅关系和消费位点。
- 消息查询:支持按 Topic、时间、Key、消息 ID 等条件查询历史消息。
- 死信队列:支持查看集群的死信队列中的死信消息,支持重新发送。
- 集群通道:支持建立跨集群之间的通道,支持消息的复制接收。
- 元数据导入:支持其他集群的元数据信息的导入。
# 核心引擎(Core Engine)
核心引擎是消息处理的核心,兼容 RocketMQ 协议,保障消息的可靠传输与存储:
RocketMQ 协议接入 & 安全访问控制
提供标准 RocketMQ 协议兼容层,支持现有 RocketMQ 客户端无缝迁移。
集成认证(如 ACL)、授权和传输加密(TLS),保障访问安全。
消息处理服务
消息生产接入:接收生产者(Producer)发送的消息,进行校验和路由。
消息消费服务:向消费者(Consumer)推送消息,支持集群消费和广播消费。
消息持久化存储:将消息写入磁盘,支持高吞吐写入和高效检索,保证数据不丢失。
元数据服务:管理 Topic、队列、消费者组等元数据信息,确保集群状态一致。
高可用与负载管理
主从复制:通过主从同步机制(同步/异步复制)保证数据冗余,防止单点故障。
故障恢复与队列迁移:Broker 故障时监控自动恢复,支持队列在集群内迁移以平衡负载。
负载均衡:将生产和消费请求均匀分配到集群节点,提升整体吞吐量。
状态监控:实时监控 Broker、Topic 和消费者的健康状态,为故障恢复提供依据。
# 产品优势
零改造信创替代:无需修改业务代码、无需调整客户端配置(仅需变更连接地址),即可直接替换原有 RocketMQ 集群,迁移成本趋近于零。
生态完全兼容:RocketMQ 原生工具、监控系统(Prometheus+Grafana)、消息轨迹等均可直接复用,无需额外适配开发。
信创环境适配:全面兼容信创软硬件生态,满足政企信创项目落地要求,提供端到端的信创解决方案。
特性完全适配:完全遵循 RocketMQ 核心特性规范,支持用户熟悉的所有业务场景(如顺序消息、事务消息、定时消息等),业务无感知切换。
安全合规增强:在保留 RocketMQ 原有安全能力基础上,新增安全特性,符合信创项目安全合规标准。
# 应用场景
- 信创项目替代场景:政企信创改造中,直接替换原有 RocketMQ 集群,无需重构业务系统,快速满足信创落地要求。
- 高可靠消息传输场景:如金融交易、订单处理等,利用 RocketMQ 的事务消息和顺序消息特性,确保消息不丢失、按序处理。
- 定时/延时消息场景:支持指定时间投递消息,适用于超时通知、定时任务等场景。
- 分布式系统解耦场景:基于 RocketMQ 原生的发布订阅模式,实现分布式系统间异步通信,降低系统耦合度。