當前位置：首頁 > 科技 > 軟件

阿里面試：RabbitMQ如何實現延遲隊列？

來源：責編：時間：2024-04-28 08:55:17 158觀看

導讀延遲隊列是指當消息被發送以后，并不是立即執行，而是等待特定的時間后，消費者才會執行該消息。延遲隊列的使用場景有以下幾種：未按時支付的訂單，30 分鐘過期之后取消訂單。給活躍度比較低的用戶間隔 N 天之后推送消息，提高活

延遲隊列是指當消息被發送以后，并不是立即執行，而是等待特定的時間后，消費者才會執行該消息。延遲隊列的使用場景有以下幾種：

未按時支付的訂單，30 分鐘過期之后取消訂單。
給活躍度比較低的用戶間隔 N 天之后推送消息，提高活躍度。
新注冊會員的用戶，等待幾分鐘之后發送歡迎郵件等。

1.如何實現延遲隊列？

延遲隊列有以下兩種實現方式：

通過消息過期后進入死信交換器，再由交換器轉發到延遲消費隊列，實現延遲功能；
使用官方提供的延遲插件實現延遲功能。

早期，大部分公司都會采用第一種方式，而隨著 RabbitMQ 3.5.7（2015 年底發布）的延遲插件的發布，因為其使用更簡單、更方便，所以它現在才是大家普通會采用的，實現延遲隊列的方式，所以本文也只講第二種方式。

2.實現延遲隊列

2.1 安裝并啟動延遲隊列

2.1.1 下載延遲插件

https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases

注意：需要根據你自己的 RabbitMQ 服務器端版本選擇相同版本的延遲插件，可以在 RabbitMQ 控制臺查看：

2.1.2 將插件放到插件目錄

接下來，將上一步下載的插件放到 RabbitMQ 服務器安裝目錄，如果是 docker，使用一下命令復制：

docker cp 宿主機文件容器名稱或ID:容器目錄

如下圖所示：

之后，進入 docker 容器，查看插件中是否包含延遲隊列：

docker exec -it 容器名稱或ID /bin/bash rabbitmq-plugins list

如下圖所示：

2.1.3 啟動插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

如下圖所示：

2.1.4 重啟RabbitMQ服務

安裝完 RabbitMQ 插件之后，需要重啟 RabbitMQ 服務才能生效。如果使用的是 Docker，只需要重啟 Docker 容器即可：

docker restart 容器名稱或ID

如下圖所示：

2.1.5 驗收結果

在 RabbitMQ 控制臺查看，新建交換機時是否有延遲消息選項，如果有就說明延遲消息插件已經正常運行了，如下圖所示：

2.1.6 手動創建延遲交換器（可選）

此步驟可選（非必須），因為某些版本下通過程序創建延遲交換器可能會出錯，如果出錯了，手動創建延遲隊列即可，如下圖所示：

2.2 編寫延遲消息實現代碼

2.2.1 配置交換器和隊列

