消息队列RabbitMQ版原生延迟消息实现

墨蓝 2022-11-12 04:16 154阅读 0赞

**RabbitMQ的延迟消息实现方案如下**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]  
图片来源地址：[https://help.aliyun.com/document\_detail/148083.html?spm=5176.11065259.1996646101.searchclickresult.44d15ab6tjjNNQ\#section-rpd-mjh-kee][https_help.aliyun.com_document_detail_148083.html_spm_5176.11065259.1996646101.searchclickresult.44d15ab6tjjNNQ_section-rpd-mjh-kee]

今天，我们来实现的就是**消息队列RabbitMQ版**的**原生延迟消息方案**

**核心依赖**

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
        <version>2.3.6.RELEASE</version>
    </dependency>

**代码实现**

@Autowired
    RabbitMessagingTemplate rabbitMessagingTemplate;
    
    
    Map<String, Object> headers = new HashMap<>(16);
    headers.put("delay", 延迟时长（单位毫秒）);
    rabbitMessagingTemplate.convertAndSend(队列名, 消息, headers);

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]: /images/20221022/5e286ad13fce4c8f80c7690c50de068c.png
[https_help.aliyun.com_document_detail_148083.html_spm_5176.11065259.1996646101.searchclickresult.44d15ab6tjjNNQ_section-rpd-mjh-kee]: https://help.aliyun.com/document_detail/148083.html?spm=5176.11065259.1996646101.searchclickresult.44d15ab6tjjNNQ#section-rpd-mjh-kee

发表评论取消回复

表情：

评论列表（有 0 条评论，154人围观）

还没有评论，来说两句吧...

相关阅读

相关【RabbitMQ】消息队列之 RabbitMQ 消息队列简介

`RabbitMQ` 是高级消息队列协议（`AMQP`）的开源消息代理软件。 `RabbitMQ` 服务器是用 `Erlang` 语言编写的，消息系统允许软件、应用相互连接和

叁歲伎倆/ 2024年04月08日 12:45/ 0 赞/ 21 阅读

相关 rabbitmq实现延迟消息

pom <dependency> <groupId>org.springframework.boot</groupId>

小鱼儿/ 2022年12月23日 13:28/ 0 赞/ 77 阅读

相关消息队列RabbitMQ版原生延迟消息实现

RabbitMQ的延迟消息实现方案如下 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR

墨蓝/ 2022年11月12日 04:16/ 0 赞/ 155 阅读

相关 SpringBoot 项目中集成RabbitMQ消息队列，发送消息，监听消息,延迟队列

1.添加依赖包 > <dependency> > <groupId>org.springframework.boot</groupId> >

分手后的思念是犯贱/ 2022年11月06日 01:00/ 0 赞/ 163 阅读

相关回顾RabbitMQ实现消息延迟

一概述在RabbitMQ中，默认情况下，消息在没有设置消息过期的参数的时候是不会过期的，即使消息没有被消费掉，消息会一直存储在队列中。二队列消息存活时间TTL

我不是女神ヾ/ 2022年09月17日 03:08/ 0 赞/ 79 阅读

相关消息中间件 - RabbitMQ延迟队列

一、概念延时队列的内部是有序的，最重要的特性就体现在它的延时属性上，延时队列中的元素是希望在指定时间到了以后或之前取出和处理，简单来说，延时队列就是用来存放需要在指

雨点打透心脏的1/2处/ 2022年09月08日 00:20/ 0 赞/ 174 阅读

相关 RabbitMQ：基于分布式消息队列 RabbitMQ 实现延迟队列

> RabbitMQ：基于分布式消息队列 RabbitMQ 实现延迟队列 [【参考文献】：基于 rabbitmq 实现延迟队列][rabbitmq] 流程图：

不念不忘少年蓝@/ 2022年05月18日 10:23/ 0 赞/ 245 阅读

相关 RabbitMQ 延迟队列，消息延迟推送

目录 [应用场景][Link 1] [消息延迟推送的实现][Link 2] [测试结果][Link 3] --------------------

野性酷女/ 2021年12月14日 21:25/ 0 赞/ 310 阅读

相关 Spring Boot+RabbitMQ 实现延迟消息实现完整版，实用！

点击上方 [Java后端][Java]，选择设为星标优质文章，及时送达 -------------------- 作者：Sam哥哥 blog.csdn.net/li

梦里梦外;/ 2021年08月30日 11:31/ 0 赞/ 314 阅读

相关 RabbitMQ实现消息队列延迟功能

要实现 RabbitMQ 的消息队列延迟功能，一般采用官方提供的插件 “rabbitmq\_delayed\_message\_exchange” 来实现。但 RabbitMQ

梦里梦外;/ 2021年07月24日 23:39/ 0 赞/ 567 阅读