概念
本節說明 Apache RocketMQ 的核心概念。
主題
主題是 Apache RocketMQ 中用於傳輸和儲存屬於相同業務邏輯的訊息的頂層容器。進一步了解 主題。
訊息類型
由訊息傳輸特性定義的類別,用於類型管理和安全性驗證。Apache RocketMQ 支援 NORMAL、FIFO、TRANSACTION 和 DELAY 訊息類型。
Apache RocketMQ 從 5.0 版本開始支援強制驗證訊息類型,即每個 Topic 只允許傳送單一類型的訊息。這能更利於生產系統的運維管理,避免混亂。但為了保證與 4.x 版本的向下相容性,驗證功能預設是關閉的。
MessageQueue
MessageQueue 是 Apache RocketMQ 中用於儲存和傳輸訊息的容器。MessageQueue 是 Apache RocketMQ 訊息最小的儲存單元。深入了解 MessageQueue。
Message
訊息是 Apache RocketMQ 中資料傳輸最小的單元。生產者將業務資料的載荷和擴充屬性封裝成訊息,並將訊息發送至 Apache RocketMQ broker。接著,broker 會根據相關語意將訊息傳遞給消費者。深入了解 Message。
MessageView
MessageView 是從開發角度來看訊息的唯讀介面。訊息檢視讓你可以讀取訊息內的多個屬性和載荷資訊,但你無法對訊息本身做任何變更。
MessageTag
MessageTag 是細粒度的訊息分類屬性,讓訊息可以在 Topic 層級以下進行細分。消費者透過訂閱特定的標籤來實作訊息過濾。深入了解 MessageFilter。
MessageOffset
訊息會依序儲存在佇列中,每個訊息在佇列中都有唯一的 Long 型態座標,定義為訊息位移。深入了解 Consumer 進度管理。
ConsumerOffset
訊息在被消費者消費後並不會立即從佇列中移除,Apache RocketMQ 會根據每個消費者群組記錄最後一次消費的訊息。深入了解 Consumer 進度管理。
MessageKey
MessageKey 是以訊息為導向的索引屬性。透過設定訊息索引,你可以快速找到對應的訊息內容。
Producer
Apache RocketMQ 中的生產者是一個建立訊息並將訊息傳送至伺服器的功能性訊息實體。生產者通常整合在業務系統中,用於將資料封裝成 Apache RocketMQ 中的訊息,並將訊息傳送至伺服器。深入了解 Producer。
TransactionChecker
Apache RocketMQ 使用事務訊息機制,需要生產者實作事務檢查器,以確保事務的最終一致性。了解更多事務訊息。
ConsumerGroup
消費者群組是負載平衡群組,包含在 Apache RocketMQ 中使用相同消費行為的消費者。了解更多 ConsumerGroup。
Consumer
消費者是接收並處理 Apache RocketMQ 中訊息的實體。消費者通常整合在業務系統中。他們從 Apache RocketMQ 代理程式取得訊息,並將訊息轉換為業務邏輯可以感知和處理的資訊。了解更多 Consumer。
Subscription
訂閱是消費者在 Apache RocketMQ 中取得和處理訊息的規則和狀態設定。訂閱是由消費者群組動態向代理程式註冊。然後根據訂閱定義的篩選規則比對和消費訊息。了解更多 Subscription。