RabbitMQ 默認并不支持“真正意義上的延遲隊列”。實現延時消息最常用的方式就是安裝 rabbitmq_delayed_message_exchange 插件。
本文將從插件安裝、啟用、配置、使用全流程帶你掌握 RabbitMQ 延時隊列的正確姿勢。

---

📌 一、什么是 RabbitMQ 延時隊列？

延時隊列的核心功能就是：讓消息延遲一定時間后再投遞到消費者。

典型應用場景包括：

• 訂單支付超時取消

• 秒殺未支付自動釋放庫存

• 用戶注冊后延時發送歡迎郵件

• 自動關閉未操作的工單等

---

🚀 二、安裝前準備

? RabbitMQ 環境要求

• RabbitMQ ≥ 3.6.x
• Erlang ≥ 19.x（越新越好）
• 插件版本需與 RabbitMQ 版本匹配（注意版本兼容）

Docker 搭建 RabbitMQ
https://blog.csdn.net/weixin_44876263/article/details/147245253?sharetype=blogdetail&sharerId=147245253&sharerefer=PC&sharesource=weixin_44876263&spm=1011.2480.3001.8118

---

🔧 三、安裝延時隊列插件

🧩 插件名稱：

rabbitmq_delayed_message_exchange

---

1?? 下載插件

你可以從 GitHub 或 RabbitMQ 官網下載預編譯的 .ez 文件。

🔗 插件發布地址：

• https://www.rabbitmq.com/community-plugins.html

• GitHub 地址：https://github.com/rabbitmq/rabbitmq-delayed-message-exchange

進入web端后左上角有顯示當前安裝的RabbitMQ版本

需要保證RabbitMQ插件的大版本與RabbitMQ保持一致，否則會啟動失敗

例如（RabbitMQ 4.0.*）：

wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v4.0.7/rabbitmq_delayed_message_exchange-v4.0.7.ez

---

2?? 復制插件到插件目錄

將插件拷貝到容器內plugins目錄下

docker cp /root/rabbitmq_delayed_message_exchange-v4.0.7.ez rabbitmq:/plugins

將 .ez 文件復制進去：

// 進入容器 我這里使用容器名字 也可以用容器id進入
docker exec -it rabbitmq /bin/bash// 移動到plugins目錄下
cd plugins// 查看是否上傳成功
ls

---

3?? 啟用插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

輸出類似：

檢查插件是否存在于鏡像中
容器內執行：

rabbitmq-plugins list

這表明：

? 插件 rabbitmq_delayed_message_exchange 已經啟用并正在運行。

---

4?? 重啟 RabbitMQ 容器（建議）

docker restart rabbitmq

---

5?? 驗證插件是否啟用成功

容器啟動成功之后，登錄RabbitMQ的管理界面（ip:15672 訪問web界面），找到ExchangesTab頁。點擊Add a new exchange，在Type里面查看是否有x-delayed-message選項，如果存在就代表插件安裝成功。

6?? 配置容器重啟時自動加載插件

為了確保 RabbitMQ 容器每次重啟時自動啟用指定插件，需要在容器內 /etc/rabbitmq/enabled_plugins 文件中配置插件列表。

1. 進入正在運行的容器：

   docker exec -it <容器名稱或ID> /bin/bash
   

2. 編輯或創建插件配置文件 /etc/rabbitmq/enabled_plugins，寫入如下內容：

   [rabbitmq_management, rabbitmq_delayed_message_exchange].
   

   

3. 保存文件并退出容器。

4. 重新啟動容器，確認插件自動啟用：

   docker restart <容器名稱或ID>
   

5. 通過 RabbitMQ 管理界面或命令行確認插件狀態：

   docker exec <容器名稱或ID> rabbitmq-plugins list
   

備注：

• 確保掛載的配置目錄（包含 enabled_plugins 文件）權限正確，容器內 RabbitMQ 進程能正常讀取。
• enabled_plugins 文件必須以 Erlang 列表格式并以句點 . 結尾。
• 也可通過環境變量或啟動命令方式啟用插件，但寫入 enabled_plugins 文件更持久、可靠。

