一 RocketMq核心概念

2022-09-02 01:15:11 字數 1877 閱讀 3770

一、producer

生產者將業務應用程式系統生成的訊息傳送給**。

rocketmq提供多種傳送範例:同步,非同步和單向。

二、producer group

具有相同角色的生產者組合在一起。如果原始生產者在事務之後崩潰,則**可以聯絡同一生產者組的不同生產者例項以提交或回滾事務。

警告:考慮到提供的生產者在傳送訊息方面足夠強大,每個生產者組只允許乙個例項,以避免不必要的生成器例項初始化。

三、consumer

消費者從**那裡獲取訊息並將其提供給應用程式。

從使用者應用的角度來看,提供了兩種型別的消費者:

(1)、pullconsumer

拉動消費者積極地從**那裡獲取訊息。

一旦提取了批量訊息,使用者應用程式就會啟動消費過程。

(2)pushconsumer

另一方面,推送消費者封裝訊息提取,消費進度並維護其他內部工作,為終端使用者留下**介面以實現將在訊息到達時執行。

四、與之前提到的生產者組類似,完全相同角色的消費者被組合在一起並命名為

消費者組

。消費者群體是乙個很好的概念,在訊息消費方面實現負載平衡和容錯目標非常容易。

警告

:使用者組的使用者例項

必須

具有完全相同的主題訂閱。

五、topic

主題是生產者傳遞訊息和消費者提取訊息的類別。

主題與生產者和消費者的關係非常鬆散。

具體來說,乙個主題可能有零個,乙個或多個生成器向它傳送訊息; 

相反,生產者可以傳送不同主題的訊息。

從消費者的角度來看,主題可以由零個,乙個或多個消費者群體訂閱。

類似地,消費者組可以訂閱乙個或多個主題,只要該組的例項保持其訂閱一致即可。

六、message

訊息是要傳遞的資訊。

訊息必須有乙個主題,可以將其解釋為您要傳送給的郵件位址。

訊息還可以具有可選標記和額外的鍵 - 值對。

例如,您可以為訊息設定業務金鑰,並在**伺服器上查詢訊息以診斷開發期間的問題。

七、message queue

主題被劃分為乙個或多個子主題「訊息佇列」。

八、tag

標記,換句話說,子主題,為使用者提供了額外的靈活性。

對於標記,來自同一業務模組的具有不同目的的訊息可以具有相同的主題和不同的標記。

標籤有助於保持**的清晰和連貫,而標籤也可以方便rocketmq提供的查詢系統。

九、broker

broker是rocketmq系統的主要組成部分。

它接收從生產者傳送的訊息,儲存它們並準備處理來自消費者的拉取請求。

它還儲存與訊息相關的元資料,包括消費者組,消耗進度偏移和主題/佇列資訊。

十、name server

name server充當路由資訊提供者。

生產者/消費者客戶查詢主題以查詢相應的broker列表。

十一、message model

(1)、clustering

(2)、broadcasting

十二、message order

使用defaultmqpushconsumer時,您可能決定按順序或同時使用訊息。

按順序使用訊息意味著訊息的使用順序與生產者為每個訊息佇列傳送的順序相同。

如果您正在處理全域性順序是必需的方案,請確保您使用的主題只有乙個訊息佇列。

警告:如果指定了有序消耗,則訊息消耗的最大併發數是消費者組訂閱的訊息佇列數。

在併發使用訊息時,訊息消耗的最大併發性僅受為每個使用者客戶端指定的執行緒池的限制。

警告:此模式不再保證訊息順序。

RocketMq核心概念

rocketmq中的概念包括producer,producer group,brocker,name server,consumer,consumer group,topic,message,message queue,tag,關係如下圖 藍色為主要部分,其餘顏色只用於區分位置關係 以topic為中...

RocketMQ簡介及核心概念說明

阿里巴巴訊息中介軟體起源 於 2001 年的五彩石專案,notify 在這期間應運而生,用於交易核心訊息的流轉 2010 年,b2b 開始大規模使用 activemq 作為訊息核心,隨著阿里業務 的快速發展,急需一款支援順序消 息,擁有海量訊息堆積能力的訊息中介軟體,metaq 1.0 在 2011...

RocketMq 基本概念

官方參考文件 rocketmq主要由 producer broker consumer 三部分組成。rocketmq提供多種傳送方式,同步傳送 非同步傳送 順序傳送 單向傳送。同步和非同步方式均需要broker返回確認資訊,單向傳送不需要。從使用者應用的角度而言提供了兩種消費形式 拉取式消費 推動式...