功能与技术规格
# 前言
本文档为金蝶Apusic分布式消息队列for MQTT(Apusic Distributed Message Queue,简称:ADMQ for MQTT)的功能规格说明,帮助用户详细了解ADMQ for MQTT的产品功能与技术指标。
# 适用对象
本文档适用于IT信息化业务负责人、研发经理、软件项目经理、软件架构师、运维工程师。
# 相关文档
了解更多ADMQ for MQTT产品相关的信息,请参阅以下ADMQ for MQTT产品手册文档集:
| 序号 | 手册文档 | 说明 |
|---|---|---|
| 1 | 金蝶Apusic分布式消息队列for MQTT 快速使用手册 | 简单介绍了如何快速上手使用ADMQ for MQTT 。 |
| 2 | 金蝶Apusic分布式消息队列for MQTT 安装手册 | 详细介绍如何在各操作系统上安装ADMQ for MQTT,以及ADMQ for MQTT服务启停等操作。 |
| 3 | 金蝶Apusic分布式消息队列for MQTT 消息引擎用户手册 | 详细介绍 ADMQ for MQTT 消息引擎相关功能的使用、配置、管理及配套工具的使用方法。 |
| 4 | 金蝶Apusic分布式消息队列for MQTT 管控台用户手册 | 详细介绍ADMQ for MQTT管控台相关功能的使用和操作说明。 |
| 5 | 金蝶Apusic分布式消息队列for MQTT 开发手册 | 详细介绍基于各开发语言进行ADMQ for MQTT客户端应用开发的说明。 |
| 6 | 金蝶Apusic分布式消息队列for MQTT 迁移手册 | 详细介绍从MQTT Broker迁移到ADMQ for MQTT的说明。 |
| 7 | 金蝶Apusic分布式消息队列for MQTT 运维手册 | 详细介绍ADMQ for MQTT的监控、运维、安全加固等运维说明。 |
| 8 | 金蝶Apusic分布式消息队列for MQTT 性能优化手册 | 详细介绍ADMQ for MQTT性能调优的说明。 |
# 技术支持
ADMQ for MQTT产品提供全面的技术支持服务,您可以通过以下方式获得技术支持:
- 网址:www.apusic.com
- 电话:400-855-5800
- 邮箱:support@apusic.com
- 金蝶云社区:https://vip.kingdee.com/?productId=73&productLineId=14&lang=zh-CN
您在取得技术支持时,请提供如下信息:
您的姓名
公司信息与联系方式
操作系统及其版本
产品版本号
出现异常及错误的日志、截图等详细信息
# 产品版本与兼容性
# 版本信息
| 属性 | 说明 |
|---|---|
| 产品名称 | 金蝶Apusic分布式消息队列 |
| 产品版本 | ADMQ for MQTT V2.0.6.587 |
| 发布日期 | 2026年3月 |
# 协议兼容性
| 协议 | 状态 | 说明 |
|---|---|---|
| MQTT 3.1 | 支持 | 基础 MQTT 协议 |
| MQTT 3.1.1 | 支持 | 主流 MQTT 协议版本 |
| MQTT 5.0 | 支持 | 最新 MQTT 协议版本,支持更多特性 |
| MQTT over TCP | 支持 | 标准 TCP 接入 |
| MQTT over SSL/TLS | 支持 | 加密 TCP 接入 |
| MQTT over WebSocket | 支持 | Web 端接入 |
| MQTT over WebSocket Secure | 支持 | 加密 WebSocket 接入 |
| MQTT over QUIC | 支持 | 基于 QUIC 的低延迟接入 |
# 客户端兼容性
ADMQ for MQTT V2.0.6.587 兼容以下MQTT客户端:
| 客户端类型 | 支持版本 | 说明 |
|---|---|---|
| Eclipse Paho Java | 1.2.x+ | Java 官方客户端 |
| Eclipse Paho Python | 1.5.x+ | Python 官方客户端 |
| Eclipse Paho C | 1.3.x+ | C 官方客户端 |
| MQTT.js | 4.x+ | Node.js/Browser 客户端 |
| EMQX Client | 5.x+ | EMQX 官方客户端 |
| 其他标准 MQTT 客户端 | - | 任何遵循 MQTT 协议的第三方客户端 |
# 核心功能特性
# MQTT 基础特性
| 功能 | 说明 | 状态 |
|---|---|---|
| 发布/订阅模型 | 支持一对多的消息分发模式 | 支持 |
| QoS 0 | 最多一次消息投递 | 支持 |
| QoS 1 | 至少一次消息投递 | 支持 |
| QoS 2 | 恰好一次消息投递 | 支持 |
| 保留消息 | 为主题保留最后一条消息,新订阅者立即收到 | 支持 |
| 遗嘱消息 | 客户端异常断开时自动发布消息 | 支持 |
| 会话保持 | 保存订阅关系和离线消息 | 支持 |
| Clean Session | 支持清除会话模式 | 支持 |
| MQTT 5.0 新特性 | 消息过期、主题别名、用户属性、共享订阅等 | 支持 |
# 接入方式
| 功能 | 说明 | 状态 |
|---|---|---|
| TCP 接入 | 标准 MQTT TCP 端口 1883 | 支持 |
| SSL/TLS 接入 | 加密 MQTT TCP 端口 8883 | 支持 |
| WebSocket 接入 | 端口 8083 | 支持 |
| WebSocket Secure 接入 | 端口 8084 | 支持 |
| QUIC 接入 | 端口 14567 | 支持 |
# 认证与授权
| 功能 | 说明 | 状态 |
|---|---|---|
| 内置数据库认证 | 用户名密码认证 | 支持 |
| JWT 认证 | 基于 JSON Web Token 认证 | 支持 |
| SCRAM 认证 | 基于 SCRAM 挑战响应机制 | 支持 |
| MySQL/PostgreSQL/HTTP 认证 | 外部数据源认证 | 支持 |
| ACL 访问控制 | 基于用户名/客户端 ID/主题的权限控制 | 支持 |
| 超级用户 | 绕过所有 ACL 检查 | 支持 |
# 高可用与集群
| 功能 | 说明 | 状态 |
|---|---|---|
| 无状态节点集群 | 节点间无状态共享,支持水平扩展 | 支持 |
| 自动故障恢复 | 节点故障时自动剔除并恢复服务 | 支持 |
| 会话持久化 | 支持会话数据持久化 | 支持 |
| 数据备份与恢复 | 支持集群配置和数据的备份恢复 | 支持 |
# 扩展能力
| 功能 | 说明 | 状态 |
|---|---|---|
| 规则引擎 | 基于 SQL 的消息处理规则 | 支持 |
| 数据桥接 | 与数据库、消息队列、HTTP 服务等集成 | 支持 |
| 主题重写 | 自动将源主题替换为目标主题 | 支持 |
| 自动订阅 | 客户端连接后自动订阅指定主题 | 支持 |
| 共享订阅 | MQTT 5.0 共享订阅,负载均衡分发 | 支持 |
# 安全特性
| 功能 | 说明 | 状态 |
|---|---|---|
| TLS/SSL 加密 | 支持传输层加密 | 支持 |
| 国密 SSL | 支持国密算法加密传输 | 支持 |
| 黑白名单 | 支持客户端 ID、用户名、IP 维度封禁 | 支持 |
| 审计日志 | 记录关键操作日志 | 支持 |
| RBAC 角色管理 | 支持基于角色的访问控制 | 支持 |
# 运维管理
| 功能 | 说明 | 状态 |
|---|---|---|
| Prometheus 指标 | 支持 Prometheus 指标导出 | 支持 |
| Grafana 仪表盘 | 支持可视化监控 | 支持 |
| 日志管理 | 支持日志级别配置和日志轮转 | 支持 |
| 告警管理 | 支持系统告警查看和清除 | 支持 |
| 慢订阅检测 | 检测消息投递耗时较长的订阅 | 支持 |
| 日志追踪 | 支持客户端/主题/IP 级别的日志追踪 | 支持 |
# 技术规格
# 系统要求
| 组件 | 最低要求 | 推荐配置 |
|---|---|---|
| CPU | 4 核 | 8 核及以上 |
| 内存 | 8 GB | 16 GB 及以上 |
| 磁盘 | 100 GB SSD | 500 GB 及以上 SSD |
| 网络 | 1 Gbps | 10 Gbps |
| 操作系统 | Linux (CentOS 7+, Ubuntu 18.04+, 麒麟, 统信) | - |
# 集群规模
| 部署模式 | 节点数量 | 说明 |
|---|---|---|
| 单机 | 1 | 开发测试环境 |
| 集群 | 3-5 | 生产环境最小配置 |
| 大规模 | 5+ | 海量设备接入场景 |
# 性能指标
| 指标 | 单节点 | 3节点集群 | 说明 |
|---|---|---|---|
| 并发连接 | 50万 | 100万+ | MQTT 客户端并发连接数 |
| 消息吞吐 | 10万/秒 | 30万/秒 | 消息收发速率 |
| 延迟 | 1ms | 1ms | P99 消息投递延迟 |
| 故障恢复 | <30s | <30s | 节点故障切换时间 |
# 网络端口
| 端口 | 用途 | 说明 |
|---|---|---|
| 1883 | MQTT TCP | 标准 MQTT 接入 |
| 8883 | MQTT over SSL | 加密 MQTT 接入 |
| 8083 | MQTT over WebSocket | WebSocket 接入 |
| 8084 | MQTT over WSS | 加密 WebSocket 接入 |
| 14567 | MQTT over QUIC | QUIC 协议接入 |
| 18083 | Dashboard HTTP | 管理后台 Web 界面 |
| 12305 | 管控台 HTTP | 管控台 Web 界面(HTTP) |
| 12306 | 管控台 HTTPS | 管控台 Web 界面(HTTPS) |
| 4370 | Erlang Distribution | 集群节点间通信 |
| 5370 | Erlang Distribution | 集群节点间通信(SSL) |
# 支持的存储
| 类型 | 支持情况 | 说明 |
|---|---|---|
| EXT4 | 支持 | Linux 标准文件系统 |
| XFS | 推荐 | 高性能文件系统 |
| NFS | 支持 | 网络文件系统(需配置) |
| 多盘挂载 | 支持 | 支持多数据目录 |
# 部署模式
| 部署模式 | 节点数量 | 说明 |
|---|---|---|
| 单机模式 | 1 | 适用于开发测试环境,无高可用保障 |
| 集群模式 | 3-10+ | 适用于生产环境,支持高可用保障和横向扩展 |
| 多集群模式 | 多个集群 | 适用于跨地域、多数据中心部署 |
# 备份与容灾
# 数据备份
| 备份方式 | 说明 |
|---|---|
| 配置备份 | 备份集群配置信息 |
| 数据备份 | 备份用户数据、ACL 规则、保留消息等 |
| 跨集群复制 | 通过数据桥接实现跨集群消息同步 |
# 容灾能力
| 容灾级别 | 能力 |
|---|---|
| 节点故障 | 自动故障转移,保证服务连续性 |
| 磁盘故障 | 多节点部署,单盘故障不影响服务 |
| 机房级 | 支持跨机房多活部署 |
| 数据安全 | 支持定期备份和恢复 |
编辑页面 (opens new window)