消息队列的消息异常处理
目录
1.如果消费端发生异常导致消息消费失败，补偿策略是什么
2.消息队列重试的话，如何保证消费的幂等性？
3.消息重发机制
1.如果消费端发生异常导致消息消费失败，补偿策略是什么
生产者发送消息失败：
设置mandatory=true；交换器无法根据自身的类型和路由键找到一个符合条件的队列的话，那么RabbitMQ会调用Basic.Return命令将消息返回给生产者
生产者将信道设置成confirm（确认）模式:一旦信道进入confirm模式，所有在该信道上面发布的消息都会被指派一个唯一的ID（从1开始），一旦消息被投递到所有匹配的队列之后，RabbitMQ就会发送一个确认（Basic.Ack）给生产者（包含消息的唯一ID）
消费者消费消息失败：
设置死信队列：消息进入死信队列，设置重新发送到正常队列的重试时间和重试间隔，重新发送到正常队列
将消息存入本地客户端：进行重发
补偿策略：当消息消费失败后，进入死信队列，获取对应死信队列的消息长度，当大于0时并判断未超过重试次数，自动将消息从死信队列迁移到正常队列
死信队列：如果队列里的消息出现存活时间超过设置的生存时间（TTL)时间、消息数量已经超过最大队列长度，该消息将成为“死信”。
“死信”消息会被RabbitMQ进行特殊处理，如果配置了死信队列信息，那么该消息将会被丢进死信队列中，如果没有配置，则该消息将会被丢弃。
2.消息队列重试的话，如何保证消费的幂等性？
消费的幂等性：消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响
利用数据库的唯一约束实现幂等：比如将订单表中的订单编号设置为唯一索引，创建订单时，根据订单编号就可以保证幂等
利用redis的原子性：每次操作都直接set到redis里面，然后将redis数据定时同步到数据库中
版本号机制：给业务数据增加一个版本号属性，每次更新数据前，比较当前数据的版本号是否和消息中的版本一致，如果不一致则拒绝更新数据，更新数据的同时将版本号+1
3.消息重发机制
消息重发：消息发送失败或者消费者消费失败后重新发送消息
在消息收发过程中，若Consumer消费某条消息失败或者消费超时，则云消息队列会在重试间隔时间后，将消息重新投递给消费者消费，若达到最大重试次数后消息还未被成功消费，则将消息投递至死信队列，通过私信消息解决业务异常
消息重试行为：
重试间隔：上一次消费失败或超时后，距下次消息可被重新消费的间隔时间
最大重试次数：消息消费失败后，可以被消息队列重复投递的最大次数
相关文章：
消息队列的消息异常处理
目录 1.如果消费端发生异常导致消息消费失败，补偿策略是什么 2.消息队列重试的话，如何保证消费的幂等性？ 3.消息重发机制 1.如果消费端发生异常导致消息消费失败，补偿策略是什么 生产者发送消息失败： 设置mandato…...
APP上线为什么要提前部署安全产品呢？
一般平台刚上线或者日活跃量比较高的时候，很容易成为攻击者的目标，服务器如果遭遇黑客攻击，资源耗尽会导致平台无法访问，业务也无法正常开展，服务器一旦触发黑洞机制，就会被拉进黑洞很长一段时间࿰…...
SQL注入之HTTP头部注入
文章目录 cookie注入练习获取数据库名称获取版本号 base64注入练习获取数据库名称获取版本号 user-agent注入练习获取数据库名称获取版本号 cookie注入练习 向服务器传参三大基本方法:GPC GET方法，参数在URL中 POST，参数在body中 COOKIE，参数…...
软考高级系统架构设计师系列论文九十七：论软件三层结构的设计
软考高级系统架构设计师系列论文九十七：论软件三层结构的设计 一、软件结构相关知识点二、摘要三、正文四、总结一、软件结构相关知识点 软考高级系统架构设计师：软件架构设计系列二二、摘要 随着中间件与Web技术的发展，三层或多层分布式应用体系越来越流行。在这种体系结构…...
【C++心愿便利店】No.2---函数重载、引用
文章目录 前言🌟一、函数重载🌏1.1.函数重载概念🌏1.2.C支持函数重载的原理 -- 名字修饰 🌟二、引用🌏2.1.引用的概念🌏2.2.引用特性🌏2.3.常引用🌏2.4.使用场景🌏2.5.传…...
掌握Six Sigma：逐步解锁业务流程优化的秘密之匙
一、Six Sigma方法简介 1. Six Sigma的起源和概念 Six Sigma起源于1980年代的摩托罗拉公司。当时的摩托罗拉在面临激烈的全球竞争和持续的质量问题时，发明了这种系统的管理方法，并通过实施，获得了显著的成绩。 所谓的“Six Sigma”&#x…...
Python中使用print()时如何实现不换行
平时刷题的时候大家可能会发现打印字符的时候需要你不换行才能得到正确答案，那么如何实现的。下面直接看例子。 使用print()函数时其实还有个默认的参数end，来看看具体怎么回事 list [a,b,c] for i in list:print(i)打印结果： 这是不加参…...
WordPress使用子主题插件 Child Theme Wizard，即使主题升级也能够保留以前主题样式
修改WordPress网站样式，主题升级会导致自己定义设置的网站样式丢失，还需要重新设置，很繁琐工作量大，发现在WordPress 中有Child Theme Wizard子主题插件，使用Child Theme Wizard子主题插件，即使主题升级&am…...
人员跌倒检测识别预警
人员跌倒检测识别预警系统通过pythonopencv深度学习网络模型架构，人员跌倒检测识别预警系统实时监测老人的活动状态，通过图像识别和行为分析算法，对老人的姿态、步态等进行检测和识别，一旦系统检测到跌倒事件，立即发出…...
C#，《小白学程序》第二课：数组与排序
1 文本格式 /// <summary> /// 《小白学程序》第二课：数组与排序 /// </summary> /// <param name"sender"></param> /// <param name"e"></param> private void button2_Click(object sender, EventArgs …...
2023有哪些更好用的网页制作工具
过去，专业人员使用HTMLL、CSS、Javascript等代码手动编写和构建网站。现在有越来越多的智能网页制作工具来帮助任何人实现零代码基础，随意建立和设计网站。在本文中，我们将向您介绍2023年流行的网页制作工具。我相信一旦选择了正确的网页制作…...
Keepalived（一）
高可用集群 High Availability Cluster，简称HA Cluste。以减少服务中断时间为目的的服务器集群技术。它通过保护用户的业务程序对外不间断提供的服务，把因软件、硬件、人为造成的故障对业务的影响降低导最低 衡量可用性：在线时间/ÿ…...
cs231n assignment3 q5 Self-Supervised Learning for Image Classification
文章目录 嫌墨迹直接看代码Q5 Self-Supervised Learning for Image Classificationcompute_train_transform CIFAR10Pair.__getitem__()题面解析代码输出 simclr_loss_naive题面解析代码输出 sim_positive_pairs题面解析代码输出 compute_sim_matrix题面解析代码输出 simclr_lo…...
电商首屏设计
1、主图最后成图效果 1.1 最后效果 1.2 主图尺寸，建多大的空白画布 1.3 如何让猜你喜欢展示跟搜索系统不一样的界面 2、实际操作方案 2.1 矩形屏信息 宽度为765 px 高度为770px； 2.2 第一步 矩形屏 2.3 第二步 填充颜色到空白 2.4 Crty j 复制图层 …...
SpringBoot集成Redis
Redis 的介绍 Redis（Remote Dictionary Server）是一个开源的内存数据结构存储系统，它被广泛地应用于缓存、计数器、限速器、消息队列、分布式锁等多种场景中。Redis 支持多种数据结构，包括字符串、散列、列表、集合和有序集合等&…...
qt 的基础学习计划列表
1 第一天 （qt 的基础） 什么是qt hello程序，空窗口 添加按钮（对象树、父子关系） 按钮的功能（信号和槽） 信号和槽的拓展2 第二天 各个控件 最简单的记事本界面（菜单栏、状态栏、工具…...
CSS中如何改变鼠标指针样式（cursor）？
聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ CSS中改变鼠标指针样式（cursor）⭐ 示例：⭐ 写在最后 ⭐ 专栏简介 前端入门之旅：探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅…...
SpringMVC-2-Spring MVC拦截器详解：从入门到精通
SpringMVC-2-Spring MVC拦截器详解：从入门到精通 今日目标 能够编写拦截器并配置拦截器 1.拦截器【理解】 1 拦截器介绍 1.1 拦截器概念和作用 拦截器（Interceptor）是一种动态拦截方法调用的机制，在SpringMVC中动态拦截控制器方…...
探索AIGC人工智能（Midjourney篇）（一）
文章目录 案例图片 Midjourney注册 创建Discord账号 下载客户端 添加Midjourney到自己的服务器 用Midjourney画一只会飞的鸭子 Midjourney绘画指令 Midjourney绘画指令_激发Midjourney的创造力 Midjourney绘画指令_Seed指令 Midjourney光线关键词，打造震撼…...
【IMX6ULL驱动开发学习】11.Linux之SPI驱动
参考：驱动程序开发：SPI设备驱动_spi驱动_邓家文007的博客-CSDN博客 目录 一、SPI驱动简介 1.1 SPI架构概述 1.2 SPI适配器（控制器）数据结构 1.2 SPI设备数据结构 1.3 SIP设备驱动 1.4 接口函数 二、SPI驱动模板 一、SPI驱动…...
定时器任务——若依源码分析
分析util包下面的工具类schedule utils： ScheduleUtils 是若依中用于与 Quartz 框架交互的工具类，封装了定时任务的 创建、更新、暂停、删除等核心逻辑。 createScheduleJob createScheduleJob 用于将任务注册到 Quartz，先构建任务的 JobD…...
将对透视变换后的图像使用Otsu进行阈值化，来分离黑色和白色像素。这句话中的Otsu是什么意思？
Otsu 是一种自动阈值化方法，用于将图像分割为前景和背景。它通过最小化图像的类内方差或等价地最大化类间方差来选择最佳阈值。这种方法特别适用于图像的二值化处理，能够自动确定一个阈值，将图像中的像素分为黑色和白色两类。 Otsu 方法的原…...
生成 Git SSH 证书
🔑 1. 生成 SSH 密钥对 在终端（Windows 使用 Git Bash，Mac/Linux 使用 Terminal）执行命令： ssh-keygen -t rsa -b 4096 -C "your_emailexample.com" 参数说明： -t rsa&#x…...
Spring Boot面试题精选汇总
🤟致敬读者 🟩感谢阅读🟦笑口常开🟪生日快乐⬛早点睡觉 📘博主相关 🟧博主信息🟨博客首页🟫专栏推荐🟥活动信息 文章目录 Spring Boot面试题精选汇总⚙️ **一、核心概…...
)
GitHub 趋势日报 (2025年06月08日)
📊 由 TrendForge 系统生成 | 🌐 https://trendforge.devlive.org/ 🌐 本日报中的项目描述已自动翻译为中文 📈 今日获星趋势图 今日获星趋势图 884 cognee 566 dify 414 HumanSystemOptimization 414 omni-tools 321 note-gen …...
自然语言处理——Transformer
自然语言处理——Transformer 自注意力机制多头注意力机制Transformer 虽然循环神经网络可以对具有序列特性的数据非常有效，它能挖掘数据中的时序信息以及语义信息，但是它有一个很大的缺陷——很难并行化。 我们可以考虑用CNN来替代RNN，但是…...
k8s业务程序联调工具-KtConnect
概述 原理 工具作用是建立了一个从本地到集群的单向VPN，根据VPN原理，打通两个内网必然需要借助一个公共中继节点，ktconnect工具巧妙的利用k8s原生的portforward能力，简化了建立连接的过程，apiserver间接起到了中继节…...
处理vxe-table 表尾数据是单独一个接口，表格tableData数据更新后，需要点击两下，表尾才是正确的
修改bug思路： 分别把 tabledata 和 表尾相关数据 console.log() 发现 更新数据先后顺序不对 settimeout延迟查询表格接口 ——测试可行 升级↑：async await 等接口返回后再开始下一个接口查询 ________________________________________________________…...
【Nginx】使用 Nginx+Lua 实现基于 IP 的访问频率限制
使用 NginxLua 实现基于 IP 的访问频率限制 在高并发场景下，限制某个 IP 的访问频率是非常重要的，可以有效防止恶意攻击或错误配置导致的服务宕机。以下是一个详细的实现方案，使用 Nginx 和 Lua 脚本结合 Redis 来实现基于 IP 的访问频率限制…...
Spring Security 认证流程——补充
一、认证流程概述 Spring Security 的认证流程基于 过滤器链（Filter Chain），核心组件包括 UsernamePasswordAuthenticationFilter、AuthenticationManager、UserDetailsService 等。整个流程可分为以下步骤： 用户提交登录请求拦…...