【RabbitMQ笔记10】消息队列RabbitMQ之死信队列的介绍
这篇文章,主要介绍消息队列RabbitMQ之死信队列。
目录
一、RabbitMQ死信队列
1.1、什么是死信队列
1.2、设置过期时间TTL
1.3、配置死信交换机和死信队列(代码配置)
(1)设置队列过期时间
(2)设置单条消息过期时间
(3)队列设置死信交换机
(4)配置的基本思路
1.4、配置死信交换机和死信队列(RabbitMQ管理界面配置)
一、RabbitMQ死信队列
1.1、什么是死信队列
在RabbitMQ中,并没有提供真正意义上的延迟队列,但是RabbitMQ可以设置队列、消息的过期时间,当队列或者消息到达过期时间之后,还没有被消费者消费,那么RabbitMQ会将这些消息放入另外一个队列,这个队列叫做:死信队列,而这个过期的消息就叫做:死信消息。
哪些情况下,消息会变成死信消息???
- 第一种情况:Queue队列已经满了,无法保存新进入的消息,那么这个消息就会被放入死信队列。
- 第二种情况:队列中的消息被消费者拒绝消费了,并且没有设置重新放入Queue队列里面。
- 第三种情况:队列中的消息到了过期时间还没有被消费者消费。
死信队列需要通过一个死信交换机来分发死信消息,死信交换机是Dead Letter Exchange,简称:DLX。死信队列大致原理图如下所示:

1.2、设置过期时间TTL
RabbitMQ可以给Queue队列设置过期时间,也可以给单独的某一条消息Message设置过期时间,过期时间就是指消息存活时间,英文全称是Time To Live,简称:TTL。
- 第一种方式:设置队列过期时间。
- RabbitMQ可以给整个Queue队列设置过期时间,设置整个Queue过期时间,也就是设置这个队列中的所有Message消息的过期时间。
- 这种方式不太灵活,因为如果每一个消息的延迟时间不一样,那么就需要保存到不同的Queue队列里面,给每一个Queue队列设置不同的过期时间,这样就会导致Queue队列非常的多。
- 注意:通过队列的属性【x-message-ttl】设置队列的过期时间,单位是【ms】毫秒。
- 第二种方式:设置单条消息过期时间。
- RabbitMQ也支持给一个队列中的每一条Message消息设置过期时间,这种方式就更加灵活啦,同一个队列里面可以保存不同过期时间的消息,减少了队列的数量。
- 这种方式也有一个缺点,那就是:每一条消息的过期时间不同,如果队列之前的消息没有被消费掉,那么后面的消息过期时间到了,也不会被剔除掉。
- RabbitMQ剔除过期消息是在消费者消费之前判断是否过期的。
- 举个例子:
- 有A、B两条消息,A消息过期时间是10秒,B消息过期时间是5秒,并且A消息在B消息之前进入队列,5秒之后,A消息还没有被消费者消费掉,此时B消息到了过期时间,但是它不会立即从队列里面剔除,而是会在消费者消费B消息时候,判断B消息是否过期。
- 当A消息消费结束之后,开始消费B消息,发现B消息已经过期,并且已经过期5秒,就会将这一条消息转发到死信交换机。
- 注意:通过消息的【expiration】属性设置过期时间,单位是【ms】毫秒。
注意:可以同时设置队列和消息的过期时间,RabbitMQ会根据最短的时间来决定消息是否已经过期了。
1.3、配置死信交换机和死信队列(代码配置)
死信交换机和死信队列和普通的交换机、队列没有什么不同,只是叫法不同,在配置死信交换机和死信队列的时候,只需要给具体的业务队列配置死信交换机,然后给这个死信交换机绑定一个死信队列即可。
可以通过代码设置死信交换机和死信队列,也可以通过RabbitMQ提供的管理界面直接配置死信交换机和死信队列。在实际开发中,交换机和队列都是事先创建好的,之后生产者、消费者直接从指定的队列消费消息即可。
(1)设置队列过期时间
在声明队列的时候,给队列设置【x-message-ttl】属性即可。
// 6、指定需要操作的消息队列,如果队列不存在,则会创建
String queueName = "queue_demo_2023";
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl", "30000"); // 设置队列的过期时间
channel.queueDeclare(queueName, false, false, false, arguments);
(2)设置单条消息过期时间
在生产者发送消息的时候,通过【AMQP.BasicProperties】设置过期时间属性。
// 6、发送消息
String message = "RabbitMQ死信队列案例";
// TODO 设置消息的属性
AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()// 设置消息的过期时间是:30秒.expiration("30000").build();
channel.basicPublish(exchangeName, "demo_key_2023", properties, message.getBytes());
(3)队列设置死信交换机
- 声明队列的时候,通过给队列指定【x-dead-letter-exchange】属性,指定当前队列需要转发的死信交换机。
- 通过【x-dead-letter-routing-key】属性,指定死信交换机绑定的路由键routingKey。
// 声明 Exchange,如果不存在,则会创建
channel.exchangeDeclare("exchange_demo_2023", "direct");
// TODO 声明死信交换机
channel.exchangeDeclare("exchange_dead_2023", "direct");// 指定需要操作的消息队列,如果队列不存在,则会创建
// TODO 设置队列过期时间【业务队列】
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl", 10000); // 设置队列的过期时间
// 指定队列绑定的死信交换机名称
arguments.put("x-dead-letter-exchange", "exchange_dead_2023");
// 指定死信交换机的路由键routingKey
arguments.put("x-dead-letter-routing-key", "dead_key_2023");
channel.queueDeclare("queue_demo_2023", false, false, false, arguments);
// TODO 创建死信队列
channel.queueDeclare("queue_dead_2023", false, false, false, null);// 绑定 Exchange 和 Queue
channel.queueBind("queue_demo_2023", "exchange_demo_2023", "demo_key_2023");
// TODO 死信队列绑定死信交换机
channel.queueBind("queue_dead_2023", "exchange_dead_2023", "dead_key_2023");
(4)配置的基本思路
- 业务队列和业务交换机绑定。
- 死信队列和死信交换机绑定。
- 业务队列和死信交换机,是通过【x-dead-letter-exchange】和【x-dead-letter-routing-key】参数建立绑定关系的。

