产品简介
# 前言
本文档为金蝶Apusic分布式消息队列for RabbitMQ(Apusic Distributed Message Queue,简称:ADMQ for RabbitMQ)的产品介绍,帮助用户快速了解ADMQ for RabbitMQ产品的功能、技术特性及典型应用场景。
# 适用对象
本文档适用于IT信息化业务负责人、研发经理、软件项目经理、软件架构师、运维工程师。
# 相关文档
了解更多 ADMQ for RabbitMQ 产品相关的信息,请参阅以下产品手册文档集:
| 序号 | 手册文档 | 说明 |
|---|---|---|
| 1 | 金蝶Apusic分布式消息队列for RabbitMQ 快速使用手册 | 简单介绍了如何快速上手使用ADMQ for RabbitMQ 。 |
| 2 | 金蝶Apusic分布式消息队列for RabbitMQ 安装手册 | 详细介绍如何在各操作系统上安装ADMQ for RabbitMQ,以及ADMQ for RabbitMQ服务启停等操作。 |
| 3 | 金蝶Apusic分布式消息队列for RabbitMQ 消息引擎用户手册 | 详细介绍 ADMQ for RabbitMQ 消息引擎相关功能的使用、配置、管理及配套工具的使用方法。 |
| 4 | 金蝶Apusic分布式消息队列for RabbitMQ 管控台用户手册 | 详细介绍ADMQ for RabbitMQ管控台相关功能的使用和操作说明。 |
| 5 | 金蝶Apusic分布式消息队列for RabbitMQ 开发手册 | 详细介绍基于各开发语言进行ADMQ for RabbitMQ客户端应用开发的说明。 |
| 6 | 金蝶Apusic分布式消息队列for RabbitMQ 迁移手册 | 详细介绍从RabbitMQ迁移到ADMQ for RabbitMQ的说明。 |
| 7 | 金蝶Apusic分布式消息队列for RabbitMQ 运维手册 | 详细介绍ADMQ for RabbitMQ的监控、运维、安全加固等运维说明。 |
| 8 | 金蝶Apusic分布式消息队列for RabbitMQ 性能优化手册 | 详细介绍ADMQ for RabbitMQ性能调优的说明。 |
# 技术支持
ADMQ for RabbitMQ产品提供全面的技术支持服务,您可以通过以下方式获得技术支持:
- 网址:www.apusic.com
- 电话:400-855-5800
- 邮箱:support@apusic.com
- 金蝶云社区:https://vip.kingdee.com/?productId=73&productLineId=14&lang=zh-CN
您在取得技术支持时,请提供如下信息:
您的姓名
公司信息与联系方式
操作系统及其版本
产品版本号
出现异常及错误的日志、截图等详细信息
# 产品简介
# 产品定位
金蝶Apusic分布式消息队列for RabbitMQ(Apusic Distributed Message Queue,简称:ADMQ for RabbitMQ)是专为RabbitMQ用户打造的信创替代型云原生消息中间件,完全遵循 RabbitMQ 核心架构设计与AMQP协议规范,实现协议、客户端、生态工具、业务场景的全兼容,无需改造即可替换原有 RabbitMQ 集群,满足信创项目落地需求。
# 核心价值
遵循 RabbitMQ 分布式、高可靠、灵活路由的核心特性,同时适配信创软硬件环境,提供更稳定的运行保障、更便捷的运维支持及更全面的安全能力,成为 RabbitMQ 信创替代的优选方案。
# 核心能力
| 核心能力 | 解释 |
|---|---|
| AMQP 协议完全兼容 | 完整实现 AMQP 0-9-1 协议,支持生产消费、队列绑定、消息确认等核心协议,行为与原生 RabbitMQ 一致。 |
| 全版本客户端适配 | 支持 Java、Python、Go、Node.js、.NET 等 RabbitMQ 官方客户端及第三方开源客户端,无代码改造即可接入。 |
| 生态工具无缝复用 | 兼容 RabbitMQ Management Plugin、bin/admq rabbitmq admin ctl、bin/admq rabbitmq admin diagnostics 等原生工具,支持 Shovel、Federation 等数据同步工具。 |
| 信创环境深度适配 | 适配主流信创操作系统(麒麟、统信等)、信创芯片(ARM、RISC-V 等),兼容信创数据库及中间件生态。 |
| RabbitMQ 核心特性继承 | 支持多种交换机类型(Direct、Fanout、Topic、Headers)、多种队列类型(Classic、Quorum、Stream)、消息确认、持久化、优先级队列等原生核心特性。 |
# 产品架构
# 架构概述
ADMQ for RabbitMQ产品采用 RabbitMQ 经典分布式架构,完全遵循 AMQP 协议与消息路由模型。产品整体架构分为管控台、核心引擎和分布式协调三大模块,具备高可靠、高可用、可扩展的特性。
# 管控台(Console)
- 管控台是面向运维人员和管理员的可视化操作界面,提供全生命周期管理能力:
- 集群管理:对消息集群节点进行接入和状态监控。
- 用户权限:基于角色的访问控制(RBAC),保障操作安全。
- Vhost 管理:创建、删除、配置虚拟主机(Vhost),实现资源隔离。
- 交换机管理:创建、删除、配置交换机(Exchange),管理路由规则。
- 队列管理:创建、删除、配置队列(Queue),管理队列属性和绑定关系。
- 消息检索:支持按时间、路由键、内容等条件查询历史消息。
# 核心引擎(Core Engine)
核心引擎是消息处理的核心,兼容 AMQP 协议,保障消息的可靠传输与存储:
AMQP 协议接入 & 安全访问控制
提供标准 AMQP 协议兼容层,支持现有 RabbitMQ 客户端无缝迁移。
集成认证(如 SASL/PLAIN、SCRAM)、授权和传输加密(SSL/TLS),保障访问安全。
消息处理服务
消息生产接入:接收生产者(Producer)发送的消息,进行校验和路由。
消息消费服务:向消费者(Consumer)推送消息,支持手动确认和自动确认。
消息持久化存储:将消息写入磁盘,支持高可靠写入和高效检索,保证数据不丢失。
元数据服务:管理 Vhost、Exchange、Queue、Binding 等元数据信息,确保集群状态一致。
高可用与负载管理
多副本同步:通过 Quorum Queue 和 Stream Queue 的多副本机制保证数据冗余,防止单点故障。
故障恢复与副本迁移:节点故障时自动切换,支持副本在集群内迁移以平衡负载。
负载均衡:将生产和消费请求均匀分配到集群节点,提升整体吞吐量。
状态监控:实时监控节点、队列和连接的健康状态,为故障恢复提供依据。
# 分布式协调(Distributed Coordination)
分布式协调模块(基于金蝶 Apusic 分布式配置中心)负责维护集群的一致性和状态:
集群成员管理:维护集群中所有 Broker 节点的在线 / 离线状态。
元数据持久存储:存储并同步 Vhost、Exchange、Queue、Binding 等核心元数据。
Leader 选举:在集群中选举出 Leader 节点,负责队列管理和故障处理。
队列 Leader 选举:当队列 Leader 节点故障时,自动从 Follower 中选举新的 Leader。
集群状态监听通知:当集群状态(如节点上下线、Leader 变更)发生变化时,向相关组件发送通知,触发相应处理。
# 产品优势
零改造信创替代:无需修改业务代码、无需调整客户端配置(仅需变更连接地址),即可直接替换原有 RabbitMQ 集群,迁移成本趋近于零。
生态完全兼容:RabbitMQ 原生工具、监控系统(Prometheus+Grafana)、数据同步工具等均可直接复用,无需额外适配开发。
信创环境适配:全面兼容信创软硬件生态,满足政企信创项目落地要求,提供端到端的信创解决方案。
特性原汁原味:完全遵循 RabbitMQ 核心特性规范,支持用户熟悉的所有业务场景(如灵活路由、异步处理、削峰填谷等),业务无感知切换。
安全合规增强:在保留 RabbitMQ 原有安全能力基础上,新增安全特性,符合信创项目安全合规标准。
# 应用场景
- 信创项目替代场景:政企信创改造中,直接替换原有 RabbitMQ 集群,无需重构业务系统,快速满足信创落地要求。
- 异步通信解耦场景:基于 RabbitMQ 原生的发布订阅模式,实现分布式系统间异步通信,降低系统耦合度。
- 削峰填谷场景:利用 RabbitMQ 的队列缓冲能力,平滑处理突发流量,保护后端服务稳定运行。
- 可靠消息传输场景:基于消息确认机制和持久化存储,确保关键业务消息不丢失。
- 灵活路由场景:利用 Direct、Fanout、Topic、Headers 等多种交换机类型,满足复杂的消息路由需求。