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

news/发布时间2024/5/18 14:57:15

当一条消息因为一些原因无法被成功消费,那么这这条消息就叫做死信,如果包含死信的队列配置了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.bcls.cn/FPNX/355.shtml

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

相关文章

【C/C++】2024春晚刘谦春晚魔术步骤模拟+暴力破解

在这个特别的除夕夜,我们不仅享受了与家人的温馨团聚,还被电视机前的春节联欢晚会深深吸引。特别是,魔术师刘谦的精彩表演,为我们带来了一场视觉和心灵的盛宴。在我的博客“【C/C】2024春晚刘谦春晚魔术步骤模拟暴力破解”中&…

MySQL基础学习

MySQL基础 注意:本文的图片截图自尚硅谷MySQL笔记。 一:基本概述: 什么是数据库: 数据库是一种用来存储和管理数据的系统。它是一个组织化的数据集合,可以通过计算机系统进行访问、管理和更新。数据库可以存储各种…

13.Qt 文件的读和写,样式表文件的读用

目录 前言: 技能: 内容: 1. 界面 2.信号槽 ①浏览按键 ②保存按键 ③加载样式按键 参考: 前言: 上一篇文章说明了如何弹窗选取文件并在Qlabel中显示文件内容 12.QT文件对话框 文件的弹窗选择-QFileDialog 这篇…

transformer 最简单学习1 输入层embeddings layer

词向量的生成可以通过嵌入层(Embedding Layer)来完成。嵌入层是神经网络中的一种常用层,用于将离散的词索引转换为密集的词向量。以下是一个典型的步骤: 建立词表:首先,需要从训练数据中收集所有的词汇&…

IDEA中的神仙插件——Smart Input (自动切换输入法)

IDEA中的神仙插件——Smart Input (自动切换输入法) 设置 更多功能详见官方文档:Windows版SmartInput使用入门

数据结构-哈夫曼树

介绍 哈夫曼树,指带权路径长度最短的二叉树,通常用于数据压缩中 什么是带权路径长度? 假设有一个结点,我们为它赋值,这个值我们称为权值,那么从根结点到它所在位置,所经历的路径,…

HCIA-HarmonyOS设备开发认证V2.0-IOT硬件子系统-UART

目录 一、UART 概述二、UART 模块相关API三、UART 接口调用实例四、UART HDF驱动开发4.1、开发步骤(待续...) 坚持就有收获 一、UART 概述 UART 是通用异步收发传输器(Universal Asynchronous Receiver/Transmitter)的缩写,是通用串行数据总…

第9讲用户信息修改实现

用户信息修改实现 后端修改用户昵称: /*** 更新用户昵称* param wxUserInfo* param token* return*/ RequestMapping("/updateNickName") public R updateNickName(RequestBody WxUserInfo wxUserInfo,RequestHeader String token){if(StringUtil.isNot…

为什么有的代理IP速度比较慢?

“为什么有的IP代理速度比较慢?”随着数字化时代的不断发展,代理服务成为了许多网络操作的关键环节。然而,有时我们可能会遇到IP代理速度慢的问题,这可能会对我们的网络操作产生影响。让我们一起揭开这个谜团,探寻其中…

Stable Diffusion教程——常用插件安装与测试(一)

前言 随着Stable Diffusion不断演进,越来越多的开发者开始涉足插件开发。尽管网络上存在大量教程,但它们通常零散分布,逐个学习和查找非常耗时,使人感觉每天都在劳累思考。这里总结了Stable Diffusion常用的插件安装与测试方法。…

什么是 Docker 容器?以及操作 Docker 容器相关的命令汇总

镜像仓库常用指令:Docker 镜像仓库是什么?有哪些镜像仓库命令? 镜像常用指令:操作 Docker 镜像的常用命令 1. 什么是容器? 容器是镜像的运行实体。容器是基于镜像创建的可运行实例,并且单独存在&#xff0…

【大数据】Flink on Kubernetes 原理剖析

Flink on Kubernetes 原理剖析 1.基本概念2.架构图3.核心概念4.架构5.JobManager6.TaskManager7.交互8.实践8.1 Session Cluster8.2 Job Cluster 9.问题解答 Kubernetes 是 Google 开源的 容器集群管理系统,其提供应用部署、维护、扩展机制等功能,利用 K…

数据结构中图的概念以及遍历算法的实现

在数据结构中,图(Graph)是由节点(Vertex)和连接节点的边(Edge)组成的一种非线性数据结构。图可以用来表示各种实际问题中的关系和连接,如社交网络、道路网络、电路等。 图由两个主要…

【二十八】springboot整合logback实现日志管理

本章节是记录logback在springboot项目中的简单使用&#xff0c;本文将会演示如何通过logback将日志记录到日志文件或输出到控制台等管理操作。将会从以下几个方面进行讲解。最后实现将特定级别的特定日志保存到日志文件。 一、依赖 <dependency><groupId>ch.qos.l…

SpringBoot整合第三方技术-缓存

&#x1f648;作者简介&#xff1a;练习时长两年半的Java up主 &#x1f649;个人主页&#xff1a;程序员老茶 &#x1f64a; ps:点赞&#x1f44d;是免费的&#xff0c;却可以让写博客的作者开心好久好久&#x1f60e; &#x1f4da;系列专栏&#xff1a;Java全栈&#xff0c;…

C++ STL详解:map

目录 一、map的使用 1.1map模板参数 1.2map的构造函数及迭代器 1.3map的容量与元素访问 1.4map中的增删查改 二、日常实操 一、map的使用 CSTL详解&#xff1a;set 通过对set的简单了解&#xff0c;我们可以知道&#xff0c;set就类似于二叉搜索树的key模型&#xff0c;…

vue2+高德地图web端开发(二)

前言&#xff1a; 高德地图输入提示与 POI 搜索相关文档&#xff1a;输入提示与 POI 搜索-服务插件和工具-进阶教程-地图 JS API 2.0 | 高德地图API (amap.com) 输入提示-输入提示-示例中心-JS API 2.0 示例 | 高德地图API (amap.com) 创建输入框&#xff1a; 引入Element组…

App测试中ios和Android有哪些区别呢?

App测试中&#xff0c;大家最常问到的问题就是&#xff1a;ios和 Android有什么区别呢&#xff1f; 在Android端&#xff0c;我们经常会使用 JavaScript、 HTML、 CSS等技术来编写一些简单的 UI界面。而 iOS端&#xff0c;我们经常会使用到 UI设计、界面布局、代码结构、 API等…

掘根宝典之C++深复制与浅复制(复制构造函数,默认复制构造函数)

到目前为止我们已经学了构造函数&#xff0c;默认构造函数&#xff0c;析构函数&#xff1a;http://t.csdnimg.cn/EOQxx 转换函数&#xff0c;转换构造函数&#xff1a;http://t.csdnimg.cn/kiHo6 友元函数&#xff1a;http://t.csdnimg.cn/To8Tj 接下来我们来学习一个新函数…

让Python自动测试更得心应手——认识一下神奇的pytest测试框架

前言 Python在测试圈的应用非常广泛&#xff0c;特别是在自动化测试以及测试开发的领域&#xff0c;其中在自动化测试中我们常用的测试框架是uniitest和pytest&#xff0c;本文将带领大家搭建以及熟悉pytest的使用。 既然有unittest那么为什么还要用pytest呢&#xff1f; 这…
推荐文章