RabbitMQ 高级特性——TTL

在这里插入图片描述

文章目录

  • 前言
  • TTL
    • 设置消息的 TTL
    • 设置队列的 TTL

前言

对于前面讲到的重试机制中,当确认策略为 MANUAL 手动确认的时候,如果消费者出现了程序逻辑错误,那么消息就无法被争取处理,那么就会执行 basicNack 方法,如果我们的 basicNack 方法的第三个参数的值为 true 的话,在只有这一个消费者的情况下,这个消息就会反复重新进入队列并且返回投递给这个消费者,那么在这个队列中的后面的消息就无法被提递给消费者,这样就导致了消息积压,那么如何处理这个问题呢?答案就是为消息或者队列设置 TTL(ime-To-Live)生存时间,当消息或者队列存在一段时间后就会被丢弃或者投递到死信队列中。那么这篇文章将介绍 RabbitMQ 中的 TTL。

TTL

TTL(Time-to-Live)过期时间,RabibtMQ 可以对队列和消息设置 TTL。当消息到达存活时间之后,如果该消息还没有被消费,那么就会被自动处理掉。

就是我们平时购物的时候,如果下单超过 24 消失还没有付款的话,订单就会被自动取消。

设置消息的 TTL

RabbitMQ 有两种设置 TTL 的方法,一是设置队列的 TTL,队列中的所有消息都有相同的过期时间,而就是对消息单独设置 TTL,每条消息的 TTL 可以不同。如果两种方式一起使用,则过期时间为两者的较小值。

先来看看如何对消息设置 TTL。

public static final String TTL_EXCHANGE = "ttl.exchange";
public static final String TTL_QUEUE = "ttl.queue";
@Bean("ttlExchange")
public DirectExchange ttlExchange() {return ExchangeBuilder.directExchange(Constants.TTL_EXCHANGE).durable(true).build();
}@Bean("ttlQueue")
public Queue ttlQueue() {return QueueBuilder.durable(Constants.TTL_QUEUE).build();
}@Bean("ttlBinding")
public Binding ttlBinding(@Qualifier("ttlQueue") Queue queue,@Qualifier("ttlExchange") DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with("ttl");
}
@RequestMapping("/ttl")
public String ttl() {//设置消息的过期时间MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {@Overridepublic Message postProcessMessage(Message message) throws AmqpException {message.getMessageProperties().setExpiration("10000");return message;}};rabbitTemplate.convertAndSend(Constants.TTL_EXCHANGE,"ttl","rabbitmq ttl",messagePostProcessor);return "消息发送成功";
}

这里消费者的代码我们就不写了,就通过 RabbitMQ 的管理页面观察消息的过期:

在这里插入图片描述

启动之后,并且让生产者生产消息,可以发现队列中已经存在一条消息了,然后等待一段时间再观察会发现刚刚生产的消息已经不存在了:

在这里插入图片描述
这是设置消息的过期时间,那么下面我们来看看如何设置队列的时间。

设置队列的 TTL

设置队列的 TTL 是在我们声明队列的时候设置的,声明队列的时候加入 x-message-ttl 参数实现的,单位是毫秒。

//队列设置TTL的第一种方法
@Bean("ttlQueue")
public Queue ttlQueue() {return QueueBuilder.durable(Constants.TTL_QUEUE).ttl(20*1000).build();
}//队列设置TTL的第二种方法
@Bean("ttlQueue")
public Queue ttlQueue() {Map<String, Object> arguments = new HashMap<>();arguments.put("x-message-ttl",20000);return QueueBuilder.durable(Constants.TTL_QUEUE).withArguments(arguments).build();
}//也可以将map平铺出来
@Bean("ttlQueue")
public Queue ttlQueue() {Map<String, Object> arguments = new HashMap<>();arguments.put("x-message-ttl",20000);return QueueBuilder.durable(Constants.TTL_QUEUE).withArgument("x-message-ttl",20000).build();
}

这里创建两个队列,一个是设置了 TTL 的队列,一个是没有设置 TTL 的对了,然后看两个队列的差别:

@Bean("ttlExchange")
public DirectExchange ttlExchange() {return ExchangeBuilder.directExchange(Constants.TTL_EXCHANGE).durable(true).build();
}@Bean("ttlQueue")
public Queue ttlQueue() {Map<String, Object> arguments = new HashMap<>();arguments.put("x-message-ttl",20000);return QueueBuilder.durable(Constants.TTL_QUEUE).withArgument("x-message-ttl",20000).build();
}@Bean("normalQueue")
public Queue normalQueue() {return QueueBuilder.durable(Constants.NORMAL_QUEUE).build();
}@Bean("ttlBinding")
public Binding ttlBinding(@Qualifier("ttlQueue") Queue queue,@Qualifier("ttlExchange") DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with("ttl");
}@Bean("ttlBinding2")
public Binding ttlBinding2(@Qualifier("normalQueue") Queue queue,@Qualifier("ttlExchange") DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with("ttl");
}

