技術規範
# 前言
本文件為金蝶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
您在取得技術支援時,請提供如下資訊:
您的姓名
公司資訊與聯絡方式
作業系統及其版本
產品版本號
出現異常及錯誤的日誌、截圖等詳細資訊
# 產品版本與相容性
# 版本資訊
| 屬性 | 說明 |
|---|---|
| 產品名稱 | 金蝶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 臺)
- 測試環境可以在一臺伺服器上執行所有元件
- 最小生產環境需要 7 臺伺服器(或虛擬機器)
- 網路:所有節點之間可以相互通訊,並具有穩定的網路連線
- 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)