目錄

創(chuàng)新互聯(lián)服務(wù)緊隨時代發(fā)展步伐，進行技術(shù)革新和技術(shù)進步，經(jīng)過10年的發(fā)展和積累，已經(jīng)匯集了一批資深網(wǎng)站策劃師、設(shè)計師、專業(yè)的網(wǎng)站實施團隊以及高素質(zhì)售后服務(wù)人員，并且完全形成了一套成熟的業(yè)務(wù)流程，能夠完全依照客戶要求對網(wǎng)站進行做網(wǎng)站、網(wǎng)站設(shè)計、建設(shè)、維護、更新和改版，實現(xiàn)客戶網(wǎng)站對外宣傳展示的首要目的，并為客戶企業(yè)品牌互聯(lián)網(wǎng)化提供全面的解決方案。

序

概念簡述

一、客戶端概念

1. Topic-主題

2.ConsumerGroup（消費者組）

概念一覽圖

二、消息傳輸模型

三、實踐應(yīng)用

1.配置文件

2.生產(chǎn)者

3.消費者

配置一覽圖

最后的話?

---

序

接上一篇對rabbitMQ隊列進行了梳理?《一文搞懂rabbitMQ消息隊列概述》。

本篇對另一種消息隊列rocketMQ進行概述理解。

注：本文依據(jù)當前最新版本5.x為基礎(chǔ)展開

概念簡述

分為三個方面進行分析理解：

• 客戶端概念
• 消息傳輸模型
• 實踐應(yīng)用

一、客戶端概念 1. Topic-主題

主題是RocketMQ消息傳輸和存儲的頂層容器，標識同一類業(yè)務(wù)消息邏輯數(shù)據(jù)。只是一個邏輯容器，并不是實際的消息容器。

messageType(消息類型)：控制臺創(chuàng)建主題時，需要設(shè)置一種消息類型，后續(xù)向該主題傳輸消息，該主題只會接收對應(yīng)的消息類型，不匹配的則會直接拒絕接收。

• Normal(普通消息)：沒有特殊語義，消息自己沒有任何關(guān)聯(lián)
• FIFO（順序消息）：MQ通過消息分組messageGroup標記一組特定消息的先后順序，可以保證消息的投遞順序可以嚴格按照消息的發(fā)送順序進行投遞。
• Delay（定時/延時消息）：通過設(shè)置延時時間控制消息生產(chǎn)后不立即投遞，而是等延時間隔時間后對消費者可見。
• Transaction（事務(wù)消息）：rocketMQ支持分布式事務(wù)，支持應(yīng)用數(shù)據(jù)庫消息和消息回調(diào)事務(wù)一致性保障。

queue（隊列）：控制臺創(chuàng)建主題時，需要設(shè)置主題的隊列數(shù)量，不用單獨創(chuàng)建隊列，MQ服務(wù)器會自動創(chuàng)建。拋開不同服務(wù)商的實現(xiàn)，對于隊列本身來說，單個queue 具有自然順序性；

注1：對于RocketMQ的隊列，還具備一個獨一無二的的特性，流式操作語義：隊列的存儲模型可確保消息從任意位點（offset）讀取任意數(shù)量的消息，以此實現(xiàn)類似聚合讀取、回溯讀取等特性??????。

2.ConsumerGroup（消費者組）

概念：是Apache RocketMQ中存在多個消費行為一直的消費者負載均衡分組。

投遞順序性：控制臺創(chuàng)建消費者分組時，需要設(shè)置一種消費者投遞的順序。

• 順序投遞：消費順序和發(fā)送順序完全一致。
• 并發(fā)投遞：并發(fā)消費，盡可能按時間順序處理。

??注2：按消費者是否設(shè)置消費者組，對于投遞順序性有不同的特性，詳細可參考RocketMQ官網(wǎng)消費者組詳解

消費重試策略：控制臺創(chuàng)建消費者分組時設(shè)置。保證消費者消費消息異?；蚴『蟪鋈サ闹卦嚥呗?。

• 重試次數(shù)
• 死信隊列設(shè)置
• 重試時間間隔
• ...

? 注3：根據(jù)消費者類型不同，重試觸發(fā)時機存在差異

? （1）PushConsumer：異常時返回失敗狀態(tài)碼，立即重試? ? ?

（2）SimpleConsumer：靜默等待超時，服務(wù)器自動重試

注4：建議通過減少重試次數(shù)+延長重試間隔來降低系統(tǒng)壓力，避免出現(xiàn)無限重試或大量重試的情況。

在控制臺中 topic主題 與 consumerGroup消費者組 沒有直接的關(guān)聯(lián)

概念一覽圖

二、消息傳輸模型

MQ的消息傳輸模型大致分為兩類：點對點消息模型、發(fā)布/訂閱消息模型

Apache RocketMQ只支持一種消息模型：發(fā)布/訂閱消息模型

注5：Apache RabbitMQ兩種消息傳輸模型都支持

三、實踐應(yīng)用 1.配置文件

• nameServer:服務(wù)器地址(控制臺獲取)
• AccessKey（控制臺獲取）
• SecretKey（控制臺）
• producer groupId(客戶端自定義設(shè)置)

2.生產(chǎn)者

• topic:主題（控制臺獲?。?/li>
• messageKey：消息唯一索引鍵（客戶端自定義設(shè)置）
• messageBody:消息內(nèi)容體（客戶端自定義設(shè)置）
• messageTag:消息過濾標簽（客戶端自定義設(shè)置）

3.消費者

• topic：主題（控制臺獲?。?/li>
• consumerGroup：消費者組（控制臺獲?。?/li>
• messageTag:消息過濾標簽（客戶端自定義設(shè)置，與生產(chǎn)者過濾標簽對應(yīng)）

消費者訂閱關(guān)系

上面說到控制臺topic與consumerGroup沒有直接的關(guān)聯(lián)，其實是在客戶端通過消費者產(chǎn)生的聯(lián)系。

項目中集成RocketMQ可參考：?springboot 整合 騰訊云RocketMq版消息隊列服務(wù)

配置一覽圖

---

最后的話?

至此rocketMQ的基本概念大致清楚了，但是想要生產(chǎn)運用不僅僅止步于表面，自己更需要去深耕框架底層的邏輯實現(xiàn)，才能真正掌握并達到事半功倍的效果。

行動起來

你是否還在尋找穩(wěn)定的海外服務(wù)器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調(diào)度確保服務(wù)器高可用性，企業(yè)級服務(wù)器適合批量采購，新人活動首月15元起，快前往官網(wǎng)查看詳情吧

網(wǎng)站名稱：《云原生》一文搞懂RocketMQ隊列概述-創(chuàng)新互聯(lián)
本文網(wǎng)址：http://weahome.cn/article/djppie.html