RabbitMQ实现延迟消息的方式-死信队列、延迟队列和惰性队列

当一条消息因为一些原因无法被成功消费,那么这这条消息就叫做死信,如果包含死信的队列配置了dead-letter-exchange属性指定了一个交换机,队列中的死信都会投递到这个交换机内,这个交换机就叫死信交换机,死信交换机再绑定一个队列,死信最终会进入到这个存放死信的队列,这个专门存放死信的队列成为死信队列。消息会成为死信原因会有很多。

比如消费者使用basic.reject或basic.nack声明消费失败,消息的requeue重入队参数设置为false。在失败重试策略中,默认的RejectAndDontRequeueRecoverer会在本地重试次数耗尽后,发送reject给RabbitMQ,消息变成死信,被丢弃。

还比如消息是一个过期消息,超时了无人进行消费。原因是因为消息在队列中是可以设置生存时间的,即TTL(Time To Live生存时间值)。死信的产生,可能情况就TTL的设置分为两种情况:

1.队列设置超时时间,进入队列后超过ttl队列超时时间,消息会变为死信

2.消息设置了超时时间,队列接收到消息后超过ttl消息超时时间,消息会变为死信

上述两者都设置了,以时间小的为准(白话理解:尽可能使时间超时)

再比如要投递的队列消息满了,无法投递。

延迟队列模式:利用TTL结合死信交换机,发送消息后,消费者延迟收到消息的效果。延迟队列的应用很常用,比如延迟发送短信,用户下单在规定时间内未支付会自动取消订单,预约工作会议指定时间后自动通知参会人员等等。

使用RabbitMQ的延迟队列需要使用插件DelayExchange,并且需要将交换机声明为delayed类型。当消息发送到delayExchange延迟交换机时,会判断消息是否具备x-delay属性,如果属性具备说明是延迟消息,将消息持久化到硬盘,读取x-delay值,作为延迟时间。x-delay时间到期后,重新投递消息到指定队列中。

Lazy Queues惰性队列,惰性队列在接收到消息后会直接存入到磁盘中(而非内存),并且在消费者要消费消息时才会从磁盘中读取到并加载到内存,基于这个特性多以惰性队列支持百万条消息的存储。可用于解决消息堆积问题(当生产者发送消息的速度超过消费者处理消息的速度,会导致队列中的消息堆积,直到队列存储消息达到上限,达到上限后再发送的消息就会成为死信,可能会被丢弃,这就是消息堆积问题)(解决消息堆积问题还可以增加消费者,提高消费速度来解决,但是惰性队列思路,将消息持久化到硬盘上提高堆积上限更具有实际意义)。

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

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

相关文章

随机过程及应用学习笔记(四) 马尔可夫过程

马尔可夫过程是理论上和实际应用中都十分重要的一类随机过程。 目录 前言 一、马尔可夫过程的概念 二、离散参数马氏链 1 定义 2 齐次马尔可夫链 3 齐次马尔可夫链的性质 三、齐次马尔可夫链状态的分类 四、有限马尔可夫链 五、状态的周期性 六、极限定理 七、生灭过…

【洛谷 B3614】【模板】栈 题解(栈+STL)

【模板】栈 题目描述 请你实现一个栈(stack),支持如下操作: push(x):向栈中加入一个数 x x x。pop():将栈顶弹出。如果此时栈为空则不进行弹出操作,输出 Empty。query():输出栈顶…

接口测试方法论

第1章 测试那点事 单元测试》接口测试》界面测试 接口就是包含特定输入和特定输出的一套逻辑处理单元,用户无须知晓接口的内部实现逻辑,这也可以称为接口的黑河处理逻辑。因为服务对象不同,接口又可分为两种:一种是系统或服务的…

K8S集群实践之十:虚拟机部署阶段性总结

