1.背景
RabbitMQ是一個由erlang開發(fā)的AMQP(Advanved Message Queue)的開源實現(xiàn)。
2.應(yīng)用場景
2.1異步處理
場景說明：用戶注冊后，需要發(fā)注冊郵件和注冊短信,傳統(tǒng)的做法有兩種1.串行的方式;2.并行的方式
(1)串行方式:將注冊信息寫入數(shù)據(jù)庫后,發(fā)送注冊郵件,再發(fā)送注冊短信,以上三個任務(wù)全部完成后才返回給客戶端。 這有一個問題是,郵件,短信并不是必須的,它只是一個通知,而這種做法讓客戶端等待沒有必要等待的東西.
(2)并行方式:將注冊信息寫入數(shù)據(jù)庫后,發(fā)送郵件的同時,發(fā)送短信,以上三個任務(wù)完成后,返回給客戶端,并行的方式能提高處理的時間。
假設(shè)三個業(yè)務(wù)節(jié)點分別使用50ms,串行方式使用時間150ms,并行使用時間100ms。雖然并性已經(jīng)提高的處理時間,但是,前面說過,郵件和短信對我正常的使用網(wǎng)站沒有任何影響，客戶端沒有必要等著其發(fā)送完成才顯示注冊成功,英愛是寫入數(shù)據(jù)庫后就返回.
(3)消息隊列
引入消息隊列后，把發(fā)送郵件,短信不是必須的業(yè)務(wù)邏輯異步處理
由此可以看出,引入消息隊列后，用戶的響應(yīng)時間就等于寫入數(shù)據(jù)庫的時間+寫入消息隊列的時間(可以忽略不計),引入消息隊列后處理后,響應(yīng)時間是串行的3倍,是并行的2倍。
2.2 應(yīng)用解耦
場景：雙11是購物狂節(jié),用戶下單后,訂單系統(tǒng)需要通知庫存系統(tǒng),傳統(tǒng)的做法就是訂單系統(tǒng)調(diào)用庫存系統(tǒng)的接口.
這種做法有一個缺點:
當(dāng)庫存系統(tǒng)出現(xiàn)故障時,訂單就會失敗。(這樣馬云將少賺好多好多錢^ ^)
-
訂單系統(tǒng)和庫存系統(tǒng)高耦合.
引入消息隊列 :
訂單系統(tǒng):用戶下單后,訂單系統(tǒng)完成持久化處理,將消息寫入消息隊列,返回用戶訂單下單成功。
庫存系統(tǒng):訂閱下單的消息,獲取下單消息,進行庫操作。
就算庫存系統(tǒng)出現(xiàn)故障,消息隊列也能保證消息的可靠投遞,不會導(dǎo)致消息丟失(馬云這下高興了).
流量削峰
流量削峰一般在秒殺活動中應(yīng)用廣泛
場景:秒殺活動，一般會因為流量過大，導(dǎo)致應(yīng)用掛掉,為了解決這個問題，一般在應(yīng)用前端加入消息隊列。
作用:
1.可以控制活動人數(shù)，超過此一定閥值的訂單直接丟棄(我為什么秒殺一次都沒有成功過呢^^)
2.可以緩解短時間的高流量壓垮應(yīng)用(應(yīng)用程序按自己的最大處理能力獲取訂單)
1.用戶的請求,服務(wù)器收到之后,首先寫入消息隊列,加入消息隊列長度超過最大值,則直接拋棄用戶請求或跳轉(zhuǎn)到錯誤頁面.
2.秒殺業(yè)務(wù)根據(jù)消息隊列中的請求信息，再做后續(xù)處理.
3.系統(tǒng)架構(gòu)
幾個概念說明:
Broker:它提供一種傳輸服務(wù),它的角色就是維護一條從生產(chǎn)者到消費者的路線，保證數(shù)據(jù)能按照指定的方式進行傳輸,
Exchange：消息交換機,它指定消息按什么規(guī)則,路由到哪個隊列。
Queue:消息的載體,每個消息都會被投到一個或多個隊列。
Binding:綁定，它的作用就是把exchange和queue按照路由規(guī)則綁定起來.
Routing Key:路由關(guān)鍵字,exchange根據(jù)這個關(guān)鍵字進行消息投遞。
vhost:虛擬主機,一個broker里可以有多個vhost，用作不同用戶的權(quán)限分離。
Producer:消息生產(chǎn)者,就是投遞消息的程序.
Consumer:消息消費者,就是接受消息的程序.
Channel:消息通道,在客戶端的每個連接里,可建立多個channel.
各種消息中間件性能的比較：
TPS比較 一ZeroMq 最好，RabbitMq 次之， ActiveMq 最差。
持久化消息比較—zeroMq不支持，activeMq和rabbitMq都支持。持久化消息主要是指：MQ down或者MQ所在的服務(wù)器down了，消息不會丟失的機制。
可靠性、靈活的路由、集群、事務(wù)、高可用的隊列、消息排序、問題追蹤、可視化管理工具、插件系統(tǒng)、社區(qū)—RabbitMq最好，ActiveMq次之，ZeroMq最差。
高并發(fā)—從實現(xiàn)語言來看，RabbitMQ最高，原因是它的實現(xiàn)語言是天生具備高并發(fā)高可用的erlang語言。
綜上所述：RabbitMQ的性能相對來說更好更全面，是消息中間件的首選。
參考：
https://blog.csdn.net/whoamiyang/article/details/54954780
https://blog.csdn.net/qq_38455201/article/details/80308771
其他教程：
https://blog.csdn.net/zhuzhezhuzhe1/article/details/80454956
https://blog.csdn.net/hellozpc/article/details/81436980
