本篇文章給大家?guī)砹岁P于消息隊列的相關知識,其中主要介紹了咱們之所以要使用消息隊列的原因,為什么要使用消息隊列,感興趣的朋友,下面一起來看一下吧,希望對大家有幫助。
為什么要使用消息隊列,六個字總結:解耦、異步、消峰
1)解耦
傳統(tǒng)模式下系統(tǒng)間的耦合性太強。怎么說呢,舉個例子:系統(tǒng) A 通過接口調用發(fā)送數據到 B、C、D 三個系統(tǒng),如果將來 E 系統(tǒng)接入或者 B 系統(tǒng)不需要接入了,那么系統(tǒng) A 還需要修改代碼,非常麻煩。
如果系統(tǒng) A 產生了一條比較關鍵的數據,那么它就要時時刻刻考慮 B、C、D、E 四個系統(tǒng)如果掛了該咋辦?這條數據它們是否都收到了?顯然,系統(tǒng) A 跟其它系統(tǒng)嚴重耦合。
而如果我們將數據(消息)寫入消息隊列,需要消息的系統(tǒng)直接自己從消息隊列中消費。這樣下來,系統(tǒng) A 就不需要去考慮要給誰發(fā)送數據,不需要去維護這個代碼,也不需要考慮其他系統(tǒng)是否調用成功、失敗超時等情況,反正我只負責生產,別的我不管。
2)異步
先來看傳統(tǒng)同步的情況,舉個例子:系統(tǒng) A 接收一個用戶請求,需要進行寫庫操作,還需要同樣的在 B、C、D 三個系統(tǒng)中進行寫庫操作。如果 A 自己本地寫庫只要 1ms,而 B、C、D 三個系統(tǒng)寫庫分別要 100ms、200ms、300ms。最終請求總延時是 1 + 100 + 200 + 300 = 601ms,用戶體驗大打折扣。
如果使用消息隊列,那么系統(tǒng) A 就只需要發(fā)送 3 條消息到消息隊列中就行了,假如耗時 5ms,A 系統(tǒng)從接受一個請求到返回響應給用戶,總時長是 1 + 5 = 6ms,對于用戶而言,體驗好感度直接拉滿。
3)消峰
如果沒有使用緩存或者消息隊列,那么系統(tǒng)就是直接基于數據庫 MySQL 的,如果有那么一個高峰期,產生了大量的請求涌入 MySQL,毫無疑問,系統(tǒng)將會直接崩潰。
那如果我們使用消息隊列,假設 MySQL 每秒鐘最多處理 1k 條數據,而高峰期瞬間涌入了 5k 條數據,不過,這 5k 條數據涌入了消息隊列。這樣,我們的系統(tǒng)就可以從消息隊列中根據數據庫的能力慢慢的來拉取請求,不要超過自己每秒能處理的最大請求數量就行。
也就是說消息隊列每秒鐘 5k 個請求進來,1k 個請求出去,假設高峰期 1 個小時,那么這段時間就可能有幾十萬甚至幾百萬的請求積壓在消息隊列中。不過這個短暫的高峰期積壓是完全可以的,因為高峰期過了之后,每秒鐘就沒有那么多的請求進入消息隊列了,但是數據庫依然會按照每秒 1k 個請求的速度處理。所以只要高峰期一過,系統(tǒng)就會快速的將積壓的消息給處理掉。
推薦學習:《Redis視頻教程》