Python知識分享網(wǎng) - 專業(yè)的Python學習網(wǎng)站 學Python,上Python222
RocketMQ詳細介紹及核心問題解釋(很全) PDF 下載
發(fā)布于:2024-02-14 10:57:20
(假如點擊沒反應,多刷新兩次就OK!)

RocketMQ詳細介紹及核心問題解釋(很全) PDF 下載  圖1

 

 

資料內(nèi)容:

 

1. RocketMq是什么
 

一個純Java、分布式隊列模型的消息中間件,具有高可用、高可靠、高實時、低延遲的特點。(記住這句就
行了)

 

2. RocketMq有什么功能


1、業(yè)務解耦:這也是發(fā)布訂閱的消息模型。生產(chǎn)者發(fā)送指令到MQ中,然后下游訂閱這類指令的 消費者會收
到這個指令執(zhí)行相應的邏輯,整個過程與具體業(yè)務無關,抽象成了一個發(fā)送指令,存儲指令,消費指令的過
程。
2、前端削峰:前端發(fā)起的請求在短時間內(nèi)太多后端無法處理,可以堆積在MQ中,后端按照一定的順序處
理,秒殺系統(tǒng)就是這么實現(xiàn)的。
3、億級消息的堆積能力,單個隊列中的百萬級消息的累積容量。
4、高可用性:Broker服務器支持多Master多Slave的同步雙寫以及Master多Slave的異步復制模式,其中同
步雙寫可保證消息不丟失。
5、高可靠性:生產(chǎn)者將消息發(fā)送到Broker端有三種方式,同步、異步和單向,其中同步和異步都可以保證
消息成功的成功發(fā)送。Broker在對于消息刷盤有兩種策略:同步刷盤和異步刷盤,其中同步刷盤可以保證消
息成功的存儲到磁盤中。消費者的消費模式也有集群消費和廣播消費兩種,默認集群消費,如果集群模式中
消費者掛了,一個組里的其他消費者會接替其消費。綜上所述,是高可靠的。
6、支持分布式事務消息:這里是采用半消息確認和消息回查機制來保證分布式事務消息的,下面會詳細描
述。
7、支持消息過濾:建議采用消費者業(yè)務端的tag過濾。
8、支持順序消息:消息在Broker中是采用隊列的FIFO模式存儲的,也就是發(fā)送是順序的,只要保證消費的
順序性即可。
9、支持定時消息和延遲消息:Broker中由定時消息的機制,消息發(fā)送到Broker中,不會立即被Consumer
消費,會等到一定的時間才被消費。延遲消息也是一樣,延遲一定時間之后才會被Consumer消費。

 

3. RocketMq的架構(gòu)

 

RocketMq一共有四個部分組成:NameServer,Broker,Producer生產(chǎn)者,Consumer消費者,每一部分
都是集群部署的。