同步與非同步任務
在進入Message Queue之前我們先來了解一下同步/非同步任務的概念。
- 菜單稱為訊息(Message), 為工作內容描述。
- 送出菜單的客人稱為生產者(Producer), 負責建立訊息。
- 櫃台就相當於Queue, 負責接單並依序處理。
- 廚師就是消費者的概念, 負責消化Queue裡面的訊息。
什麼是Message Queue?
採生產者/消費者模式，主要提供不同process之間通訊的方式之一。- Producer: 負責生產訊息。
- Consumer: 負責接收及處理訊息。
應用場景
應用解耦
用戶下單後, 訂單系統需要通知庫存系統, 但是假設庫存系統故障, 就會導致客戶下單失敗。
引入Message Queue之後
- 訂單系統: 用戶下單後, 訂單系統完成持久化工作後, 發布消息到Message Queue, 並返回下單成功。
- 庫存系統: 向Message Queue訂閱下單的消息, 再根據下單的訊息內容進行庫存的更新。
- 如此一來客戶下單時假設庫存系統故障, 仍可正常下單。
並行處理
帳號註冊成功後還需要發送Mail及簡訊, 如果還沒有Message Queue時勢必需要依序發送, 但如果中間隔了一層Message Queue時, 簡訊系統及Mail系統就可以各自獲取訊息並處理。
流量控制
電商平台常常推出限時搶購活動, 但如果大家都在同一時間發出請求, 那麼當訂單系統無法負荷時將造成下單失敗, 勢必引來使用者抱怨的狀況, 而為了防止這種後端被壓垮的狀況, 可以導入MQ的架構來因應, 透過Queue來堆積下單的請求, 當系統有能力處理時再進行處理。
- 下單系統收到請求後就先丟到Queue，當Queue已經超出最大設定值時就reject請求。
- 訂單處理系統根據Queue的依序請求訊息進行後續處理。
