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

Spring AMQP-保证消费者消息的可靠性

news 来源：原创 2025/5/15 10:16:09

为什么要保证消息的可靠性？

当MQ向消费者发送一个消息之后需要得到消费者的状态，因为消息并不一定就真的被消费者给消费了，可能在消费的过程中出现了一些意外，比如

1. 网络问题

2. 消息转换有问题

3. 消费者本身的业务处理有问题

消费者确认机制

消费者消息处理状态：

ack:消息成功接收，并且成功被处理，MQ将此消息删除
nack：消息处理失败，需要MQ重新发送消息
reject：消息处理失败并且拒绝该消息，MQ将此消息删除

由于消息回执的处理代码比较统一，因此SpringAMQP帮我们实现了消息确认。并允许我们通过配置文件设置ACK处理方式，有三种模式：

none：不处理。即消息投递给消费者后立刻ack，消息会立刻从MQ删除。非常不安全，不建议使用

manual：手动模式。需要自己在业务代码中调用api，发送ack或reject，存在业务入侵，但更灵活

auto：自动模式。SpringAMQP利用AOP对我们的消息处理逻辑做了环绕增强，当业务正常执行时则自动返回ack. 当业务出现异常时，根据异常判断返回不同结果：

如果是业务异常，会自动返回nack；

如果是消息处理或校验异常，自动返回reject;

在配置文件中通过下面的配置即可设置ACK的处理方式
spring:rabbitmq:listener:simple:acknowledge-mode: c # none 默认 auto 自动确认 manual 手动确认 

消费者重试机制

消费者接收了一个消息，但是在处理的过程中出现异常了，那么AMQP会不断的重试，直到把资源占完然后崩掉，这个时候就必须要设置重试机制，限制重试的次数，避免无限制重试。
spring:rabbitmq:listener:simple:retry:enabled: true # 开启消费者失败重试initial-interval: 1000ms # 初识的失败等待时长为1秒multiplier: 1 # 失败的等待时长倍数，下次等待时长 = multiplier * last-intervalmax-attempts: 3 # 最大重试次数stateless: true # true无状态；false有状态。如果业务中包含事务，这里改为false
测试

先别配置重试机制，然后在需要在接收消息的地方手动抛出一个异常，查看控制台就会看见消费者在尝试不断的获取消息，但是一直获取不到无限制的重试
  @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "fanout.hamll.query1", // 队列名称durable = "true"), // 是否持久exchange = @Exchange(name = "fanout.hamll", type = ExchangeTypes.FANOUT) // 交换机名称))public void query2(String message) {System.err.println("fanout.hamll.query1 消息内容：" + message); throw  new RuntimeException("故意的错误"); // 抛出异常}
配置好重试之后到了三次就会直接停止，这样子就很好的减少了系统资源的消耗

业务的幂等性判断

什么是幂等性？

在Java领域，幂等性是指同一个请求，不管发送多少次执行的结构都是一样的。

比如支付和交易，支付成功之后通知交易服务修改状态。在交易服务需要查询订单并判断订单的状态，这样子不管同一个订单重复发起多少次请求，都不会对业务的结果造成影响。

MQ保证消息的幂等性

MQ中的幂等是说，不管消息是否被重复消费，都不会对业务造成影响、处理的结果都是一致的。

MQ实现业务幂等性

