【資訊軟體知識】井然有序的處理機制 - 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的依序請求訊息進行後續處理。

圖片來源