產品介紹
# 前言
本文件為金蝶Apusic分散式訊息佇列for RocketMQ(Apusic Distributed Message Queue for RocketMQ,簡稱:ADMQ for RocketMQ)的產品介紹,幫助使用者快速了解ADMQ for RocketMQ產品的功能、技術特性及典型應用場景。
# 適用對象
本文件適用於IT資訊化業務負責人、研發經理、軟體專案經理、軟體架構師、運維工程師。
# 相關文件
了解更多 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分散式訊息佇列for RocketMQ(Apusic Distributed Message Queue,簡稱:ADMQ for RocketMQ)是專為RocketMQ使用者打造的信創替代型雲原生訊息中介軟體,完全遵循 RocketMQ 核心架構設計與協定規範,實現協定、客戶端、生態工具、業務場景的全相容,無需改造即可替換原有 RocketMQ 叢集,滿足信創專案落地需求。
# 核心價值
遵循 RocketMQ 分散式、高可靠、低延遲、支援豐富訊息型別的核心特性,同時適配信創軟硬體環境,提供更穩定的執行保障、更便捷的運維支援及更全面的安全能力,成為 RocketMQ 信創替代的優選方案。
# 核心能力
| 核心能力 | 解釋 |
|---|---|
| RocketMQ 協定完全相容 | 完整實現 RocketMQ 生產消費協定、NameServer 路由協定、訊息儲存協定等核心協定,行為與原生 RocketMQ 一致。 |
| 全版本客戶端適配 | 支援 Java、Go、Python、C++ 等 RocketMQ 官方客戶端(4.x-5.x 版本)及第三方開源客戶端,無需程式碼改造即可接入。 |
| 生態工具無縫複用 | 相容 mqadmin、RocketMQ Console 等原生工具,支援訊息軌跡、監控告警等生態能力。 |
| 信創環境深度適配 | 適配主流信創作業系統(麒麟、統信等)、信創晶片(ARM、RISC-V 等),相容信創資料庫及中介軟體生態。 |
| RocketMQ 核心特性繼承 | 支援順序訊息、事務訊息、定時/延遲訊息、廣播消費、訊息軌跡、訊息過濾等 RocketMQ 原生核心特性。 |
# 產品架構
# 架構概述
ADMQ for RocketMQ產品採用 RocketMQ 經典分散式架構,完全遵循 RocketMQ 通訊協定與儲存模型。產品整體架構分為管控台、核心引擎等模組,具備高可靠、高可用、可擴充套件的特性。
# 管控台(Console)
- 管控台是面向運維人員和管理員的視覺化操作介面,提供全生命週期管理能力:
- 叢集管理:對訊息叢集節點進行接入和狀態監控。
- 命名空間管理:建立、刪除、配置命名空間。
- Topic 管理:建立、刪除、配置訊息主題(Topic),管理讀寫佇列數。
- 訂閱組管理:管理訂閱組(Consumer Group)、訂閱關係和消費位點。
- 訊息查詢:支援按 Topic、時間、Key、訊息 ID 等條件查詢歷史訊息。
- 死信佇列:支援檢視叢集的死信佇列中的死信訊息,支援重新傳送。
- 叢集通道:支援建立跨叢集之間的通道,支援訊息的複製接收。
- 元資料匯入:支援其他叢集的元資料資訊的匯入。
# 核心引擎(Core Engine)
核心引擎是訊息處理的核心,相容 RocketMQ 協定,保障訊息的可靠傳輸與儲存:
RocketMQ 協定接入 & 安全存取控制
提供標準 RocketMQ 協定相容層,支援現有 RocketMQ 客戶端無縫遷移。
整合認證(如 ACL)、授權和傳輸加密(TLS),保障存取安全。
訊息處理服務
訊息生產接入:接收生產者(Producer)傳送的訊息,進行校驗和路由。
訊息消費服務:向消費者(Consumer)推送訊息,支援叢集消費和廣播消費。
訊息持久化儲存:將訊息寫入磁碟,支援高吞吐寫入和高效檢索,保證資料不丟失。
元資料服務:管理 Topic、佇列、消費者組等元資料資訊,確保叢集狀態一致。
高可用與負載管理
主從複製:透過主從同步機制(同步/非同步複製)保證資料冗餘,防止單點故障。
故障恢復與佇列遷移:Broker 故障時監控自動恢復,支援佇列在叢集內遷移以平衡負載。
負載均衡:將生產和消費請求均勻分配到叢集節點,提升整體吞吐量。
狀態監控:即時監控 Broker、Topic 和消費者的健康狀態,為故障恢復提供依據。
# 產品優勢
零改造信創替代:無需修改業務程式碼、無需調整客戶端配置(僅需變更連線地址),即可直接替換原有 RocketMQ 叢集,遷移成本趨近於零。
生態完全相容:RocketMQ 原生工具、監控系統(Prometheus+Grafana)、訊息軌跡等均可直接複用,無需額外適配開發。
信創環境適配:全面相容信創軟硬體生態,滿足政企信創專案落地要求,提供端到端的信創解決方案。
特性完全適配:完全遵循 RocketMQ 核心特性規範,支援使用者熟悉的所有業務場景(如順序訊息、事務訊息、定時訊息等),業務無感知切換。
安全合規增強:在保留 RocketMQ 原有安全能力基礎上,新增安全特性,符合信創專案安全合規標準。
# 應用場景
- 信創專案替代場景:政企信創改造中,直接替換原有 RocketMQ 叢集,無需重構業務系統,快速滿足信創落地要求。
- 高可靠訊息傳輸場景:如金融交易、訂單處理等,利用 RocketMQ 的事務訊息和順序訊息特性,確保訊息不丟失、按序處理。
- 定時/延時訊息場景:支援指定時間投遞訊息,適用於超時通知、定時任務等場景。
- 分散式系統解耦場景:基於 RocketMQ 原生的釋出訂閱模式,實現分散式系統間非同步通訊,降低系統耦合度。