RabbitMQ?延時隊列插件安裝與使用示例詳解(基于?Delayed?Message?Plugin)
RabbitMQ 默認并不支持“真正意義上的延遲隊列”。實現(xiàn)延時消息最常用的方式就是安裝 rabbitmq_delayed_message_exchange 插件。
本文將從插件安裝、啟用、配置、使用全流程帶你掌握 RabbitMQ 延時隊列的正確姿勢。
?? 一、什么是 RabbitMQ 延時隊列？
延時隊列的核心功能就是：讓消息延遲一定時間后再投遞到消費者。
典型應(yīng)用場景包括：
- 訂單支付超時取消
- 秒殺未支付自動釋放庫存
- 用戶注冊后延時發(fā)送歡迎郵件
- 自動關(guān)閉未操作的工單等
?? 二、安裝前準(zhǔn)備
? RabbitMQ 環(huán)境要求
- RabbitMQ ≥ 3.6.x
- Erlang ≥ 19.x（越新越好）
- 插件版本需與 RabbitMQ 版本匹配（注意版本兼容）
?? 三、安裝延時隊列插件
?? 插件名稱：
rabbitmq_delayed_message_exchange
1?? 下載插件
你可以從 GitHub 或 RabbitMQ 官網(wǎng)下載預(yù)編譯的 .ez 文件。
?? 插件發(fā)布地址：
進入web端后左上角有顯示當(dāng)前安裝的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?? 復(fù)制插件到插件目錄
將插件拷貝到容器內(nèi)plugins目錄下
docker cp /root/rabbitmq_delayed_message_exchange-v4.0.7.ez rabbitmq:/plugins
將 .ez 文件復(fù)制進去：
// 進入容器 我這里使用容器名字 也可以用容器id進入 docker exec -it rabbitmq /bin/bash // 移動到plugins目錄下 cd plugins // 查看是否上傳成功 ls
3?? 啟用插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
輸出類似：
檢查插件是否存在于鏡像中
容器內(nèi)執(zhí)行：
rabbitmq-plugins list
這表明：
? 插件 rabbitmq_delayed_message_exchange 已經(jīng)啟用并正在運行。
4?? 重啟 RabbitMQ 容器（建議）
docker restart rabbitmq
5?? 驗證插件是否啟用成功
容器啟動成功之后，登錄RabbitMQ的管理界面（ip:15672 訪問web界面），找到ExchangesTab頁。點擊Add a new exchange，在Type里面查看是否有x-delayed-message選項，如果存在就代表插件安裝成功。
6?? 配置容器重啟時自動加載插件
為了確保 RabbitMQ 容器每次重啟時自動啟用指定插件，需要在容器內(nèi) /etc/rabbitmq/enabled_plugins 文件中配置插件列表。
進入正在運行的容器：
docker exec -it <容器名稱或ID> /bin/bash
編輯或創(chuàng)建插件配置文件 /etc/rabbitmq/enabled_plugins，寫入如下內(nèi)容：
[rabbitmq_management, rabbitmq_delayed_message_exchange].
保存文件并退出容器。
重新啟動容器，確認插件自動啟用：
docker restart <容器名稱或ID>
通過 RabbitMQ 管理界面或命令行確認插件狀態(tài)：
docker exec <容器名稱或ID> rabbitmq-plugins list
備注：
- 確保掛載的配置目錄（包含
enabled_plugins文件）權(quán)限正確，容器內(nèi) RabbitMQ 進程能正常讀取。 enabled_plugins文件必須以 Erlang 列表格式并以句點.結(jié)尾。- 也可通過環(huán)境變量或啟動命令方式啟用插件，但寫入
enabled_plugins文件更持久、可靠。
?? 四、使用延時隊列功能（Java 示例）
延時消息的核心是：通過一個特殊的 Exchange 類型 x-delayed-message + 自定義 header 設(shè)置延遲時間。
?? 創(chuàng)建延時交換機與隊列
/**
* 聲明延遲隊列（Queue 本身無 TTL，延遲由消息屬性 x-delay 控制）
* 注意：需要安裝 RabbitMQ 的延遲消息插件（rabbitmq_delayed_message_exchange）
*/
@Bean
public Queue delayQueue() {
return QueueBuilder.durable(getRetry().getQueue()).build();
}
/**
* 聲明延遲交換機：必須使用插件類型 x-delayed-message，并聲明延遲基礎(chǔ)類型為 direct
*/
@Bean
public CustomExchange delayExchange() {
Map<String, Object> args = new HashMap<>();
args.put("x-delayed-type", "direct");
return new CustomExchange(
getRetry().getExchange(), // 名稱
"x-delayed-message", // 類型（延遲消息插件）
true, // durable
false, // auto-delete
args // 參數(shù)：聲明 delayed 類型為 direct
);
}
/**
* 綁定延遲隊列到延遲交換機
*/
@Bean
public Binding delayBinding() {
return BindingBuilder.bind(delayQueue())
.to(delayExchange())
.with(getRetry().getRoutingKey())
.noargs();
}?? 發(fā)送延時消息
/**
* 默認延遲 30 分鐘（1800000 毫秒）
*/
public void sendDelayedTask(String message) {
this.sendDelayedTask(message, 30 * 60 * 1000);
}
/**
* 發(fā)送延遲消息
*/
public void sendDelayedTask(String message, long delayMillis) {
MessageProperties properties = new MessageProperties();
properties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
properties.setHeader("x-delay", delayMillis); // 設(shè)置延遲時間（單位：毫秒）
Message amqpMessage = new Message(message.getBytes(StandardCharsets.UTF_8), properties);
rabbitTemplate.send(
rabbitMqProperties.getConfig().getRetry().getExchange(),
rabbitMqProperties.getConfig().getRetry().getRoutingKey(),
amqpMessage
);
log.info("延遲任務(wù)已發(fā)送，延遲 {} s 后投遞: {}", delayMillis/1000, message);
}?? 五、注意事項
- 插件啟用后，RabbitMQ 會新增一種交換機類型
x-delayed-message - 不兼容 RabbitMQ 自帶的 TTL + DLX 延遲實現(xiàn)方案
- 插件僅支持設(shè)置 發(fā)送時延遲，不支持基于隊列統(tǒng)一延遲
- 插件不支持所有 AMQP 客戶端（需顯式支持 header 設(shè)置的客戶端）
?? 六、Web 管理界面配置示例
你也可以通過 RabbitMQ 的 Web 控制臺：
- 創(chuàng)建交換機類型為
x-delayed-message - 設(shè)置參數(shù)
x-delayed-type = direct - 綁定隊列
- 消息發(fā)布時設(shè)置 header：
x-delay: 10000（單位 ms）
?? 七、延時隊列 VS RabbitMQ 原生 TTL 實現(xiàn)
| 方案 | 支持粒度 | 精準(zhǔn)控制 | 依賴 DLX | 靈活性 | 復(fù)雜度 |
|---|---|---|---|---|---|
| 原生 TTL + 死信隊列 | 隊列級 / 消息級 | 一般 | 是 | 中等 | 中等 |
| 延時插件 rabbitmq_delayed_message_exchange | 消息級 | 高 | 否 | 高 | 低 |
? 八、常見問題 FAQ
1. 插件安裝后沒有效果？
- 檢查是否重啟 RabbitMQ
- 檢查交換機類型是否正確設(shè)置為
x-delayed-message - 檢查消息是否設(shè)置了 header：
x-delay
2. 插件是否與集群兼容？
支持，只需確保每個節(jié)點都安裝啟用了插件。
?? 總結(jié)
通過安裝 rabbitmq_delayed_message_exchange 插件，RabbitMQ 擁有了真正意義上的“消息級”延遲投遞功能，無需依賴死信隊列和 TTL，極大簡化了延時場景的開發(fā)與維護工作。
到此這篇關(guān)于RabbitMQ 延時隊列插件安裝與使用示例詳解(基于 Delayed Message Plugin)的文章就介紹到這了,更多相關(guān)RabbitMQ 延時隊列插件內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java并發(fā)系列之AbstractQueuedSynchronizer源碼分析（共享模式）
這篇文章主要為大家詳細介紹了Java并發(fā)系列之AbstractQueuedSynchronizer源碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-02-02
一般的應(yīng)用程序不會涉及到 Reference 編程， 但是了解這些知識會對理解 GC 的工作原理以及性能調(diào)優(yōu)有一定幫助，在實現(xiàn)一些基礎(chǔ)性設(shè)施比如緩存時也可能會用到，希望本文能有所幫助2013-09-09
本文主要介紹了Spring嵌套事務(wù)是怎么回滾的，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-11-11
這篇文章主要介紹了Java中的Classloader的運行機制,包括從JVM方面講解類加載器的委托機制等,需要的朋友可以參考下2015-11-11
Spring主配置文件(applicationContext.xml) 導(dǎo)入約束詳解
在本篇文章里我們給各位整理的是關(guān)于Spring主配置文件(applicationContext.xml) 導(dǎo)入約束的相關(guān)知識點內(nèi)容，需要參考下。2019-08-08
這篇文章主要介紹了Java字符串split方法的坑及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-12-12
在Java中實現(xiàn)隨機抽獎的方法,通常我們會使用java.util.Random類來生成隨機數(shù),然后基于這些隨機數(shù)來選擇中獎?wù)?以下將給出幾種常見的隨機抽獎實現(xiàn)方式,需要的朋友可以參考下2024-09-09
這篇文章主要介紹了java使用Graphics2D繪圖/畫圖方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
java為什么會出現(xiàn)精度丟失這種現(xiàn)象你知道嗎
這篇文章主要介紹了Java精度丟失的問題，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下，希望能夠給你帶來幫助2021-08-08
詳解Java接口簽名(Signature)實現(xiàn)方案
這篇文章主要介紹了Java接口簽名(Signature)實現(xiàn)方案?,本文給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-01-01