Apusic文档中心
首页
  • 应用服务器 AAS
  • 负载均衡器 ALB
  • 分布式消息队列 ADMQ
  • 分布式缓存 AMDC
  • 分布式配置中心 ADCC
  • Java开发工具包软件 AJDK
  • 搜索引擎 ASE
  • 中间件云平台 ACP
  • 统一管理平台 AUMP
  • 云原生中间件管理 ACMP
  • DevOps平台 ADOP
  • 许可授权中心 ACLS
  • Copilot智能问答系统 ACS
  • 监控平台 AMP
  • 智能日志 AILP
  • 应用性能管理 AAPM
  • 智能告警 AAlarm
  • 主数据管理 AMDM
  • 数据交换平台 ADXP
  • 企业服务总线 AESB
  • 数据智脑 ADPR
  • 服务治理 ASGP
  • 统一身份管理 AIDM
  • 标准模板
  • Markdown教程 (opens new window)
  • VuePress官方社区 (opens new window)
  • 帮助
贡献文档 (opens new window)
首页
  • 应用服务器 AAS
  • 负载均衡器 ALB
  • 分布式消息队列 ADMQ
  • 分布式缓存 AMDC
  • 分布式配置中心 ADCC
  • Java开发工具包软件 AJDK
  • 搜索引擎 ASE
  • 中间件云平台 ACP
  • 统一管理平台 AUMP
  • 云原生中间件管理 ACMP
  • DevOps平台 ADOP
  • 许可授权中心 ACLS
  • Copilot智能问答系统 ACS
  • 监控平台 AMP
  • 智能日志 AILP
  • 应用性能管理 AAPM
  • 智能告警 AAlarm
  • 主数据管理 AMDM
  • 数据交换平台 ADXP
  • 企业服务总线 AESB
  • 数据智脑 ADPR
  • 服务治理 ASGP
  • 统一身份管理 AIDM
  • 标准模板
  • Markdown教程 (opens new window)
  • VuePress官方社区 (opens new window)
  • 帮助
贡献文档 (opens new window)
文档中心
  • 金蝶Apusic应用服务器

  • 金蝶Apusic负载均衡器

  • 金蝶Apusic分布式消息队列

    • 产品白皮书
    • 产品更新说明
    • 统一管控台

    • V2.0.6(最新)

    • V2.0.6_for_kafka

    • V2.0.6_for_rabbitmq

    • V2.0.6_for_rocketmq

      • 产品简介
      • 功能与技术规格
      • 安装手册
      • 快速使用手册
      • 管控台用户手册
      • 消息引擎用户手册
      • 开发手册
      • 迁移手册
      • 运维手册
      • 性能优化手册
    • V2.0.6_for_MQTT

    • V2.0.5

    • V2.0.4

    • V2.0.3

  • 金蝶Apusic分布式缓存

  • 金蝶Apusic分布式配置中心

  • 金蝶Apusic Java开发工具包软件

  • 金蝶Apusic全文检索

产品简介

# 前言

本文档为金蝶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

您在取得技术支持时,请提供如下信息:

  1. 您的姓名

  2. 公司信息与联系方式

  3. 操作系统及其版本

  4. 产品版本号

  5. 出现异常及错误的日志、截图等详细信息

# 产品简介

# 产品定位

金蝶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 原生的发布订阅模式,实现分布式系统间异步通信,降低系统耦合度。
编辑页面 (opens new window)
#产品简介

← 极简运维手册 功能与技术规格→

  • 浅色模式