---

🧪 四、使用延時隊列功能（Java 示例）

延時消息的核心是：通過一個特殊的 Exchange 類型 x-delayed-message + 自定義 header 設置延遲時間。

---

📝 創建延時交換機與隊列

/*** 聲明延遲隊列（Queue 本身無 TTL，延遲由消息屬性 x-delay 控制）* 注意：需要安裝 RabbitMQ 的延遲消息插件（rabbitmq_delayed_message_exchange）*/@Beanpublic Queue delayQueue() {return QueueBuilder.durable(getRetry().getQueue()).build();}/*** 聲明延遲交換機：必須使用插件類型 x-delayed-message，并聲明延遲基礎類型為 direct*/@Beanpublic CustomExchange delayExchange() {Map<String, Object> args = new HashMap<>();args.put("x-delayed-type", "direct");return new CustomExchange(getRetry().getExchange(),      // 名稱"x-delayed-message",           // 類型（延遲消息插件）true,                          // durablefalse,                         // auto-deleteargs                           // 參數：聲明 delayed 類型為 direct);}/*** 綁定延遲隊列到延遲交換機*/@Beanpublic Binding delayBinding() {return BindingBuilder.bind(delayQueue()).to(delayExchange()).with(getRetry().getRoutingKey()).noargs();}

---

📨 發送延時消息

/*** 默認延遲 30 分鐘（1800000 毫秒）*/public void sendDelayedTask(String message) {this.sendDelayedTask(message, 30 * 60 * 1000);}/*** 發送延遲消息*/public void sendDelayedTask(String message, long delayMillis) {MessageProperties properties = new MessageProperties();properties.setContentType(MessageProperties.CONTENT_TYPE_JSON);properties.setHeader("x-delay", delayMillis); // 設置延遲時間（單位：毫秒）Message amqpMessage = new Message(message.getBytes(StandardCharsets.UTF_8), properties);rabbitTemplate.send(rabbitMqProperties.getConfig().getRetry().getExchange(),rabbitMqProperties.getConfig().getRetry().getRoutingKey(),amqpMessage);log.info("延遲任務已發送，延遲 {} s 后投遞: {}", delayMillis/1000, message);}

---

🔒 五、注意事項

• 插件啟用后，RabbitMQ 會新增一種交換機類型 x-delayed-message
• 不兼容 RabbitMQ 自帶的 TTL + DLX 延遲實現方案
• 插件僅支持設置 發送時延遲，不支持基于隊列統一延遲
• 插件不支持所有 AMQP 客戶端（需顯式支持 header 設置的客戶端）

---

🧰 六、Web 管理界面配置示例

你也可以通過 RabbitMQ 的 Web 控制臺：

1. 創建交換機類型為 x-delayed-message
2. 設置參數 x-delayed-type = direct
3. 綁定隊列
4. 消息發布時設置 header：x-delay: 10000（單位 ms）

---

📌 七、延時隊列 VS RabbitMQ 原生 TTL 實現

方案	支持粒度	精準控制	依賴 DLX	靈活性	復雜度
原生 TTL + 死信隊列	隊列級 / 消息級	一般	是	中等	中等
延時插件 rabbitmq_delayed_message_exchange	消息級	高	否	高	低

---

? 八、常見問題 FAQ

1. 插件安裝后沒有效果？

• 檢查是否重啟 RabbitMQ
• 檢查交換機類型是否正確設置為 x-delayed-message
• 檢查消息是否設置了 header：x-delay

2. 插件是否與集群兼容？

支持，只需確保每個節點都安裝啟用了插件。

---

🏁 總結

通過安裝 rabbitmq_delayed_message_exchange 插件，RabbitMQ 擁有了真正意義上的“消息級”延遲投遞功能，無需依賴死信隊列和 TTL，極大簡化了延時場景的開發與維護工作。