功能与技术规格

# 前言

本文档为金蝶Apusic分布式消息队列for RocketMQ（Apusic Distributed Message Queue for RocketMQ，简称：ADMQ for RocketMQ）的功能规格说明，帮助用户详细了解ADMQ for RocketMQ的产品功能与技术指标。

# 适用对象

本文档适用于IT信息化业务负责人、研发经理、软件项目经理、软件架构师、运维工程师。

# 相关文档

了解更多ADMQ for RocketMQ产品相关的信息，请参阅以下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分布式消息队列
产品版本 ADMQ for RocketMQ V2.0.6.534
发布日期 2026年6月

# 客户端兼容性

ADMQ for RocketMQ V2.0.6.534 兼容以下RocketMQ客户端版本：（目前下面的协议在5.x版本都支持，在4.x版本跟开源RocketMQ一致，Java为主，其他语言为第三方仓库实现）

客户端类型 支持版本 说明
Java 4.4.x - 5.3.x 官方 Java 客户端
Go 2.x 官方 Go 客户端
Python 2.0.x 官方 Python 客户端
C/C++ 2.0.x - 2.2.x 官方 C++ 客户端
.NET 1.x 社区 .NET 客户端
Node.js 1.x 社区 Node.js 客户端

# 协议兼容性

协议 状态 说明
RocketMQ Remoting 支持 核心消息传输协议
gRPC 支持 RocketMQ 5.x 新协议
HTTP 支持 RESTful API 协议
TCP 支持 底层传输协议
TLS 支持 加密传输
ACL 支持 访问控制协议

# 核心功能特性

# 消息收发

功能 说明 状态
生产者（Producer） 支持同步/异步发送、单向发送、批量发送 支持
消费者（Consumer） 支持推模式、拉模式、批量消费 支持
消息顺序 支持全局顺序和分区顺序 支持
消息持久化 消息持久化到磁盘，支持主从复制 支持
消息重试 支持消费失败重试和定时重试 支持
死信队列 支持超过重试次数的消息进入死信队列 支持
消息轨迹 支持记录消息全链路轨迹 支持

# 主题与队列

功能 说明 状态
Topic 创建/删除 支持手动创建、自动创建 支持
队列管理 支持读写队列数配置 支持
消息过滤 支持 Tag 过滤和 SQL92 过滤 支持
消息查询 支持按 Key、消息 ID、时间查询 支持
消息回溯 支持按时间戳回溯消费 支持
消息清理 支持定时和按容量清理 支持

# 消费者组

功能 说明 状态
消费者组 支持消费者组管理 支持
集群消费 同一消费者组内消息仅消费一次 支持
广播消费 同一消费者组内每条消息都被消费 支持
消费位点 支持按位点消费和按时间消费 支持
消费重试 支持消费失败后的重试机制 支持
消费进度 支持查看消费延迟和积压 支持

# 高级消息特性

功能 说明 状态
顺序消息 支持全局顺序和分区顺序消息 支持
事务消息 支持分布式事务消息（两阶段提交） 支持
定时/延时消息 支持指定时间投递消息 支持
批量消息 支持生产者批量发送消息 支持
消息压缩 支持消息体压缩传输 支持

# 高可用与容错

功能 说明 状态
主从复制 支持同步复制和异步复制 支持
主从切换 支持主从切换 支持
故障恢复 支持自动故障转移 支持
跨机房部署 支持跨机房多活部署 支持

# 安全特性

功能 说明 状态
身份认证 支持 AK/SK 和用户名密码认证 支持
授权管理 支持 ACL 访问控制 支持
传输加密 支持 TLS 加密 支持
角色控制 支持 RBAC 角色管理 支持
多租户 支持命名空间隔离 支持

# 运维管理

功能 说明 状态
监控指标 支持 Prometheus 指标导出 支持
日志管理 支持日志级别配置和日志轮转 支持
配置管理 支持动态配置更新 支持
集群管理 支持 Broker 添加/移除 支持

# 技术规格

# 系统要求

在开始部署之前，请确保您的环境满足以下要求：

  • 操作系统：64 位 Linux（推荐 CentOS 7+、Ubuntu 18.04+，国产Kylin v10+、OpenEuler 22.03+）
  • Java 版本：JDK 8及以上
  • 硬件配置：
    • 最小生产环境需要 7 台服务器（或虚拟机）
      • 3 台运行 Name Server
      • 4 台运行 Broker（Master 和 Slave 各 2 台）
    • 测试环境可以在一台服务器上运行所有组件
  • 网络：所有节点之间可以相互通信，并具有稳定的网络连接
  • DNS：可选，为所有 Broker 节点配置一个共同的 DNS 名称

# 硬件推荐

下表提供了不同规模集群的硬件推荐（每节点）：

组件 小型集群 (250 个主题) 中型集群 (1000 个主题)
Name Server • CPU: 4 核 • 内存: 16GB • 磁盘: 200GB SSD • CPU: 8 核 • 内存: 32GB • 磁盘: 500GB SSD
Broker • CPU: 8 核 • 内存: 32GB • 磁盘: 500GB SSD • CPU: 16 核 • 内存: 64GB • 磁盘: 1TB SSD

硬件选择建议

  • Name Server 只用于元数据存储，可以使用相对较小的服务器
  • Broker 计算需要快速的 CPU 和网络，推荐使用 10Gbps 网络接口；存储需要快速的存储设备，推荐使用 SSD 或带电池缓存的 RAID 控制器

# 性能指标

指标 单节点 3节点集群 说明
吞吐量 6万/秒 10万/秒 生产者发送速率
延迟 2ms 2ms P99 延迟
主从同步 <1s <1s 同步复制延迟
故障恢复 <30s <30s 主从切换时间

# 网络端口

端口 用途 说明
9876 NameServer 服务注册与发现
10911 Broker 生产者和消费者连接
10909 Broker VIP VIP 通道
10912 Broker HA 主从复制端口
12305 管控台 HTTP 管控台 Web 界面（HTTP）
12306 管控台 HTTPS 管控台 Web 界面（HTTPS）

# 支持的存储

类型 支持情况 说明
EXT4 支持 Linux 标准文件系统
XFS 推荐 高性能文件系统
NFS 支持 网络文件系统（需配置）
多盘挂载 支持 支持多数据目录

# 部署模式

部署模式 Broker数量 NameServer数量 说明
单机模式 1 1 适用于开发测试环境，无高可用保障
双主模式 2 2 适用于生产环境，双 Master 互备
多主多从模式 4+ 3+ 适用于生产环境，Master-Slave 架构

# 备份与容灾

# 数据备份

备份方式 说明
主从备份 通过主从复制机制实现数据冗余
定期备份 支持定期导出 CommitLog 和 ConsumeQueue
跨机房备份 支持跨机房主从复制

# 容灾能力

容灾级别 能力
节点故障 自动主从切换，保证服务连续性
磁盘故障 主从复制机制，单盘故障不影响服务
机房级 支持跨机房多活部署
数据安全 支持定期快照备份
编辑页面 (opens new window)
#功能与技术规格

← 安装手册→