消息隊(duì)列使用場(chǎng)景 為什么會(huì)需要消息隊(duì)列(MQ)？

解耦
在項(xiàng)目啟動(dòng)之初來預(yù)測(cè)將來項(xiàng)目會(huì)碰到什么需求，是極其困難的。消息系統(tǒng)在處理過程中間插入了一個(gè)隱含的、基于數(shù)據(jù)的接口層，兩邊的處理過程都要實(shí)現(xiàn)這一接口。這允許你獨(dú)立的擴(kuò)展或修改兩邊的處理過程，只要確保它們遵守同樣的接口約束。
冗余
有些情況下，處理數(shù)據(jù)的過程會(huì)失敗。除非數(shù)據(jù)被持久化，否則將造成丟失。消息隊(duì)列把數(shù)據(jù)進(jìn)行持久化直到它們已經(jīng)被完全處理，通過這一方式規(guī)避了數(shù)據(jù)丟失風(fēng)險(xiǎn)。許多消息隊(duì)列所采用的”插入-獲取-刪除”范式中，在把一個(gè)消息從隊(duì)列中刪除之前，需要你的處理系統(tǒng)明確的指出該消息已經(jīng)被處理完畢，從而確保你的數(shù)據(jù)被安全的保存直到你使用完畢。
擴(kuò)展性
因?yàn)橄㈥?duì)列解耦了你的處理過程，所以增大消息入隊(duì)和處理的頻率是很容易的，只要另外增加處理過程即可。不需要改變代碼、不需要調(diào)節(jié)參數(shù)。擴(kuò)展就像調(diào)大電力按鈕一樣簡(jiǎn)單。
靈活性 & 峰值處理能力
在訪問量劇增的情況下，應(yīng)用仍然需要繼續(xù)發(fā)揮作用，但是這樣的突發(fā)流量并不常見；如果為以能處理這類峰值訪問為標(biāo)準(zhǔn)來投入資源隨時(shí)待命無疑是巨大的浪費(fèi)。使用消息隊(duì)列能夠使關(guān)鍵組件頂住突發(fā)的訪問壓力，而不會(huì)因?yàn)橥话l(fā)的超負(fù)荷的請(qǐng)求而完全崩潰。
可恢復(fù)性
系統(tǒng)的一部分組件失效時(shí)，不會(huì)影響到整個(gè)系統(tǒng)。消息隊(duì)列降低了進(jìn)程間的耦合度，所以即使一個(gè)處理消息的進(jìn)程掛掉，加入隊(duì)列中的消息仍然可以在系統(tǒng)恢復(fù)后被處理。
順序保證
在大多使用場(chǎng)景下，數(shù)據(jù)處理的順序都很重要。大部分消息隊(duì)列本來就是排序的，并且能保證數(shù)據(jù)會(huì)按照特定的順序來處理。Kafka保證一個(gè)Partition內(nèi)的消息的有序性。
緩沖
在任何重要的系統(tǒng)中，都會(huì)有需要不同的處理時(shí)間的元素。例如，加載一張圖片比應(yīng)用過濾器花費(fèi)更少的時(shí)間。消息隊(duì)列通過一個(gè)緩沖層來幫助任務(wù)最高效率的執(zhí)行———寫入隊(duì)列的處理會(huì)盡可能的快速。該緩沖有助于控制和優(yōu)化數(shù)據(jù)流經(jīng)過系統(tǒng)的速度。
異步通信
很多時(shí)候，用戶不想也不需要立即處理消息。消息隊(duì)列提供了異步處理機(jī)制，允許用戶把一個(gè)消息放入隊(duì)列，但并不立即處理它。想向隊(duì)列中放入多少消息就放多少，然后在需要的時(shí)候再去處理它們。

MQ常用的使用場(chǎng)景：
1. 進(jìn)程間通訊和系統(tǒng)間的消息通知，比如在分布式系統(tǒng)中。
2. 解耦，比如像我們公司有許多開發(fā)團(tuán)隊(duì)，每個(gè)團(tuán)隊(duì)負(fù)責(zé)業(yè)務(wù)的不同模塊，各個(gè)開發(fā)團(tuán)隊(duì)可以使用MQ來通信。
3. 在一些高并發(fā)場(chǎng)景下，使用MQ的異步特性。

消息隊(duì)列和RPC對(duì)比 系統(tǒng)架構(gòu)

RPC系統(tǒng)結(jié)構(gòu)：

+----------++----------+|Consumer|<=>|Provider|+----------++----------+

Consumer調(diào)用的Provider提供的服務(wù)。
Message Queue系統(tǒng)結(jié)構(gòu)：

+--------++-------++----------+|Sender|<=>|Queue|<=>|Receiver|+--------++-------++----------+

Sender發(fā)送消息給Queue；Receiver從Queue拿到消息來處理。

功能特點(diǎn)

在架構(gòu)上，RPC和Message Queue的差異點(diǎn)是，Message Queue有一個(gè)中間結(jié)點(diǎn)Message Queue(broker)，可以把消息存儲(chǔ)。

消息隊(duì)列的特點(diǎn)

Message Queue把請(qǐng)求的壓力保存一下，逐漸釋放出來，讓處理者按照自己的節(jié)奏來處理。

Message Queue引入一下新的結(jié)點(diǎn)，讓系統(tǒng)的可靠性會(huì)受Message Queue結(jié)點(diǎn)的影響。

Message Queue是異步單向的消息。發(fā)送消息設(shè)計(jì)成是不需要等待消息處理的完成。

所以對(duì)于有同步返回需求，用Message Queue則變得麻煩了。

RPC的特點(diǎn)

同步調(diào)用，對(duì)于要等待返回結(jié)果/處理結(jié)果的場(chǎng)景，RPC是可以非常自然直覺的使用方式。RPC也可以是異步調(diào)用。

由于等待結(jié)果，Consumer（Client）會(huì)有線程消耗。