目录 1. 说明: 2. 安装准备 2.1 每个节点设置双网卡,一卡做网桥(外部访问),一卡做NAT(集群内网访问) 2.2 准备一个可用的代理服务器 3. 由于虚拟机崩溃(停电,宿主机…

VBA技术资料MF119:数据验证的添加与删除

我给VBA的定义:VBA是个人小型自动化处理的有效工具。利用好了,可以大大提高自己的工作效率,而且可以提高数据的准确度。“VBA语言専攻”提供的教程一共九套,分为初级、中级、高级三大部分,教程是对VBA的系统讲解&#…

《苍穹外卖》知识梳理p7-用户下单与模拟微信支付

用户下单与微信支付 一.用户下单 1.1 订单表的设计 订单功能是一个核心的功能; 需要使用2张表: 1.订单表:记录一些订单信息,比如收货人,收获地址,支付金额,下单时间等; 2.订单详情…

GitLab配置SSHKey

段落一:什么是SSH密钥 SSH(Secure Shell)是一种网络协议,用于安全地远程登录和执行命令。SSH密钥是一种用于身份验证的加密文件,它允许您在与远程服务器通信时,无需输入密码即可进行认证。在GitLab中配置S…

Kibana:如何嵌入 Kibana 仪表板

作者:Carly Richmond 像我这样的前端工程师经常提出的要求是将 Kibana 等来源的现有仪表板嵌入到 JavaScript Web 应用程序中。 这是我必须多次执行的任务,因为我们希望快速部署用户生成的视图或允许用户控制给定的视图。 从我们从精彩的开发者社区收到的…

JVM(3)高级篇

1 GraalVM 1.1 什么是GraalVM GraalVM是Oracle官方推出的一款高性能JDK,使用它享受比OpenJDK或者OracleJDK更好的性能。 GraalVM的官方网址:https://www.graalvm.org/ 官方标语:Build faster, smaller, leaner applications。 更低的CPU、内…

Sora技术报告——Video generation models as world simulators

文章目录 1. 视频生成模型,可以视为一个世界模拟器2. 技术内容2.1 将可视数据转换成patches2.2 视频压缩网络2.3 Spacetime Latent Patches2.4 Scaling transformers 用于视频生成2.5 可变的持续时间,分辨率,宽高比2.6 抽样的灵活性2.7 改进框…

Invalid DataSize: cannot convert ‘30Mb‘ to Long

Invalid DataSize: cannot convert 30Mb to Long servlet:multipart:max-file-size: 30MBmax-request-size: 30MB

【研究生复试】计算机软件工程人工智能研究生复试——资料整理(速记版)——计算机网络

1、JAVA 2、计算机网络 3、计算机体系结构 4、数据库 5、计算机租场原理 6、软件工程 7、大数据 8、英文 自我介绍 2. 计算机网络 1. TCP如何解决丢包和乱序? 序列号:TCP所传送的每段数据都有标有序列号,避免乱序问题发送端确认应答、超时…

反向迭代器------封装的力量

目录 一、list封装中模板参数Ref和Ptr的理解 二、反向迭代器的实现 一、list封装中模板参数Ref和Ptr的理解 对于反向迭代器,是我们在前面STL模拟实现中留下的一个问题。在之前的文章中,我们极大程度上的利用了模板,从而减少了许多的代码&…

09、全文检索 -- Solr -- SpringBoot 整合 Spring Data Solr (生成DAO组件 和 实现自定义查询方法)

目录 SpringBoot 整合 Spring Data SolrSpring Data Solr的功能(生成DAO组件):Spring Data Solr大致包括如下几方面功能:Query查询(属于半自动)代码演示:1、演示通过dao组件来保存文档1、实体类…

B3668 [语言月赛202210] 应急食品

题目背景 派蒙是不是应急食品?不同的旅行者有不同的答案。 题目描述 派蒙是不是应急食品,是每一个旅行者必须完成的选择题。 选项 A 为 派蒙是应急食品; 选项 B 为 派蒙不是应急食品。 旅行者一定是正确的,现在告诉你某个旅行…

SpringCloud之Feign发送Http请求

文章目录 http客户端Feign使用步骤自定义Feign的配置Feign的性能优化Feign的性能优化-连接池配置 Feign的最佳实践 http客户端Feign Feign的介绍: Feign是一个声明式的http客户端,官方地址:https:/github.com/OpenFeign/feign 其作用就是帮助…

人群异常聚集监测系统-聚众行为检测与识别算法---豌豆云

聚众识别系统对指定区域进行实时监测,当监测到人群大量聚集、达到设置上限时,立即告警及时疏散。 旅游业作为国民经济战略性支柱产业,随着客流量不断增加,旅游景区和一些旅游城市的管理和服务面临着前所未有的挑战: …

上海历年社保平均工资

标签: 上海历年平均工资; 上海历年社保最低工资; 备注: 上海最低社保按平均工资60%缴纳。上海社保最高基数为平均工资的3倍。公司裁员或者公司违约解除劳动合同,每月补偿工资不超过平均工资的3倍。 年份平均工资&…

使用 Spring Data JPA 和 Mybatis 结合的方式进行分页查询

文章目录 1. Spring Data JPA 和 Mybatis 操作数据库的区别1.1 Spring Data JPA1.2 Mybatis 2. 使用 Spring Data JPA 和 Mybatis 结合的方式进行分页查询2.1 创建实体类2.2 创建实体操作的 Repository 接口2.3 创建 Mybatis 的 Mapper 接口2.4 创建 Mybatis 的 Mapper XML 文件…