import org.springframework.context.annotation.Configuration;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bean;/** * 延遲交換器和隊列 */@Configurationpublic class DelayedExchangeConfig {    public static final String EXCHANGE_NAME = "myDelayedExchange";    public static final String QUEUE_NAME = "delayed.queue";    public static final String ROUTING_KEY = "delayed.routing.key";    @Bean    public CustomExchange delayedExchange() {        return new CustomExchange(EXCHANGE_NAME,                "x-delayed-message", // 消息類型                true, // 是否持久化                false); // 是否自動刪除    }    @Bean    public Queue delayedQueue() {        return QueueBuilder.durable(QUEUE_NAME)                .withArgument("x-delayed-type", "direct")                .build();    }    @Bean    public Binding delayedBinding(Queue delayedQueue,CustomExchange delayedExchange) {        return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with(ROUTING_KEY).noargs();    }}

2.1.2 定義消息發送方法

import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;@Componentpublic class DelayedMessageProducer {    @Autowired    private RabbitTemplate rabbitTemplate;    @Scheduled(fixedDelay = 5000)    public void sendDelayedMessage(String message) {        rabbitTemplate.convertAndSend(DelayedExchangeConfig.EXCHANGE_NAME,                DelayedExchangeConfig.ROUTING_KEY,                message,                messagePostProcessor -> {                    messagePostProcessor.getMessageProperties().setDelay(10000); // 設置延遲時間，單位毫秒                    return messagePostProcessor;                });    }}

2.1.3 發送延遲消息

import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.RestController;@RestController@RequestMapping("/delayed")public class DelayedMessageController {    @Autowired    private DelayedMessageProducer delayedMessageProducer;    @GetMapping("/send")    public String sendDirectMessage(@RequestParam String message) {        delayedMessageProducer.sendDelayedMessage(message);        return "Delayed message sent to Exchange: " + message;    }}

2.1.4 接收延遲消息

import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Componentpublic class DelayedMessageConsumer {    @RabbitListener(queues = DelayedExchangeConfig.QUEUE_NAME)    public void receiveDelayedMessage(String message) {        System.out.println("Received delayed message: " + message);    }}

PS：獲取本文延遲隊列的實現 Demo，請加我：GG_Stone【備注：延遲隊列】

小結

實現 RabbitMQ 延遲隊列目前主流的實現方式，是采用官方提供的延遲插件來實現。而延遲插件需要先下載插件、然后配置并重啟 RabbitMQ 服務，之后就可以通過編寫代碼的方式實現延遲隊列了。

本文鏈接：http://www.tebozhan.com/showinfo-26-86060-0.html阿里面試：RabbitMQ如何實現延遲隊列？

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

上一篇：電視產業躍升：AI 芯片推動三星電視再度提至新高度

下一篇：原理剖析| Kafka Exactly Once 語義實現原理：冪等性與事務消息

標簽：

熱門焦點

vivo TWS Air開箱體驗：真輕臻好聽

在vivo S15系列新機的發布會上，vivo的最新款真無線藍牙耳機vivo TWS Air也一同發布，本次就這款耳機新品給大家帶來一個簡單的分享。外包裝盒上，vivo TWS Air保持了vivo自家產
一加首款折疊屏！一加Open渲染圖出爐：罕見單手可握小尺寸

8月5日消息，此前就有爆料稱，一加首款折疊屏手機將會在第三季度上市，如今隨著時間臨近，新機的各種消息也開始浮出水面。據悉，這款新機將會被命名為“On
破圈是B站頭上的緊箍咒

來源 | 光子星球撰文 | 吳坤諺編輯 | 吳先之每年的暑期檔都少不了瞄準追劇女孩們的古偶劇集，2021年有優酷的《山河令》，2022年有愛奇藝的《蒼蘭訣》，今年卻輪到小破站抓住了追
騰訊VS網易，最卷游戲暑期檔，誰能笑到最后？

作者：無銹缽來源：財經無忌7月16日晚，上海1862時尚藝術中心。伴隨著幻象的精準命中，碩大的熒幕之上，比分被定格在了14：12，被寄予厚望的EDG戰隊以絕對的優勢戰勝了BLG戰隊，拿下了總決
年輕人的“職場羞恥感”，無處不在

作者：馮曉亭陶淘李欣張琳馬舒葉來源：燃次元“人在職場，應該選擇什么樣的著裝？”近日，在網絡上，一個與著裝相關的帖子引發關注，在該帖子里，一位在高級寫字樓亞洲金
認真聊聊東方甄選：如何告別低垂的果實

來源：山核桃作者：財經無忌爆火一年后，俞敏洪和他的東方甄選依舊是頗受外界關心的“網紅”。7月5日至9日，為期5天的東方甄選“甘肅行”首次在自有App內直播，
華為和江淮汽車合作開發百萬元問界MPV？雙方回應來了

8月1日消息，郭明錤今天在社交平臺發文稱，華為正在和江淮汽車合作，開發售價在100萬元的問界MPV，預計在2024年第2季度量產，銷量目標為上市首年交付5萬輛。
三星顯示已開始為AR設備研發硅基LED微顯示屏

7月18日消息，據外媒報道，隨著蘋果首款頭顯產品Vision Pro在6月份正式推出，AR/VR/MR等頭顯產品也就將成為各大公司下一個重要的競爭領域，對顯示屏這一關
DRAM存儲器10月價格下跌，NAND閃存本月價格與上月持平

10月30日，據韓國媒體消息，自今年年初以來一直在上漲的 DRAM 存儲器的交易價格僅在本月就下跌了近 10％，此次是全年首次降價，而NAND 閃存本月價格與上月持平。市

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

阿里面試：RabbitMQ如何實現延遲隊列？

1.如何實現延遲隊列？

2.實現延遲隊列

2.1 安裝并啟動延遲隊列

2.1.1 下載延遲插件

2.1.2 將插件放到插件目錄

2.1.3 啟動插件

2.1.4 重啟RabbitMQ服務

2.1.5 驗收結果

2.1.6 手動創建延遲交換器（可選）

2.2 編寫延遲消息實現代碼

2.2.1 配置交換器和隊列

2.1.2 定義消息發送方法

2.1.3 發送延遲消息

2.1.4 接收延遲消息

小結

vivo TWS Air開箱體驗：真輕臻好聽

一加首款折疊屏！一加Open渲染圖出爐：罕見單手可握小尺寸

破圈是B站頭上的緊箍咒

騰訊VS網易，最卷游戲暑期檔，誰能笑到最后？

年輕人的“職場羞恥感”，無處不在

認真聊聊東方甄選：如何告別低垂的果實

華為和江淮汽車合作開發百萬元問界MPV？雙方回應來了

三星顯示已開始為AR設備研發硅基LED微顯示屏

DRAM存儲器10月價格下跌，NAND閃存本月價格與上月持平

最新推薦

猜你喜歡

熱門推薦

相關資訊