当前位置: 首页 > news >正文

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.lryc.cn/news/301690.html

相关文章:

  • 【运维测试】测试理论+工具总结笔记第1篇:测试理论的主要内容(已分享,附代码)
  • 【C语言】实现队列
  • 【友塔笔试面试复盘】八边形取反问题
  • GB 18585-2023 壁纸中有害物质限量
  • 全面的ASP.NET Core Blazor简介和快速入门
  • HGAME 2024 WEEK2 Crypto WP
  • Postman轻松签名,让SHA256withRSA保驾护航!
  • C#面:简述装箱和拆箱
  • 【Kubernetes in Action笔记】1.快速开始
  • 踩坑实录(Fourth Day)
  • 【python】网络爬虫与信息提取--requests库
  • 洛谷 P8627 [蓝桥杯 2015 省 A] 饮料换购
  • Academic Inquiry|投稿状态分享(ACS,Wiley,RSC,Elsevier,MDPI,Springer Nature出版社)
  • 1+X运维试题样卷C卷(初级)
  • Spring学习笔记(二)Spring的控制反转(设计原则)与依赖注入(设计模式)
  • MySQL 基础知识(四)之表操作
  • 计算机网络——10FTP
  • javascript中的this指向
  • WebServer 之 http连接处理(下)
  • Android电量相关知识
  • 【Java多线程】线程中几个常见的属性以及状态
  • 鸿蒙OS跨进程IPC与RPC通信
  • Effective Objective-C 学习(三)
  • 蓝桥杯备赛攻略
  • react反向代理
  • 债券专题二:可转债估值-二叉树模型
  • 【闲谈】开源软件的崛起与影响
  • 【教程】Linux使用aria2c多线程满速下载
  • 【漏洞复现】蓝网科技临床浏览系统信息泄露漏洞
  • JSON转换List<Map<String, Object>>、Map<String, Object>