Message Queue之基本概念

同步與非同步任務

在進入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來堆積下單的請求, 當系統有能力處理時再進行處理。

1. 下單系統收到請求後就先丟到Queue，當Queue已經超出最大設定值時就reject請求。
2. 訂單處理系統根據Queue的依序請求訊息進行後續處理。

延伸閱讀: RabbitMQ — 消費者分發制度