为每个消息都创建一个唯一的MessageId在操作的时候将其存入数据库，然后在进行判断消息是否存在，存在就直接跳过业务的处理，不存在就继续操作。
    @Beanpublic MessageConverter messageConverter(){// 1.定义消息转换器Jackson2JsonMessageConverter jackson2JsonMessageConverter = new Jackson2JsonMessageConverter();// 2.配置自动创建消息id，用于识别不同消息，也可以在业务中基于ID判断是否是重复消息jackson2JsonMessageConverter.setCreateMessageIds(true);return jackson2JsonMessageConverter;}
业务实现幂等性

在业务的操作中，比如支付和交易服务，支付成功之后会通知交易服务修改订单的状态，而在交易服务应该做判断，判断该订单的状态是否未未支付。如果是未支付就继续处理接下来的业务，否则就直接结束。
package com.hmall.trade.listener;import com.hmall.trade.domain.po.Order;
import com.hmall.trade.service.IOrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
@Slf4j
public class PayStatusListener {@AutowiredIOrderService orderService;@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "trade.pay.success.queue", durable = "true"),exchange = @Exchange(value = "pay.direct", type = ExchangeTypes.DIRECT),key = "pay.success"))public void paySuccess(Long orderId) {log.info("支付成功，订单号：{}", orderId);//查询当前订单 判断幂等性Order order = orderService.getById(orderId);//判断状态以及对象是否存在if (order == null || order.getStatus() != 1) {return;}orderService.markOrderPaySuccess(orderId);}
}

Spring AMQP-保证消费者消息的可靠性

为什么要保证消息的可靠性？ 当MQ向消费者发送一个消息之后需要得到消费者的状态，因为消息并不一定就真的被消费者给消费了，可能在消费的过程中出现了一些意外，比如 1. 网络问题 2. 消息转换有问题 3. 消费者本身的业务处理有问题 …...

编程日记 2025/5/15 10:16:09

32单片机从入门到精通之数据处理——数学运算(十三)

无论你身在何处，无论你面对什么困难，只要对自己充满信心，坚持不懈地努力，相信自己的能力，你就能战胜任何困难，实现自己的目标。不要害怕失败，因为失败并不意味着你没有能力成功，只是…...

编程日记 2025/5/12 17:34:01

参考： https://www.overleaf.com/learn/latex/Free_online_introduction_to_LaTeX_(part_3)https://www.overleaf.com/learn/latex/Free_online_introduction_to_LaTeX_(part_2)https://www.overleaf.com/learn/latex/Free_online_introduction_to_LaTeX_(part_1) …...

编程日记 2025/5/12 9:48:23

小程序textarea组件键盘弹起会遮挡住输入框

<textarea value"{{remark}}" input"handleInputRemark" ></textarea> 如下会有遮挡： 一行代码搞定 cursor-spacing160 修改后代码 <textarea value"{{remark}}" input"handleInputRemark" cursor-spacin…...

编程日记 2025/5/5 19:31:22

vue之element-ui文件上传（二）

一、点击上传，使用默认的action上传，添加校验，上传成功后，去除校验： <el-form-item label"文件md5" prop"fileMd5"><el-uploadv-if"!form.fileMd5"v-model"form.fileMd5&…...

编程日记 2025/5/12 11:24:23

DC/AC并网逆变器模型与仿真MATLAB

DC/AC并网逆变器是一种将直流电（DC）转化为交流电（AC），并将其与电网并联的设备。它的核心功能是实现直流电源（如光伏电池板或储能电池）与电网的有效连接，同时保证输出电能质量满足电网…...

编程日记 2025/5/10 4:08:14

python面向对象

面向对象简介 python完全采用了面向对象的思想，是真正面向对象的变成语言，完全支持面向对象的基本功能，例如：继承、多态、封装等 python中，一切皆为对象。前面学习的数据类型、函数等都是对象面向过程和面向对象思…...

编程日记 2025/5/11 3:01:15

【UI自动化测试】selenium八种定位方式

🏡个人主页：謬熙，欢迎各位大佬到访❤️❤️❤️~ 👲个人简介：本人编程小白，正在学习互联网求职知识…… 如果您觉得本文对您有帮助的话，记得点赞👍、收藏⭐️、评论💬&am…...

编程日记 2025/5/6 1:35:39

基于物联网疫苗冷链物流监测系统设计

1. 项目开发背景随着全球对疫苗运输要求的提高，特别是针对温度敏感型药品（如疫苗）的冷链管理，如何保证疫苗在运输过程中的温度、湿度、震动等环境因素的稳定性已成为亟需解决的问题。疫苗运输过程中，任何温度或湿度的…...

编程日记 2025/5/14 10:38:43

实训云上搭建集群

