使用 RabbitMQ 和 RocketMQ 的人是幸運(yùn)的，因為這兩個 MQ 自身提供了延遲隊列的實現(xiàn)，不像用 Kafka 的同學(xué)那么苦逼，還要自己實現(xiàn)延遲隊列。當(dāng)然，這都是題外話，今天咱們重點(diǎn)來聊聊 RabbitMQ 延遲隊列的實現(xiàn)原理，以及 RabbitMQ 實現(xiàn)延遲隊列的優(yōu)缺點(diǎn)有哪些？sHN28資訊網(wǎng)——每日最新資訊28at.com

很多人知道使用 RabbitMQ 是可以實現(xiàn)延遲隊列的，但對于 RocketMQ 自身也提供了延遲隊列這件事卻持有不同態(tài)度，這是因為網(wǎng)上有些資料說 RocketMQ 和 Kafka 沒有內(nèi)置延遲隊列。其實這種說法是因為，RocketMQ 在早期版本中確實沒有內(nèi)置延遲隊列，但在 4.x 就內(nèi)置了 18 個級別的延遲隊列了（最長支持 2 小時的延遲隊列），5.x 就支持隨機(jī)延遲時間的延遲隊列了，所以這里需要特殊強(qiáng)調(diào)一下。sHN28資訊網(wǎng)——每日最新資訊28at.com

1.什么是延遲隊列？

延遲隊列（Delay Queue）是一種特殊類型的隊列，它的主要特點(diǎn)是可以讓進(jìn)入隊列的元素在指定的延遲時間之后才被取出進(jìn)行處理。sHN28資訊網(wǎng)——每日最新資訊28at.com

延遲隊列的主要使用場景有以下這些：sHN28資訊網(wǎng)——每日最新資訊28at.com

• 訂單超時處理：在電商系統(tǒng)中，如果用戶下單后未在一定時間內(nèi)支付，訂單可能會被自動取消?？梢詫⒂唵畏湃胙舆t隊列，在設(shè)定的延遲時間（如 30 分鐘）后取出處理取消操作。
• 任務(wù)重試：當(dāng)某個任務(wù)執(zhí)行失敗時，將其放入延遲隊列，等待一段時間（如 5 分鐘）后重新執(zhí)行。
• 消息延遲發(fā)送：某些消息不需要立即發(fā)送，而是在指定的延遲時間后發(fā)送，例如定時提醒消息。
• 緩存過期處理：緩存中的數(shù)據(jù)可能有一定的有效期，將即將過期的數(shù)據(jù)放入延遲隊列，到期后進(jìn)行刪除或更新操作。

2.延遲任務(wù)實現(xiàn)方法

那么延遲隊列的實現(xiàn)方式有哪些呢？sHN28資訊網(wǎng)——每日最新資訊28at.com

延遲隊列的實現(xiàn)方式通常有以下幾種：sHN28資訊網(wǎng)——每日最新資訊28at.com

• 基于 JDK 提供的 DelayQueue 來實現(xiàn)：它是內(nèi)存級別的延遲隊列，重啟應(yīng)用之后消息會丟失，并且只支持單機(jī)版延遲隊列，所以一般不用。
• 基于 MQ 的延遲隊列：例如使用 RabbitMQ 來實現(xiàn)延遲隊列，他們適合處理動態(tài)和臨時延遲任務(wù)，不像定時任務(wù)一樣，適合處理正式的、固定的延遲任務(wù)。
• 基于定時任務(wù)組件實現(xiàn)延遲任務(wù)：例如 XXLJob 或 Quartz 等框架來實現(xiàn)延遲任務(wù)，他們適合處理固定（執(zhí)行）頻率的延遲任務(wù)。

我們通常會使用延遲隊列來存儲（和實現(xiàn)）延遲消息，所以大部分時候，我們說的延遲隊列和延遲消息其實是一回事。sHN28資訊網(wǎng)——每日最新資訊28at.com

3.使用RabbitMQ實現(xiàn)延遲隊列

使用 RabbitMQ 實現(xiàn)延遲隊列有以下兩種實現(xiàn)方式：sHN28資訊網(wǎng)——每日最新資訊28at.com

• 通過死信隊列實現(xiàn)延遲任務(wù)：將正常的消息放到?jīng)]有消息訂閱者的消息隊列（消息自然就會過期），等消息過期之后會進(jìn)入死信隊列，通過訂閱死信隊列消費(fèi)消息，從而實現(xiàn)延遲隊列，如下圖所示：

sHN28資訊網(wǎng)——每日最新資訊28at.com

• 通過官方提供的延遲插件實現(xiàn)延遲功能。

早期大部分公司都會采用第一種方式，而隨著 RabbitMQ 3.5.7（2015 年底發(fā)布）的延遲插件的發(fā)布，因為其使用更簡單、更方便，所以它現(xiàn)在才是大家普通會采用的，實現(xiàn)延遲隊列的方式。sHN28資訊網(wǎng)——每日最新資訊28at.com

（1）實現(xiàn)原理分析

使用延遲插件的實現(xiàn)原理是通過創(chuàng)建一個延遲交換機(jī)（Delay Exchange），延遲消息首先會把消息投遞到延遲交換機(jī)，并不是直接將消息投遞業(yè)務(wù)隊列（所以不會立即執(zhí)行），由延遲交換機(jī)控制消息在延遲一段時間后，再將消息投遞到真正的隊列中進(jìn)行消費(fèi)，從而實現(xiàn)延遲隊列，它的實現(xiàn)流程如下圖所示：sHN28資訊網(wǎng)——每日最新資訊28at.com

sHN28資訊網(wǎng)——每日最新資訊28at.com

其中 Mnesia 可以理解為基于文件存儲的數(shù)據(jù)庫。sHN28資訊網(wǎng)——每日最新資訊28at.com

（2）優(yōu)缺點(diǎn)分析

使用死信隊列實現(xiàn)延遲任務(wù)有個缺點(diǎn)，它不能實現(xiàn)隨機(jī)延遲任務(wù)，每個無消費(fèi)者的隊列上只能設(shè)置一個 ttl（消息過期時間），所以只能實現(xiàn)固定過期時間的延遲任務(wù)。sHN28資訊網(wǎng)——每日最新資訊28at.com

使用延遲插件實現(xiàn)延遲任務(wù)有以下兩個缺點(diǎn)：sHN28資訊網(wǎng)——每日最新資訊28at.com

• 消息丟失問題：消息在真的被投遞到目標(biāo)消息隊列之前，是存放在接收到了這個消息的服務(wù)端本地的 Mnesia 里面。也就是說，如果這個時候還沒有刷新磁盤，那么消息就會丟失；如果這個節(jié)點(diǎn)不可用了，那么消息也同樣會丟失。
• 高并發(fā)問題：這種實現(xiàn)方式不支持高并發(fā)場景，因為它只有一個延遲交換機(jī)，當(dāng)高并發(fā)或數(shù)據(jù)量比較大時執(zhí)行效率就會比較低。

本文鏈接：http://m.www897cc.com/showinfo-26-101269-0.html說說MQ延遲隊列實現(xiàn)原理？

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： 微前端代碼隔離方案，手把手實現(xiàn)一個 JS 沙箱隔離！

下一篇： 不掉頭發(fā)“逆向”旋轉(zhuǎn)驗證碼