1.4、配置死信交换机和死信队列(RabbitMQ管理界面配置)
- 第一步:创建业务交换机【busi_exchange_2023】。

- 第二步:创建死信交换机【dead_exchange_2023】。

- 第三步:创建业务队列【busi_queue_2023】。
- 设置【x-message-ttl】消息过期时间。
- 设置【x-dead-letter-exchange】死信交换机。
- 设置【x-dead-letter-routing-key】死信交换机的路由键routingKey。

- 第五步:创建死信队列【dead_queue_2023】。

- 第六步:业务队列【busi_queue_2023】绑定业务交换机【busi_exchange_2023】。

- 第七步:死信队列【dead_queue_2023】绑定死信交换机【dead_exchange_2023】。

- 第八步:通过前面七个步骤,已经配置好了死信队列和死信交换机啦,可以进行测试啦。

- 第九步:查看业务队列和死信队列的变化情况。

到此,RabbitMQ中的死信队列就介绍完啦。
综上,这篇文章结束了,主要介绍消息队列RabbitMQ之死信队列。
相关文章:
【RabbitMQ笔记10】消息队列RabbitMQ之死信队列的介绍
这篇文章,主要介绍消息队列RabbitMQ之死信队列。 目录 一、RabbitMQ死信队列 1.1、什么是死信队列 1.2、设置过期时间TTL 1.3、配置死信交换机和死信队列(代码配置) (1)设置队列过期时间 (2ÿ…...
Python04 数据序列-字符串
Python04 数据序列-字符串 4.1 字符串概念 字符串是 Python 中最常用的数据类型。我们可以使用引号( ’ 或 " )来创建字符串。 格式: 变量名 数据 / "数据" / """ 数据 """案例: a hello world b &q…...
Redis限流接口防刷
Redis限流接口防刷 Redis 除了做缓存,还能干很多很多事情:分布式锁、限流、处理请求接口幂等性。。。太多太多了~ 大家好,我是llp,许久没有写博客了,今天就针对Redis实现接口限流做个记录。废话不多说&am…...
Yarn 资源调度器
Yarn 资源调度器:资源调度平台,负责为运算程序提供服务器运算资源 1 Yarn 基础架构 YARN 主要由 ResourceManager、NodeManager、ApplicationMaster 和 Container 等组件构成。 MR 程序提交到客户端所在的节点。YarnRunner 向 ResourceManager 申请一个…...
通达信 34日上升三角形主图源码
请先看效果图。 以下是编程源码,可以参考学习一下: N:34;{三角背景} 趋势下:DRAWLINE(HHHV(H,N),H,LLLV(L,N),L,0),LINETHICK2,COLORMAGENTA; SX:REF(趋势下,1)<趋势下; SS:DRAWLINE(SX,趋势下,REF(SX,1),REF(趋势下,1),1); DRAWBAND(SS,RGB(0,0,16…...
CSDN周赛第37期题解(Python版)
这期周赛题目和测试集还算完整,没有出现往期的bug。1、题目名称:幼稚班作业幼稚园终于又有新的作业了。 老师安排同学用发给同学的4根木棒拼接成一个三角形。 当然按照正常的逻辑,如果不能拼接成三角形。 必然要折断某个木棍来拼接三角形。 可…...
程序调试方法
调试思路 程序中一定要尽可能的做容错处理,可能会出错的地方,增加打印日志,这样在出问题时候才能最快的定位问题,所以这个属于前置工作,前置做的越多越好,后期调试越省力,程序也更健壮。学会看…...
【Android入门到项目实战--2.3】—— 活动的四种启动模式(standard、singleTop、singleTask、singleInstance)
目录 一、活动的启动模式 1、standard 2、singleTop 3、singleTask 4、singleInstance 本篇文章主要讲解活动的生命周期和活动的启动模式。 一、活动的启动模式 活动的启动模式共有4种,分别是standard、singleTop、singleTask和singleInstance; 可…...
SpringCloud微服务技术栈.黑马跟学(三)
SpringCloud微服务技术栈.黑马跟学 三今日目标1.初识Docker1.1.什么是Docker1.1.1.应用部署的环境问题1.1.2.Docker解决依赖兼容问题1.1.3.Docker解决操作系统环境差异1.1.4.小结1.2.Docker和虚拟机的区别1.3.Docker架构1.3.1.镜像和容器1.3.2.DockerHub1.3.3.Docker架构1.3.4.…...
学习Java——集合类
目录 1.Collection和Collections区别 2.Set和List区别 3.ArrayList和LinkedList和Vector的区别 4.Set如何保证元素不重复 5.Arrays.asList获得的List使用时需要注意什么 1.Collection和Collections区别 Collection 是一个集合接口。 它提供了对集合对象进行基本操作的通用…...
[前端笔记035]vue2之脚手架vue-cli
前言 本笔记参考视频,尚硅谷:BV1Zy4y1K7SH p61 - p95 简介 Vue 脚手架是 Vue 官方提供的标准化开发工具,vue-cli使用步骤 如果下载缓慢请配置 npm 淘宝镜像:npm config set registry http://registry.npm.taobao.org全局安装vue/cli&#…...
《Linux的权限》
本文主要对linux的一些基本权限进行讲解 文章目录前言Linux权限(1)权限的概念(2)linux下用户分类(root,普通)(3)linux的文件属性文件属性的分类文件权限修改文件权限1、chmod2、chown和chgrp3、fiile权限的三个重要的问题第一个问…...
js类型转换
类型转换 1.字符串转换 字符串转换在原来值的基础上加上 "" let num 1 num String(num) // "1"String(false) // "false"2.数字转换 在算数函数和表达式中,会自动进行数字转换。其自动完成的数字转换为隐式转换,也可…...
PostMan工具的使用
PostMan工具的使用 1 PostMan简介 代码编写完后,我们要想测试,只需要打开浏览器直接输入地址发送请求即可。发送的是GET请求可以直接使用浏览器,但是如果要发送的是POST请求呢? 如果要求发送的是post请求,我们就得准备页面在页…...
Sentinel 授权规则规则持久化
本篇博客我们来学习授权规则,授权规则是对请求者的一种身份的判断。 1、授权规则 授权规则是对请求者的身份做一个判断。你有没有权限来访问我?那就有人可能会说这个功能,好像以前我们在学习微服务的时候讲过网关他不就是把门的吗࿱…...
C#大型HIS医院LIS管理系统源码
▶ 一、实验室信息管理系统(LIS)是什么? 实验室信息管理系统也就是平时所说的LIS(Laboratory Information System)系统,其主要服务的对象主要是医院检验科工作人员,也是医院信息化建设必…...
Java基础学习(5)
Java基础学习一 面向对象1.1 介绍对象1.2 设计对象并使用1.2.1定义类的补充注意事项1.3 封装好处:1.3 private关键字1.4 this关键字1.5 构造方法构造方法的注意事项:1.6 标准的JavaBean1.7 对象内存图1.7.1 一个对象的内存图1.7.2 两个对象内存图1.7.两个引用指向同一个对象1.8…...
SpringBoot接口 - 如何生成接口文档之Swagger技术栈
SpringBoot开发Restful接口,有什么API规范吗?如何快速生成API文档呢?Swagger 是一个用于生成、描述和调用 RESTful 接口的 Web 服务。通俗的来讲,Swagger 就是将项目中所有(想要暴露的)接口展现在页面上&am…...
JavaScript execCommand函数
execCommand函数命令execCommand方法是执行一个对当前文档,当前选择或者给出范围的命令。处理Html数据时常用如下格式:document.execCommand(sCommand[,交互方式, 动态参数]) ,其中:sCommand为指令参数(如下例中的”2D…...
2023年安徽省中职网络安全跨站脚本攻击
B-4:跨站脚本攻击 任务环境说明: √ 服务器场景:Server2125(关闭链接) √ 服务器场景操作系统:未知 √ 用户名:未知 密码:未知 1.访问服务器网站目录1,根据页面信息完成条件&am…...
uniapp 对接腾讯云IM群组成员管理(增删改查)
UniApp 实战:腾讯云IM群组成员管理(增删改查) 一、前言 在社交类App开发中,群组成员管理是核心功能之一。本文将基于UniApp框架,结合腾讯云IM SDK,详细讲解如何实现群组成员的增删改查全流程。 权限校验…...
Cursor实现用excel数据填充word模版的方法
cursor主页:https://www.cursor.com/ 任务目标:把excel格式的数据里的单元格,按照某一个固定模版填充到word中 文章目录 注意事项逐步生成程序1. 确定格式2. 调试程序 注意事项 直接给一个excel文件和最终呈现的word文件的示例,…...
《Qt C++ 与 OpenCV:解锁视频播放程序设计的奥秘》
引言:探索视频播放程序设计之旅 在当今数字化时代,多媒体应用已渗透到我们生活的方方面面,从日常的视频娱乐到专业的视频监控、视频会议系统,视频播放程序作为多媒体应用的核心组成部分,扮演着至关重要的角色。无论是在个人电脑、移动设备还是智能电视等平台上,用户都期望…...
BCS 2025|百度副总裁陈洋:智能体在安全领域的应用实践
6月5日,2025全球数字经济大会数字安全主论坛暨北京网络安全大会在国家会议中心隆重开幕。百度副总裁陈洋受邀出席,并作《智能体在安全领域的应用实践》主题演讲,分享了在智能体在安全领域的突破性实践。他指出,百度通过将安全能力…...
鱼香ros docker配置镜像报错:https://registry-1.docker.io/v2/
使用鱼香ros一件安装docker时的https://registry-1.docker.io/v2/问题 一键安装指令 wget http://fishros.com/install -O fishros && . fishros出现问题:docker pull 失败 网络不同,需要使用镜像源 按照如下步骤操作 sudo vi /etc/docker/dae…...
Mac下Android Studio扫描根目录卡死问题记录
环境信息 操作系统: macOS 15.5 (Apple M2芯片)Android Studio版本: Meerkat Feature Drop | 2024.3.2 Patch 1 (Build #AI-243.26053.27.2432.13536105, 2025年5月22日构建) 问题现象 在项目开发过程中,提示一个依赖外部头文件的cpp源文件需要同步,点…...
动态 Web 开发技术入门篇
一、HTTP 协议核心 1.1 HTTP 基础 协议全称 :HyperText Transfer Protocol(超文本传输协议) 默认端口 :HTTP 使用 80 端口,HTTPS 使用 443 端口。 请求方法 : GET :用于获取资源,…...
基于IDIG-GAN的小样本电机轴承故障诊断
目录 🔍 核心问题 一、IDIG-GAN模型原理 1. 整体架构 2. 核心创新点 (1) 梯度归一化(Gradient Normalization) (2) 判别器梯度间隙正则化(Discriminator Gradient Gap Regularization) (3) 自注意力机制(Self-Attention) 3. 完整损失函数 二…...
腾讯云V3签名
想要接入腾讯云的Api,必然先按其文档计算出所要求的签名。 之前也调用过腾讯云的接口,但总是卡在签名这一步,最后放弃选择SDK,这次终于自己代码实现。 可能腾讯云翻新了接口文档,现在阅读起来,清晰了很多&…...
逻辑回归暴力训练预测金融欺诈
简述 「使用逻辑回归暴力预测金融欺诈,并不断增加特征维度持续测试」的做法,体现了一种逐步建模与迭代验证的实验思路,在金融欺诈检测中非常有价值,本文作为一篇回顾性记录了早年间公司给某行做反欺诈预测用到的技术和思路。百度…...
