RocketMq核心概念

2022-07-05 02:21:07 字數 1777 閱讀 3444

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

以topic為中心各個概念關係直接採用官網圖:(其中subtopics==message queue)

producer:生產者,代表產生訊息的一方。將業務應用程式系統生成的訊息傳送給brocker儲存。rocketmq提供了多種傳送方式,包括同步,非同步和單向。同步和非同步傳送均需要brocker返回確認資訊,單向傳送不需要。

producer group:同一類producer的集合,這類producer傳送同一類訊息且傳送邏輯一致。如果傳送的是事務訊息且原始生產者在傳送之後崩潰,則broker伺服器會聯絡同一生產者組的其他生產者例項以提交或回溯消費。

consumer:消費者,代表消費訊息的一方。從borcker獲取訊息並輸入應用程式中。從使用者應用的角度,提供了兩種型別的消費者,pullconsumer和pushconsumer

pullconsumer:pullconsumer主動從brocker獲取訊息,一旦一批訊息被拉去,使用者應用程式將啟動消費過程。

pushconsumer:push consumer將訊息拉取、消費進度和維護其他工作封裝在內部,給終端使用者留下乙個**介面,在訊息到達時執行。push模式只是對pull模式的一種封裝,其本質實現為訊息拉取執行緒在從伺服器拉取到一批訊息後,然後提交到訊息消費執行緒池後,又「馬不停蹄」的繼續向伺服器再次嘗試拉取訊息。

consumer group:同一類consumer的集合,這類consumer通常消費同一類訊息且消費邏輯一致。消費者組使得在訊息消費方面,實現負載均衡和容錯的目標變得非常容易。要注意的是,消費者組的消費者例項必須訂閱完全相同的topic。rocketmq 支援兩種訊息模式:集群消費(clustering)和廣播消費(broadcasting)。

集群消費:相同consumer group的consumer例項平均分攤訊息

廣播消費:相同consumer group的consumer例項全量接收訊息

name server:充當路由資訊提供程式。

topic:表示一類訊息的集合,每個主題包含若干條message,每條message只能屬於乙個主題,是rocketmq進行訊息訂閱的基本單位。topic與producer和consumer的關係非常鬆散。具體來說,乙個topic可以有零個、乙個或多個向其傳送message的producer;相反,生產者可以傳送不同topic的message。從consumer的角度來看,乙個topic可以由零個、乙個或多個consumer group訂閱。類似地,consumer group可以訂閱乙個或多個主題,只要該組的例項保持其訂閱一致。

message:訊息系統所傳輸資訊的物理載體,生產和消費資料的最小單位,每條訊息必須屬於乙個主題。rocketmq中每個訊息擁有唯一的message id,且可以攜帶具有業務標識的key。系統提供了通過message id和key查詢訊息的功能。

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

tag:使用標記,來自同一業務模組的不同目的的訊息可能具有相同的主題和不同的標記。標記將有助於保持**的整潔和一致性,而且標記還可以方便rocketmq提供的查詢系統。

一 RocketMq核心概念

一 producer 生產者將業務應用程式系統生成的訊息傳送給 rocketmq提供多種傳送範例 同步,非同步和單向。二 producer group 具有相同角色的生產者組合在一起。如果原始生產者在事務之後崩潰,則 可以聯絡同一生產者組的不同生產者例項以提交或回滾事務。警告 考慮到提供的生產者在傳...

RocketMQ簡介及核心概念說明

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

RocketMq 基本概念

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