技術規範
# 前言
本文檔為金蝶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)