@
目錄- ？RocketMQ 是什么
- RocketMQ主體
- 生產者Producer
- 消費者Consumer
- 訊息Message
- Topic
- Tag
- 統籌者
- 注冊中心 Name Server
- 經紀人 Broker
- RocketMQ 架構
- RocketMQ 部署模式
MQ筆記
MQ之主流MQkafaka+RocketMQ+RabbitMQ對比：https://blog.csdn.net/weixin_42526326/article/details/121604583
MQ之RocketMQ常見錯誤：https://blog.csdn.net/weixin_42526326/article/details/121578747
MQ之RocketMQ專業術語：https://blog.csdn.net/weixin_42526326/article/details/121578780
MQ之RocketMQ環境詳細配置：https://blog.csdn.net/weixin_42526326/article/details/121522113
？RocketMQ 是什么
RocketMQ是阿里巴巴在2012年開源的分布式訊息中間件，目前已經捐贈給Apache基金會，并于2016年11月成為 Apache 范訓專案，
中間件是一類連接軟體組件和應用的計算機軟體，它包括一組服務，以便于運行在一臺或多臺機器上的多個軟體通過網路進行互動，中間件技術所提供的互操作性，推動了分布式體系架構的演進，該架構通常用于支持并簡化那些復雜的分布式應用程式，它包括web服務器、事務監控器和訊息佇列軟體，中間件(middleware)是基礎軟體的一大類，屬于可復用軟體的范疇，顧名思義，中間件處于作業系統軟體與用戶的應用軟體的中間，中間件在作業系統、網路和資料庫之上，應用軟體的下層，總的作用是為處于自己上層的應用軟體提供運行與開發的環境，幫助用戶靈活、高效地開發和集成復雜的應用軟體，
中間件是位于平臺（硬體和作業系統）和應用之間的通用服務，這些服務具有標準的程式介面和協議，針對不同的作業系統和硬體平臺，中間件可以有符合介面和協議規范的多種實作，
RcoketMQ 是一款低延遲、高可靠、可伸縮、易于使用的訊息中間件，具有以下特性：
- 支持發布/訂閱（Pub/Sub）和點對點（P2P）訊息模型
- 在一個佇列中可靠的先進先出（FIFO）和嚴格的順序傳遞
- 支持拉（pull）和推（push）兩種訊息模式
- 單一佇列百萬訊息的堆積能力
- 支持多種訊息協議，如 JMS、MQTT 等
- 分布式高可用的部署架構,滿足至少一次訊息傳遞語意
- 提供 docker 鏡像用于隔離測驗和云集群部署
- 提供配置、指標和監控等功能豐富的 Dashboard
RocketMQ主體
主體分為四個角色
生產者Producer
訊息生產者，生產者的作用就是將訊息發送到 MQ，生產者本身既可以產生訊息，如讀取文本資訊等，也可以對外提供介面，由外部應用來呼叫介面，再由生產者將收到的訊息發送到 MQ，
衍生概念：Producer Group
生產者組，多個發送同一類訊息的生產者稱之為一個生產者組，
消費者Consumer
訊息消費者，消費 MQ 上的訊息的應用程式就是消費者
衍生概念：Consumer Group
消費者組，消費同一類訊息的多個 consumer 實體組成一個消費者組
訊息Message
Message 是訊息的載體，一個 Message 必須指定 topic，相當于寄信的地址，Message 還有一個可選的 tag 設定，以便消費端可以基于 tag 進行過濾訊息，也可以添加額外的鍵值對，例如你需要一個業務 key 來查找 broker 上的訊息，方便在開發程序中診斷問題，
衍生概念：Topic Tag
Topic
Topic 是一種訊息的邏輯分類，比如說你有訂單類的訊息，也有庫存類的訊息，那么就需要進行分類，一個是訂單 Topic 存放訂單相關的訊息，一個是庫存 Topic 存盤庫存相關的訊息，
Tag
標簽可以被認為是對 Topic 進一步細化，一般在相同業務模塊中通過引入標簽來標記不同用途的訊息，
統籌者
注冊中心 Name Server
Name Server 為 producer 和 consumer 提供路由資訊
經紀人 Broker
Broker 是 RocketMQ 系統的主要角色，其實就是前面一直說的 MQ，Broker 接收來自生產者的訊息，儲存以及為消費者拉取訊息的請求做好準備
RocketMQ 架構
RocketMQ 架構
由這張圖可以看到有四個集群，分別是 NameServer 集群、Broker 集群、Producer 集群和 Consumer 集群：
-
NameServer: 提供輕量級的服務發現和路由， 每個 NameServer 記錄完整的路由資訊，提供等效的讀寫服務，并支持快速存盤擴展，
-
Broker: 通過提供輕量級的 Topic 和 Queue 機制來處理訊息存盤,同時支持推（push）和拉（pull）模式以及主從結構的容錯機制，
-
Producer：生產者，產生訊息的實體，擁有相同 Producer Group 的 Producer 組成一個集群，
-
Consumer：消費者，接收訊息進行消費的實體，擁有相同 Consumer Group 的Consumer 組成一個集群
簡單說明一下圖中箭頭含義，從 Broker 開始，Broker Master1 和 Broker Slave1 是主從結構，它們之間會進行資料同步，即 Date Sync，同時每個 Broker 與 NameServer 集群中的所有節點建立長連接，定時注冊 Topic 資訊到所有 NameServer 中，
Producer 與 NameServer 集群中的其中一個節點（隨機選擇）建立長連接，定期從 NameServer 獲取 Topic 路由資訊，并向提供 Topic 服務的 Broker Master 建立長連接，且定時向 Broker 發送心跳，Producer 只能將訊息發送到 Broker master，但是 Consumer 則不一樣，它同時和提供 Topic 服務的 Master 和 Slave
建立長連接，既可以從 Broker Master 訂閱訊息，也可以從 Broker Slave 訂閱訊息，
RocketMQ 部署模式
-
單 master 模式
也就是只有一個 master 節點，稱不上是集群，一旦這個 master 節點宕機，那么整個服務就不可用，適合個人學習使用，
-
多 master 模式
多個 master 節點組成集群，單個 master 節點宕機或者重啟對應用沒有影響，
優點：所有模式中性能最高
缺點：單個 master 節點宕機期間，未被消費的訊息在節點恢復之前不可用，訊息的實時性就受到影響，
注意： 使用同步刷盤可以保證訊息不丟失，同時 Topic 相對應的 queue 應該分布在集群中各個節點，而不是只在某各節點上，否則，該節點宕機會對訂閱該 topic 的應用造成影響，
-
多 master 多 slave 異步復制模式
在多 master 模式的基礎上，每個 master 節點都有至少一個對應的 slave，master
節點可讀可寫，但是 slave 只能讀不能寫，類似于 mysql 的主備模式，
優點： 在 master 宕機時，消費者可以從 slave 讀取訊息，訊息的實時性不會受影響，性能幾乎和多 master 一樣，
缺點：使用異步復制的同步方式有可能會有訊息丟失的問題，
-
多 master 多 slave 同步雙寫模式
同多 master 多 slave 異步復制模式類似，區別在于 master 和 slave 之間的資料同步方式，
優點：同步雙寫的同步模式能保證資料不丟失，
缺點：發送單個訊息 RT 會略長，性能相比異步復制低10%左右，
刷盤策略：同步刷盤和異步刷盤（指的是節點自身資料是同步還是異步存盤）
同步方式：同步雙寫和異步復制（指的一組 master 和 slave 之間資料的同步）
注意：要保證資料可靠，需采用同步刷盤和同步雙寫的方式，但性能會較其他方式低，
持續更新中，，，
參考鏈接：
https://www.jianshu.com/p/824066d70da8
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/375126.html
標籤：其他