文章目录 1. 登录实训云1.1 实训云网址1.2 登录实训云 2. 创建网络2.1 网络概述2.2 创建步骤 3. 创建路由器3.1 路由器名称3.1 创建路由器3.3 查看网络拓扑 4. 连接子网5. 创建虚拟网卡5.1 创建原因5.2 查看端口5.3 创建虚拟网卡 6. 管理安全组规则6.1 为什么要管理安全组规则6…...

编程日记 2025/5/10 10:20:33

【网页自动化】篡改猴入门教程

安装篡改猴打开浏览器扩展商店（Edge、Chrome、Firefox 等）。搜索 Tampermonkey 并安装。如图安装后，浏览器右上角会显示一个带有猴子图标的按钮。创建用户脚本已进入篡改猴管理面板点击创建脚本注释说明 name：脚本名称。…...

编程日记 2025/5/9 8:14:02

（概率论）无偏估计

参考文章：(15 封私信 / 51 条消息) 什么是无偏估计？ - 知乎 (zhihu.com) 首先，第一个回答中，马同学图解数学讲解得很形象， 我的概括是：“注意，有一个总体的均值u。然后，如果抽样n个&…...

编程日记 2025/5/13 0:29:36

JavaScript 正则表达式

JavaScript 正则表达式（RegEx）是一种强大的工具，用于在字符串中查找匹配的模式、替换文本，或者验证输入的格式。下面是一些常用的正则表达式操作和语法：常用正则表达式符号： .：匹配任意字符（除了换行符）。^：匹配输入字符串的开始。$：匹配输入字符串的结束。[]：定…...

编程日记 2025/5/12 15:15:15

Swift语言的正则表达式

Swift语言的正则表达式正则表达式是一种用于匹配字符串的强大工具，它可以帮助开发者在文本处理中高效地搜索和操作字符串。在Swift语言中，正则表达式的支持是通过Foundation框架提供的。本文将全面介绍Swift中的正则表达式，从基础知识到进阶…...

编程日记 2025/5/14 7:22:33

Matlab 数据处理与可视化的多元拓展应用（具体代码分析）

一、代码整体功能概述： 该代码主要实现了以下几个功能： 从文件（part1.txt）中读取数据，并提取第二列数据，将其存储在 originalColumnData 中。对原始数据进行可视化，包括绘制置零前数据的折线图…...

编程日记 2025/5/13 8:13:36

小程序与内嵌网页的数据通信

小程序与内嵌网页的数据通信前言微信小程序提供了web-view组件，允许开发者在小程序中嵌入网页。然而，由于小程序和网页运行在不同的环境中，它们之间的通信就需要依赖特定的机制来实现。然而我们日常的需求中，很多的时候都涉及…...

编程日记 2025/5/12 17:59:03

【学习笔记】数据结构（十一）

外部排序文章目录外部排序11.1 外存信息的存取11.2 外部排序的方法11.3 多路平衡归并的实现 - 增加k11.4 置换-选择排序 - 减少m11.5 最佳归并树外部排序指的是大文件的排序，即待排序的记录存储在外存储器上，在排序过程中需进行多次的内、外存之间的…...

编程日记 2025/5/12 17:13:05

【Logstash03】企业级日志分析系统ELK之Logstash 过滤 Filter 插件

Logstash 过滤 Filter 插件数据从源传输到存储库的过程中，Logstash 过滤器能够解析各个事件，识别已命名的字段以构建结构， 并将它们转换成通用格式，以便进行更强大的分析和实现商业价值。 Logstash 能够动态地转换和解析数据&a…...

编程日记 2025/5/11 1:11:23

深度学习模型部署——基于Onnx Runtime的深度学习模型CPU与GPU部署（C++实现）

1.概述许多机器学习和深度学习模型都是在基于 Python 的框架中开发和训练的，例如 PyTorch 和 TensorFlow 等。但是，当需要将这些训练好模型部署到生产环境中时，通常会希望将模型集成到生产流程中，而这些流程大多是用 C 编写的&a…...

编程日记 2025/5/7 6:58:02

Selenium 的四种等待方式及使用场景