在这里插入图片描述
在这里插入图片描述

过一段时间之后再观察:

在这里插入图片描述

设置队列的过期时间和设置消息的过期时间的区别

设置队列TTL属性的方法,一旦消息过期,就会从队列中删除。

设置消息TTL的方法,即使消息过期,也不会马上从队列中删除,而是在即将投递到消费者之前进行判定的。

为什么这两种方法处理的方式不一样?

因为设置队列过期时间,队列中已过期的消息肯定在队列头部(假设是按照时间顺序入队的),RabbitMQ只要定期从队头开始扫描是否有过期的消息即可。

而设置消息TTL的方式,每条消息的过期时间不同,如果要删除所有过期消息需要扫描整个队列,这样效率较低。因此,RabbitMQ选择等到此消息即将被消费时再判定是否过期,如果过期再进行删除即可。跟 Redis 中的惰性删除是一个道理。这种方式避免了不必要的全队列扫描,提高了效率。

注意:这里的“即将投递到消费者之前”通常指的是在消息被发送到消费者之前,RabbitMQ会检查该消息是否已过期。如果消息已过期,RabbitMQ会将其删除,不会将其发送给消费者。这种机制确保了消费者不会接收到过期的消息。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/53953.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ClickHouse | 查询

1 ALL 子句 2 ARRAY JOIN 使用别名 :在使用时可以为数组指定别名&#xff0c;数组元素可以通过此别名访问&#xff0c;但数组本身则通过原始名称访问 3 DISTINCT子句 DISTINCT不支持当包含有数组的列 4 FROM子句 FROM 子句指定从以下数据源中读取数据: 1.表 2.子…

hive如何刷新现有分区

hive刷新现有分区的需求&#xff0c;一般出现在你操组分区数据时采用了其他手段&#xff0c;也有极少的情况是有的发行版会删除历史很久的分区&#xff0c;总之各种原因导致的元数据和实际数据的分区对不上。 此时你就可以运行如下语句&#xff0c;让hive去根据实际数据刷新元…

推荐4款2024年大家都在用的高质量翻译器。

翻译器在我们的生活中有着很重要的作用&#xff0c;不管是我们在学习还是工作&#xff0c;生活娱乐&#xff0c;出国旅游等场合都会派上用场&#xff0c;它是我们解决沟通的障碍&#xff0c;提高阅读效率的好帮手。我自己使用的翻译器有很多&#xff0c;可以给大家列举几款特别…

基于微信小程序的商品展示+ssm(lw+演示+源码+运行)

商品展示系统 摘 要 随着我国经济迅速发展&#xff0c;人们对手机的需求越来越大&#xff0c;各种手机软件也都在被广泛应用&#xff0c;但是对于手机进行数据信息管理&#xff0c;对于手机的各种软件也是备受用户的喜爱&#xff0c;微信小程序被用户普遍使用&#xff0c;为方…

微服务配置管理——动态路由

动态路由 网关的路由配置全部是在项目启动时由org.springframework.cloud.gateway.route.CompositeRouteDefinitionLocator在项目启动的时候加载&#xff0c;并且一经加载就会缓存到内存中的路由表内&#xff08;一个Map&#xff09;&#xff0c;不会改变。也不会监听路由变更新…

【大模型】AutoDL部署AI绘图大模型Stable Diffusion使用详解

目录 一、前言 二、AI绘图大模型概述 2.1 AI绘图大模型介绍 2.2 AI绘图大模型特点 2.3 AI绘图大模型优势 三、主流的AI绘图大模型介绍 3.1 Midjourney 3.1.1 Midjourney介绍 3.1.2 Midjourney功能特点 3.1.3 Midjourney使用场景 3.2 Stable Diffusion 3.2.1 Stable …

王道-数据结构

1 设数组data[m]作为循环队列的存储空间,front为队头指针,rear为队尾指针,则执行出队操作后其头指针front值为____ 答案:D 解析:队列的头指针指向队首元素的实际位置,因此出队操作后,头指针需向上移动一个元素的位置。循环队列的容量为m,所以头指针front加1以后,需…

高效的视频压缩标准H.264介绍,以及H.264在视频监控系统中的应用

目录 一、概述 二、 工作原理 三、技术特点与优势 1、高效压缩率 2、高质量视频 3、错误恢复能力 4、灵活性 四、编解码过程 1、编码过程 2、解码过程 五、帧类型与结构 1、I帧 2、P帧 3、B帧 六、应用与优势 1、节省存储空间和带宽 2、提高视频质量 3、适应…

使用nest+typeorm框架写数据库导致mysql的binlog暴增记录

