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

  • 金蝶Apusic负载均衡器

  • 金蝶Apusic分布式消息队列

    • 产品白皮书
    • Product Whitepaper
    • 產品白皮書
    • 产品更新说明
    • 统一管控台

    • V2.0.6(最新)

    • V2.0.6_for_kafka

    • V2.0.6_for_rabbitmq

    • V2.0.6_for_rocketmq

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

      • 繁體中文

        • 產品介紹
        • 技術規範
        • 安裝手冊
        • 快速入門
        • 管控台使用者手冊
        • 核心引擎使用者手冊
        • 開發手冊
        • 遷移手冊
        • 維運手冊
        • 效能調優
    • 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產品相關的資訊,請參閱以下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)
#功能與技術規格

← 產品介紹 安裝手冊→

  • 浅色模式