Selenium 的四种等待方式及使用场景隐式等待（Implicit Wait）显式等待（Explicit Wait）自定义等待（Custom Wait）固定等待（Sleep） 1. 隐式等待定义： 隐式等待是为 WebD…...

编程日记 2025/5/9 20:26:32

攻防世界 ics-07

点击之后发现有个项目管理能进，点进去，点击看到源码，如下三段 <?php session_start(); if (!isset($_GET[page])) { show_source(__FILE__); die(); } if (isset($_GET[page]) && $_GET[page] ! index.php) { include(flag.php);…...

编程日记 2025/5/11 21:53:29

一文读懂「LoRA」：大型语言模型的低秩适应

LoRA: Low-Rank Adaptation of Large Language Models 前言 LoRA作为大模型的微调框架十分实用，在LoRA出现以前本人都是通过手动修改参数、优化器或者层数来“炼丹”的，具有极大的盲目性，但是LoRA技术能够快速微调参数，如果LoRA…...

编程日记 2025/5/13 14:06:57

新车月交付突破2万辆！小鹏汽车“激活”智驾之困待解

首次突破月交付2万辆规模的小鹏汽车，稳吗？ 本周，高工智能汽车研究院发布的最新监测数据显示，2024年11月，小鹏汽车在国内市场（不含出口）交付量（上险口径，下同&#xff09…...

编程日记 2025/5/13 17:07:39

dockerfile 中 #(nop)

在 Dockerfile 中，#(nop) 通常出现在 docker history 命令的输出中。以下是对它的详细解释： 背景当你使用 docker history <image_name> 命令查看 Docker 镜像的构建历史时，你可能会看到 #(nop) 这样的标记。这是因为 Docker 镜像由…...

编程日记 2025/5/14 0:24:12

升级 Spring Boot 3 配置讲解 —— 为何 SpringBoot3 淘汰了 JDK8？

学会这款 🔥全新设计的 Java 脚手架 ，从此面试不再怕！ 随着 Spring Boot 3 的发布，许多开发者发现了一个重要的变化：Spring Boot 3 不再支持 JDK 8。这一变化引发了不少讨论，尤其是对于那些仍然在使用 JDK …...

编程日记 2025/5/14 0:07:34

IT面试求职系列主题-人工智能（一）

想成功求职，必要的IT技能一样不能少，再从人工智能基础知识来一波吧。 1）您对人工智能的理解是什么？ 人工智能是计算机科学技术，强调创造能够模仿人类行为的智能机器。这里智能机器可以定义为能够像人一样行动、像人一…...

编程日记 2025/5/7 10:37:58

JVM 优化指南

JVM 优化指南 1. JVM 参数配置 1.1 基础参数配置设置堆内存大小 -Xms2048m -Xmx2048m 设置新生代大小 -Xmn1024m 设置元空间大小 -XX:MetaspaceSize256m -XX:MaxMetaspaceSize256m 设置线程栈大小 -Xss512k1.2 垃圾回收器配置使用 G1 垃圾回收器 -XX:UseG1GC 设置期望停顿…...

编程日记 2025/5/12 14:42:25

windows下编写的shell脚本在Linux下执行有问题解决方法

前言： 这个问题在实际工作中经常会遇到(非语法错误)，脚本来源有些是自己在windows系统编写的、有些是从别人那里copy来的，还有些原本是好的被别人拿到windows下修改了一些内容，总之各种场景，但是如果是一个内容比较多的…...

编程日记 2025/5/9 13:14:18

使用 SQL 和表格数据进行问答和 RAG（6）—将指定目录下的 CSV 或 Excel 文件导入 SQLite 数据库

将指定目录下的 CSV 或 Excel 文件导入 SQLite 数据库。以下是详细代码逻辑： 1. 类结构该类包含三个主要方法： _prepare_db：负责将文件夹中的 CSV 和 XLSX 文件转换为 SQL 表。_validate_db：用于验证 SQL 数据库中创建的表是否…...

编程日记 2025/4/27 21:26:17

【算法】算法大纲

这篇文章介绍计算机算法的各个思维模式。包括计数原理、数组、树型结构、链表递归栈、查找排序、管窥算法、图论、贪心法和动态规划、以及概率论：概率分治和机器学习。没有办法逐个说明，算法本身错综复杂，不同的算法对应着不同的实用场景，也需要根据具体情况设计与调整。…...

编程日记 2025/5/10 14:46:14

vue（2,3）, react (16及以上)开发者工具资源

在前端开发的广阔领域中，Vue.js 和 React.js 作为两大主流框架，各自拥有庞大的用户群体和丰富的生态系统。为了帮助开发者更高效地进行调试和开发，Vue Devtools 和 React 开发者工具应运而生，成为这两个框架不可或缺的辅助工具。本…...

编程日记 2025/5/14 3:28:20

系统编程(网络,文件基础)

网络链接虚拟机和主机之间网络连接的主要模式有三种，分别是桥接模式（Bridged）、网络地址转换模式（NAT）以及主机模式（Host-Only）。以下是这三种模式的详细解释： 一、桥接模式&…...

编程日记 2025/5/12 7:34:20

重温设计模式--13、策略模式

策略模式介绍文章目录策略模式介绍C 代码示例策略模式是一种行为设计模式，它允许在运行时选择算法的行为。该模式将算法的定义和使用分离开来，使得算法可以独立于使用它的客户端而变化，提高了代码的灵活性和可维护性。其主要包含以下几个…...

编程日记 2025/5/13 11:09:27

数字IC设计高频面试题

在数字IC设计领域，面试是评估候选人技术能力和问题解决能力的重要环节。数字IC设计的复杂性和要求在不断提高。面试官通常会提出一系列面试题，以考察应聘者在数字设计、验证、时钟管理、功耗优化等方面的专业知识和实践经验。这些题目不仅涉及理论知识…...

编程日记 2025/5/11 10:28:32

C#异步多线程——ThreadPool线程池

C#实现异步多线程的方式有多种，以下总结的是ThreadPool的用法。线程池的特点线程池受CLR管理，线程的生命周期，任务调度等细节都不需要我们操心了，我们只需要专注于任务实现，使用ThreadPool提供的静态方法把我们的任…...

编程日记 2025/5/11 23:27:21

矩母函数（MGF）

矩母函数（MGF）简介矩母函数（Moment Generating Function，MGF）是概率统计中描述随机变量分布特征的重要工具。MGF的主要用途是通过导数来计算随机变量的矩（比如均值、方差等），同时它…...

编程日记 2025/5/10 13:27:56

【技术支持】安卓无线adb调试连接方式

Android 10 及更低版本，需要借助 USB 手机和电脑需连接在同一 WiFi 下；手机开启开发者选项和 USB 调试模式，并通过 USB 连接电脑（即adb devices可以查看到手机）；设置手机的监听adb tcpip 5555;拔掉 USB 线…...

编程日记 2025/5/11 22:20:20

OpenCV相机标定与3D重建(46)将三维空间中的点投影到二维图像平面上函数projectPoints()的使用

操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述将3D点投影到图像平面上。 cv::projectPoints 是 OpenCV 库中的一个函数，用于将三维空间中的点投影到二维图像平面上。这个过程涉及到…...

编程日记 2025/5/12 7:24:05

Android wifi常见问题及分析

参考 Android Network/WiFi 那些事儿前言本文将讨论几个有意思的网络问题，同时介绍 Android 上常见WiFi 问题的分析思路。网络基础Q & A 一. 网络分层缘由分层想必大家很熟悉，是否想过为何需要这样分层？ 网上大多都是介绍每一层…...

编程日记 2025/5/14 9:19:17

如何用 ESP32-CAM 做一个实时视频流服务器

文章目录 ESP32-CAM 概述ESP32-S 处理器内存Camera 模块MicroSD 卡槽天线板载 LED 和闪光灯其他数据手册和原理图ESP32-CAM 功耗 ESP32-CAM 引脚参考引脚排列GPIO 引脚哪些 GPIO 可以安全使用？GPIO 0 引脚MicroSD 卡引脚 ESP32-CAM 的烧录方式使用 ESP32-CAM-MB 编程…...

编程日记 2025/5/14 17:35:48

编译与汇编

本文来自《程序员的自我修养》编译过程是把预处理完的文件进行一系列词法分析，语法分析，语义分析以及优化后生成相应的汇编文件代码。现在版本的GCC把预编译和编译两个步骤合并为一个步骤。 gcc -S HelloWorld.c HelloWorld.sint main() {//test/* …...

编程日记 2025/5/11 15:52:24

Linux入门攻坚——43、keepalived入门-1

Linux Cluster（Linux集群的类型）：LB、HA、HPC，分别是负载均衡集群、高可用性集群、高性能集群。 LB：lvs，nginx HA：keepalived，heartbeat，corosync，cman HP&am…...

编程日记 2025/5/14 20:49:09

备考蓝桥杯：顺序表相关算法题

目录询问学号寄包柜移动0 颜色分类合并两个有序数组物品移动询问学号我们的思路：创建一个顺序表存储从1开始依次存放进入教室的学生学号，然后查询 #include <iostream> #include <vector> using namespace std; const int N 2…...

编程日记 2025/5/11 21:55:40

【STM32+QT项目】基于STM32与QT的智慧粮仓环境监测与管理系统设计（完整工程资料源码）

视频演示：基于STM32与QT的智慧粮仓环境监测与管理系统设计目录：目录视频演示：目录：前言：...

编程日记 2025/4/29 9:58:13

Vue3 自定义hook

文章目录 Vue3 自定义hook概述用法 Vue3 自定义hook 概述 Vue3推荐利用Vue的组合式API函数进行代码封装，这种封装方式统称为自定义hook。用法定义 hook/countHook.js： import {computed, ref, watch} from "vue";export default (initC…...

编程日记 2025/5/13 17:28:46

【VBA】【EXCEL】将某列内容横向粘贴到指定行

Sub CopyRowToColumn()On Error GoTo ErrorHandler 添加错误处理Application.ScreenUpdating FalseApplication.Calculation xlCalculationManualApplication.EnableEvents False 禁用事件处理Dim lastCol As LongDim lastRow As LongDim i As Long, colCount As LongDim …...

编程日记 2025/5/15 9:54:14

使用Llama 3.1创建合成数据集以调优你的大型语言模型

使用Llama 3.1创建合成数据集以调优你的大型语言模型在数据驱动的人工智能领域，数据是核心资产。开发高质量数据集既复杂又昂贵，因此很多实验室和开发者选择使用合成数据集。本文将介绍如何利用大型语言模型Llama 3.1 405B创建合成数据集，并…...

编程日记 2025/5/10 8:32:43

【Ubuntu22.04】VMware虚拟机硬盘扩容

1.首先打开虚拟机设置 2.根据需要对硬盘扩展这边提示我们还需要进入虚拟机在内部分区 3.安装界面化磁盘管理工具 # 安装 sudo apt install gparted# 启动 sudo gparted调整硬盘大小调整的时候会提示我们硬盘是只读的，因此还要进行操作新建终端重新挂载文件系…...

编程日记 2025/5/13 18:01:11

初学stm32 --- DMA直接存储器

目录 DMA介绍 STM32F1 DMA框图 DMA处理过程 DMA通道 DMA优先级 DMA相关寄存器介绍 F1 DMA通道x配置寄存器（DMA_CCRx） DMA中断状态寄存器（DMA_ISR） DMA中断标志清除寄存器（DMA_IFCR） DMA通道x传输…...

编程日记 2025/5/14 2:25:30

reactor中的并发

1. reactor中的并发有两种方式 1.1 flatmap，底层是多线程并发处理。在reactor的演讲中，flatmap对于io类型的并发效果较好. flamap有两个参数: int concurrency, int prefetch。分别代表并发的线程数和缓存大小注意凡是参数中有prefetch的，都…...

编程日记 2025/5/14 22:09:27

为什么要保证消息的可靠性？

消费者确认机制

消费者重试机制

测试

业务的幂等性判断

相关文章：