rocketmq主要由 producer、broker、consumer 三部分組成,其中producer 負責生產訊息,consumer 負責消費訊息,broker 負責儲存訊息。broker 在實際部署過程中對應一台伺服器,每個 broker 可以儲存多個topic的訊息,每個topic的訊息也可以分片儲存於不同的 broker。message queue 用於儲存訊息的實體地址,每個topic中的訊息位址儲存於多個 message queue 中。consumergroup 由多個consumer 例項構成。
負責生產訊息,一般由業務系統負責生產訊息。乙個訊息生產者會把業務應用系統裡產生的訊息傳送到broker伺服器。rocketmq提供多種傳送方式,同步傳送、非同步傳送、順序傳送、單向傳送。同步和非同步方式均需要broker返回確認資訊,單向傳送不需要。
負責消費訊息,一般是後台系統負責非同步消費。乙個訊息消費者會從broker伺服器拉取訊息、並將其提供給應用程式。從使用者應用的角度而言提供了兩種消費形式:拉取式消費、推動式消費。
表示一類訊息的集合,每個主題包含若干條訊息,每條訊息只能屬於乙個主題,是rocketmq進行訊息訂閱的基本單位。
訊息中轉角色,負責儲存訊息、**訊息。**伺服器在rocketmq系統中負責接收從生產者傳送來的訊息並儲存、同時為消費者的拉取請求作準備。**伺服器也儲存訊息相關的元資料,包括消費者組、消費進度偏移和主題和佇列訊息等。
名稱服務充當路由訊息的提供者。生產者或消費者能夠通過名字服務查詢各主題相應的broker ip列表。多個namesrv例項組成集群,但相互獨立,沒有資訊交換。
consumer消費的一種型別,應用通常主動呼叫consumer的拉訊息方法從broker伺服器拉訊息、主動權由應用控制。一旦獲取了批量訊息,應用就會啟動消費過程。
consumer消費的一種型別,該模式下broker收到資料後會主動推送給消費端,該消費模式一般實時性較高。
同一類producer的集合,這類producer傳送同一類訊息且傳送邏輯一致。如果傳送的是事務訊息且原始生產者在傳送之後崩潰,則broker伺服器會聯絡同一生產者組的其他生產者例項以提交或回溯消費。
同一類consumer的集合,這類consumer通常消費同一類訊息且消費邏輯一致。消費者組使得在訊息消費方面,實現負載均衡和容錯的目標變得非常容易。要注意的是,消費者組的消費者例項必須訂閱完全相同的topic。rocketmq 支援兩種訊息模式:集群消費(clustering)和廣播消費(broadcasting)。
集群消費模式下,相同consumer group的每個consumer例項平均分攤訊息。
廣播消費模式下,相同consumer group的每個consumer例項都接收全量的訊息。
普通順序消費模式下,消費者通過同乙個消費佇列收到的訊息是有順序的,不同訊息佇列收到的訊息則可能是無順序的。
嚴格順序訊息模式下,消費者收到的所有訊息均是有順序的。
訊息系統所傳輸資訊的物理載體,生產和消費資料的最小單位,每條訊息必須屬於乙個主題。rocketmq中每個訊息擁有唯一的message id,且可以攜帶具有業務標識的key。系統提供了通過message id和key查詢訊息的功能。
為訊息設定的標誌,用於同一主題下區分不同型別的訊息。來自同一業務單元的訊息,可以根據不同業務目的在同一主題下設定不同標籤。標籤能夠有效地保持**的清晰度和連貫性,並優化rocketmq提供的查詢系統。消費者可以根據tag實現對不同子主題的不同消費邏輯,實現更好的擴充套件性。
摘自
RocketMq 基本概念
官方參考文件 rocketmq主要由 producer broker consumer 三部分組成。rocketmq提供多種傳送方式,同步傳送 非同步傳送 順序傳送 單向傳送。同步和非同步方式均需要broker返回確認資訊,單向傳送不需要。從使用者應用的角度而言提供了兩種消費形式 拉取式消費 推動式...
基本概念 C 基本概念
由於工作中需要用到c 編寫的一些工具,有時候需要根據需求修改或者定製工具,所以現在不得不學習一下c 的基礎語法,此為筆記,不成章法!機器語言 組合語言 高階語言 面向過程的程式設計方法 物件導向的程式設計方法 泛型程式設計方法 1 演算法設計 2 源程式編輯 3 編譯 4 連線 5 執行除錯 輸入裝...
基本概念 數控系統基本概念
第一章 基本概念 數控工具機cnc是一種按事先編制好的加工零件程式進行加工的高效 自動化加工裝置。是 computer numerical control machine tools 的簡稱。數控工具機較好地解決了複雜 精密 小批量 多品種的零件加工問題,是一種柔性的 高效能的自動化工具機。西門子系...