延遲機制

延遲隊列

• 延遲隊列——消息進入到隊列之后，延遲指定的時間才能被消費者消費
• AMQP協議和RabbitMQ隊列本身是不支持延遲隊列功能的，但是可以通過TTL（Time To Live）特性模擬延遲隊列的功能
• TTL就是消息的存活時間。RabbitMQ可以分別對隊列和消息設置存活時間

• 在創建隊列的時候可以設置隊列的存活時間，當消息進入到隊列并且在存活時間內沒有消費者消費，則此消息就會從當前隊列被移除；
• 創建消息隊列沒有設置TTL，但是消息設置了TTL，那么當消息的存活時間結束，也會被移除；一般設置每個消息的存活時間相等，即使不等也要保持前面消息的存活時間小于后面消息，因為隊列是滿足先進先出原則的消費，只有第一個消息被消費才能到第二個消息，如果后面的消息存活時間很短，等到前面消息處理完，后面的消息也被移除了，就是后面是無效消息。
• 當TTL結束之后，我們可以指定將當前隊列的消息轉存到其他指定的隊列

使用延遲隊列實現訂單支付監控

死信隊列：沒有消費者，但設置了消息TTL存活時間，等過期時間一到，所以消息要么轉存到其他隊列，要么移除。

實現流程圖

**訂單延時支付功能實現：**準備一個路由模式的交換機，一個死信隊列存放消息，但是沒有消費者消費它，一個queue2消息隊列不存放消息，只接收死信隊列轉存的過期消息，有B服務消費queue2隊列，這樣就可以保障B服務會在30分鐘后檢查支付狀態（因為一開始queue2沒有存消息，B消費者不能消費，只有在30分鐘后，死信隊列轉存過期消息到queue2,B才能消費）。

創建交換機和隊列

總結

以上是生活随笔為你收集整理的MQ延迟机制的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。