这 两天用nesttypeorm写了一个商城&#xff0c;上线后mysql日志binlog两天就达到了10几个G&#xff0c;排查结果如下&#xff1a; 有个功能是定时遍历所有未签收的订单&#xff0c;看看是否到了自动签收时间&#xff0c;如果到了&#xff0c;就把订单状态设置成已签收。 代码…

mysql 05 InnoDB数据页结构

01.数据页结构的快速浏览 前边我们简单提了一下 页 的概念&#xff0c;它是 InnoDB 管理存储空间的基本单位&#xff0c;一个页的大小一般是 16KB 。InnoDB 为了不同的目的而设计了许多种不同类型的 页 &#xff0c;比如存放表空间头部信息的页&#xff0c;存放 Insert Buffer…

《C++设计新思维-泛型编程与设计模式之应用》阅读记录

目录 写在前面policy和policy class的认识 写在前面 这本书是2003年出版的&#xff0c;大佬侯捷翻译的&#xff0c;21年前的书了&#xff0c;最近打算翻一翻。 看这种技术书籍&#xff0c;特别是简历理论体系的书籍&#xff0c;最好看纸质书。 本书从根本上展示了generic pa…

赛氪作媒体支持单位受邀参加首届科普翻译与跨学科专业学术研讨会

2024年9月22日&#xff0c;正值全国科普日之际&#xff0c;首届科普翻译与跨学科专业学术研讨会在上海健康与营养研究所信息中心励志厅成功举行并圆满结束。此次研讨会汇聚了来自全国各地的近60名专家学者、学界及企业界代表&#xff0c;共同探讨科普翻译与跨学科专业的发展。作…

LLM - 使用 vLLM 部署 Qwen2-VL 多模态大模型 (配置 FlashAttention) 教程

欢迎关注我的CSDN&#xff1a;https://spike.blog.csdn.net/ 本文地址&#xff1a;https://spike.blog.csdn.net/article/details/142528967 免责声明&#xff1a;本文来源于个人知识与公开资料&#xff0c;仅用于学术交流&#xff0c;欢迎讨论&#xff0c;不支持转载。 vLLM 用…

ASCII码对应表

刚开始基础计算机编程的时候&#xff0c;学习的是二进制、十进制、十六进制。 十进制是生活习惯中最常用的计数方法&#xff0c;也是我们计数的思维逻辑。 后来接触了计算机基础&#xff0c;我们知道计算机都是用二进制表示的&#xff0c;但是这种表示方法让人理解很困难。 …

wordpress迁移到别的服务器

wordpress论坛网站搭建 于2023/11/16写的该文章 一-配置环境 配置LNMP&#xff08;linuxnginxmysqlphpphpmyadmin&#xff09;环境或者LAMP&#xff08;apache&#xff09; 可以选择集成了这些软件的套件 下载链接&#xff1a;https://www.xp.cn/download.html 手动下载这…

1.1.4 计算机网络的分类

按分布范围分类&#xff1a; 广域网&#xff08;wan&#xff09; 城域网&#xff08;man&#xff09; 局域网&#xff08;lan&#xff09; 个域网&#xff08;pan&#xff09; 注意&#xff1a;如今局域网几乎采用“以太网技术实现”&#xff0c;因此“以太网”几乎成了“局域…

C#源码安装ZedGraph组件,并且立即演示使用

要想源码安装ZedGraph,那么就需要先找到源码,而源码的来源,显然就是鼎鼎大名的Github: https://github.com/ZedGraph/ZedGraph 下载源码的地址是: https://gitcode.com/gh_mirrors/ze/ZedGraph.git 这样就可以把代码全部下载下来,不过它是支持.net 3.5的版本,现在已经…

努比亚z17努比亚NX563j原厂固件卡刷包下载_刷机ROM固件包下载-原厂ROM固件-安卓刷机固件网

努比亚z17努比亚NX563j原厂固件卡刷包下载_刷机ROM固件包下载-原厂ROM固件-安卓刷机固件网 统版本&#xff1a;官方软件作者&#xff1a;热心网友rom大小&#xff1a;911MB发布日期&#xff1a;2018-12-23 努比亚z17努比亚NX563j原厂固件卡刷包下载_刷机ROM固件包下载-原厂RO…

ScrapeGraphAl AI爬虫

官网&#xff1a;https://scrapegraph-ai.readthedocs.io/en/latest/ from flask import Flask, request, jsonify from scrapegraphai.graphs import SmartScraperGraphapp Flask(__name__)openai_key "sk-xxxxxxxxxxxxxxxxxxxx"graph_config {"llm":…

Android 系统增加ro property

以下都是基于高通平台 一&#xff0c;Android.mk 中添加 新增自己的参考系统的device/qcom/xxxx/xxxx.mk #target specific runtime prop for qspm PRODUCT_PROPERTY_OVERRIDES \ ro.vendor.qspm.enabletrue 二&#xff0c;脚本添加。 build/tools/buildinfo.sh 里面很多…