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

RabbitMQ 消息确认机制

RabbitMQ 消息确认机制

本文总结了RabbitMQ消息发送过程中的一些代码片段,详细分析了回调函数和发布确认机制的实现,以提高消息传递的可靠性。


返回回调机制的代码分析

主要用途

这个代码主要用于设置RabbitMQ消息发送过程中的回调函数,即在消息不能被成功投递到目标队列时的返回回调处理。具体来说,它使用RabbitTemplate对象来设置ReturnsCallback回调函数,这个回调函数可以帮助开发者在消息无法正确路由到队列时获得相关的反馈信息。

代码详细分析

类与注解
  • @Slf4j:用来生成一个用于日志记录的log对象,方便日志输出。
  • @AllArgsConstructor:自动生成全参构造器,使得可以方便地初始化类的所有字段。
  • @Configuration:表明这是一个Spring配置类,用于定义一些Bean。
RabbitTemplate的初始化
  • private final RabbitTemplate rabbitTemplate;:这是一个RabbitTemplate对象,用于与RabbitMQ进行交互操作。
  • @PostConstruct:标注的方法将在所有依赖项注入完成后自动调用,通常用于初始化逻辑。
init() 方法
  • rabbitTemplate.setReturnsCallback(...):设置一个回调函数,当消息不能正确路由时会触发这个回调。
  • new RabbitTemplate.ReturnsCallback():匿名内部类,用于定义ReturnsCallback的逻辑。
  • public void returnedMessage(ReturnedMessage returned):这是实现ReturnsCallback接口中的方法,它负责处理返回的消息。
returnedMessage() 方法中的具体逻辑
  • log.error("触发return callback,"):表示触发了返回回调,记录一条错误日志。
  • log.debug(...):输出了消息在返回时的各种属性,包括:
    • exchange:消息发送到的交换机名称。
    • routingKey:用于路由消息的路由键。
    • message:具体的消息内容。
    • replyCodereplyText:返回码及返回的文本,表明返回的原因。
方法执行的时机
  • 当RabbitMQ消息没有成功被路由到指定的队列时,这个回调函数将被调用。典型的场景是队列不存在、交换机配置错误或路由键不匹配等情况。
  • 这种情况下,RabbitMQ会触发返回回调,通过returnedMessage()方法通知应用程序该消息未能被成功投递。
代码示例
@Slf4j
@AllArgsConstructor
@Configuration
public class MqConfig {private final RabbitTemplate rabbitTemplate;@PostConstructpublic void init() {rabbitTemplate.setReturnsCallback(new RabbitTemplate.ReturnsCallback() {@Overridepublic void returnedMessage(ReturnedMessage returned) {log.error("触发return callback,");log.debug("exchange: {}", returned.getExchange());log.debug("routingKey: {}", returned.getRoutingKey());log.debug("message: {}", returned.getMessage());log.debug("replyCode: {}", returned.getReplyCode());log.debug("replyText: {}", returned.getReplyText());}});}
}

代码的用途

  • 当RabbitMQ消息没有成功被路由到指定的队列时,这个回调函数将被调用。
  • 典型的场景是队列不存在、交换机配置错误或路由键不匹配等情况。
  • 通过这些日志输出,开发人员可以方便地定位问题所在,了解为什么消息未能成功发送到队列中。
  • 这个回调可以提高系统的健壮性,确保消息发送的可靠性,如果消息丢失或出现其他问题,可以通过日志及时发现并进行处理。

总结:这个代码主要用于设置RabbitMQ的返回回调机制,以便在消息发送失败时可以及时进行处理和日志记录。它是消息可靠传输的一部分,尤其适用于需要高可靠性的消息传递场景。


发布确认机制的代码分析

主要用途

这个代码演示了如何在RabbitMQ中使用**发布确认(Publisher Confirm)**的机制,确保消息成功到达交换机并获得确认(ack)。通过这种机制,应用程序可以在消息发送到交换机后获得反馈,确认是否发送成功,从而提高消息传输的可靠性。

代码详细分析

方法注解与声明
  • @Test:表示这是一个测试方法,通常用JUnit等测试框架来执行,测试消息发送的过程。
  • void testPublisherConfirm():方法名表明该方法用于测试发布者的确认(Publisher Confirm)。
创建CorrelationData对象
  • CorrelationData cd = new CorrelationData();
    • CorrelationData对象用于追踪每个消息的唯一标识。
    • 在发布消息时,相关的确认信息与该对象进行关联。
    • 通过该对象,可以区分出每条消息的确认状态。
设置ConfirmCallback回调
  • cd.getFuture().addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {...})

    • 使用了一个ListenableFutureCallback来监听消息的确认结果。
    • addCallback()方法用于指定回调逻辑,当消息被确认(或失败)时,执行对应的逻辑。
  • onFailure(Throwable ex)

    • 如果消息确认过程中发生异常,则会进入onFailure()方法。
    • log.error("handle message ack fail", ex):记录一条错误日志,表明消息的确认失败,并输出具体异常信息。
  • onSuccess(CorrelationData.Confirm result)

    • 如果消息成功被确认,则会进入onSuccess()方法。
    • result.isAck():判断确认结果是否为ack,即成功确认。
    • 如果isAck()返回true,则记录日志,表示消息成功接收。
    • 如果返回false,则表示消息未被确认(即nack),需要处理相应的失败情况,记录错误日志并输出原因。
发送消息
  • rabbitTemplate.convertAndSend("hmall.direct", "red1", "hello", cd)
    • rabbitTemplate是用于发送消息的模板对象。
    • convertAndSend()方法用于发送消息,参数分别为:
      • "hmall.direct":交换机名称。
      • "red1":路由键。
      • "hello":消息内容。
      • cd:之前创建的CorrelationData对象,用于追踪该消息的状态。
方法执行的时机
  • onFailure(Throwable ex)方法会在消息确认过程中出现异常时被调用,例如由于网络中断或RabbitMQ服务器不可用等情况,导致消息无法被正确发送或确认。
  • onSuccess(CorrelationData.Confirm result)方法会在RabbitMQ成功处理消息时被调用,返回确认结果(ack)或者未确认结果(nack)。如果交换机成功接收了消息但队列出现问题,则可能返回nack。
代码示例
@Test
void testPublisherConfirm() throws InterruptedException {// 1. 创建CorrelationDataCorrelationData cd = new CorrelationData();// 2. 给Future添加ConfirmCallbackcd.getFuture().addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {@Overridepublic void onFailure(Throwable ex) {// 2.1. Future发生异常时的处理逻辑,基本不会触发log.error("handle message ack fail", ex);}@Overridepublic void onSuccess(CorrelationData.Confirm result) {// 2.2. Future接收到确认的处理逻辑,参数中的result就是回执内容if(result.isAck()){ // result.isAck(),boolean类型,true代表ack回执,false 代表 nack回执log.debug("发送消息成功, 收到 ack!");} else {log.error("发送消息失败, 收到 nack, reason: {}", result.getReason());}}});// 3. 发送消息rabbitTemplate.convertAndSend("hmall.direct", "red1", "hello", cd);
}

发布确认机制在MQ中的作用

消息的可靠性传输
  • 发布者确认(Publisher Confirm)机制确保消息从生产者成功发送到交换机,并获得交换机的确认。
  • 通过这种方式,可以保证消息不会因为网络故障或者交换机问题而丢失。
失败处理
  • 通过在onFailure()方法中记录异常,可以帮助开发者了解在发送过程中出现的错误。
  • onSuccess()中处理acknack,使得开发者可以及时知道消息是否被交换机接收并正确处理。
提高系统健壮性
  • 确保消息传递的可靠性,当消息未被正确确认(例如nack)时,可以及时记录日志或者进行补救措施(例如重新发送消息)。
  • 特别适用于金融系统、电商订单等需要高可靠性的场景。

总结:这个代码演示了在RabbitMQ中使用发布者确认机制,以提高消息传递的可靠性。通过监听消息的确认结果,可以确保消息是否成功到达交换机,并在失败的情况下做出适当的处理。这种机制非常适用于需要高可靠性消息传递的系统,以确保消息不会丢失。


发布者确认和返回机制总结

在这里插入图片描述

Spring AMQP提供了Publisher ConfirmPublisher Return两种确认机制。开启确认机制后,当发送者发送消息给MQ后,MQ会返回确认结果给发送者。返回的结果有以下几种情况:

  • 消息投递到了MQ,但路由失败。此时会通过PublisherReturn返回路由异常原因,然后返回ACK,告知投递成功。
  • 临时消息投递到了MQ,并且入队成功,返回ACK,告知投递成功。
  • 持久消息投递到了MQ,并且入队完成持久化,返回ACK,告知投递成功。
  • 其它情况都会返回NACK,告知投递失败。

通过以上机制,消息的可靠性得到进一步保证。结合代码和确认机制,开发者可以更加精细地控制消息的生命周期和状态,以确保业务逻辑的健壮性和可靠性。

相关文章:

RabbitMQ 消息确认机制

RabbitMQ 消息确认机制 本文总结了RabbitMQ消息发送过程中的一些代码片段&#xff0c;详细分析了回调函数和发布确认机制的实现&#xff0c;以提高消息传递的可靠性。 返回回调机制的代码分析 主要用途 这个代码主要用于设置RabbitMQ消息发送过程中的回调函数&#xff0c;即…...

Node.js:开发和生产之间的区别

Node.js 中的开发和生产没有区别&#xff0c;即&#xff0c;你无需应用任何特定设置即可使 Node.js 在生产配置中工作。但是&#xff0c;npm 注册表中的一些库会识别使用 NODE_ENV 变量并将其默认为 development 设置。始终在设置了 NODE_ENVproduction 的情况下运行 Node.js。…...

【QT】背景,安装和介绍

TOC 目录 背景 GUI技术 QT的安装 使用流程 QT程序介绍 main.cpp​编辑 Wiget.h Widget.cpp form file .pro文件 临时文件 C作为一门比较古老的语言&#xff0c;在人们的认知里始终是以底层&#xff0c;复杂和高性能著称&#xff0c;所以在很多高性能需求的场景之下…...

从0到1搭建webpack

好&#xff0c;上一篇文章我们说了一下在react中怎么弄这个webpack&#xff0c;那么现在在说一下不用react我们又该怎么配置&#xff0c;这些呢也都是我自己通弄过看视频自己总结的&#xff0c;拿来给大家分享一下。 前期准备条件 1、nvm&#xff08;可以快速切换node版本&am…...

针对解决conda环境BUG的个人笔记

1-conda学习&安装 安装视频&#xff1a; 零基础教程&#xff1a;基于Anaconda和PyCharm配置Pytorch环境_哔哩哔哩_bilibili 安装过程&#xff1a; MX250笔记本安装Pytorch、CUDA和cuDNN-CSDN博客 Win10MX250CUDA10.1cuDNNPytorch1.4安装测试全过程(吐血)_nvidia geforc…...

读《Effective Java》笔记 - 条目13

条目13&#xff1a;谨慎重写clone方法 浅拷贝和深拷贝 浅拷贝&#xff08;Shallow Copy&#xff09; 浅拷贝 只复制对象本身&#xff0c;而不复制对象引用的成员。 对于引用类型的字段&#xff0c;浅拷贝会将原对象的引用复制到新对象中&#xff0c;而不会创建新对象实例。因…...

SQL 之连接查询

SQL 连接查询&#xff1a;深入理解 JOIN 操作 在数据库管理中&#xff0c;连接查询&#xff08;JOIN&#xff09;是一种基本而强大的操作&#xff0c;它允许我们从两个或多个表中检索数据。SQL 中的 JOIN 操作使得数据整合变得简单&#xff0c;这对于数据分析和报告至关重要。…...

vscode切换anaconda虚拟环境解释器不成功

问题&#xff1a; 切换解释器之后运行代码还是使用的原来的解释器 可以看到&#xff0c;我已经切换了“nlp”解释器&#xff0c;我的nltk包只在“nlp”环境下安装了&#xff0c;但是运行代码依然是"torch"解释器&#xff0c;所以找不到“nltk”包。 在网上找了各种…...

一个实用的 Maven localRepository 工具

目录 1 现状2 当前解决3 更好的解决3.1 下载 Maven localRepository 工具包3.2 上传本地 localRepository 包3.3 清理 localRepository 中指定后缀的文件 1 现状 在使用 Maven 时&#xff0c;我们可能会经常与本地仓库和私服仓库打交道。 例如对于本地仓库&#xff0c;因为某…...

目标检测,图像分割,超分辨率重建

目标检测和图像分割 目标检测和图像分割是计算机视觉中的两个不同任务&#xff0c;它们的输出形式也有所不同。下面我将分别介绍这两个任务的输出。图像分割又可以分为&#xff1a;语义分割、实例分割、全景分割。 语义分割&#xff08;Semantic Segmentation&#xff09;&…...

微信小程序 城市点击后跳转 并首页显示被点击城市

在微信小程序中&#xff0c;渲染出城市列表后&#xff0c;如何点击城市&#xff0c;就跳转回到首页&#xff0c;并在首页显示所点击的城市呢&#xff1f; 目录 一、定义点击城市的事件 二、首页的处理 首页&#xff1a;点击成都市会跳转到城市列表 城市列表&#xff1a;点击…...

Linux - nfs服务器

五、nfs服务器 1、基础 NFS服务器可以让PC将网络中的NFS服务器共享的目录挂载到本地端的文件系统中&#xff0c;而在本地端的系统 中看来&#xff0c;那个远程主机的目录就好像是自己的一个磁盘分区一样。 由于NFS支持的功能比较多&#xff0c;而不同的功能都会使用不同的程…...

uniapp图片上传预览uni.chooseImage、uni.previewImage

文章目录 1.上传图片2.预览图片 1.上传图片 uni.chooseImage(OBJECT) 从本地相册选择图片或使用相机拍照。 App端如需要更丰富的相机拍照API&#xff08;如直接调用前置摄像头&#xff09;&#xff0c;参考plus.camera 微信小程序从基础库 2.21.0 开始&#xff0c; wx.choos…...

C++ 字符串中数字识别

【问题描述】 输入一个字符串&#xff0c;含有数字和非数字字符&#xff0c;如“sumabc234;while(abc700)tab{ass346;bssabc267;}”&#xff0c;将其中连续的数字作为一个整数&#xff0c;依次存放到一个数组nums中。例如&#xff0c;234放在nums[0]&#xff0c;700放在nums[1…...

学术中常见理论归纳总结-不定期更新

1.信息传播类 1.1 扩散创新理论 创新扩散理论是传播效果研究的经典理论之一,是由美国学者埃弗雷特罗杰斯(E.M.Rogers)于20世纪60年代提出的一个关于通过媒介劝服人们接受新观念、新事物、新产品的理论,侧重大众传播对社会和文化的影响。 1927-1941年进行的“艾奥瓦杂交玉…...

ModelSim怎么修改字体及大小

点击TOOLS 选择PERFERENCES选择下一级菜单的TEXTFONT/CHOOSE/选择字体和大小最后不要忘记点apply再退出...

图片预处理技术介绍4——降噪

图片预处理 大家好&#xff0c;我是阿赵。   这一篇将两种基础的降噪算法。   之前介绍过均值模糊和高斯模糊。如果从降噪的角度来说&#xff0c;模糊算法也算是降噪的一类&#xff0c;所以之前介绍的两种模糊可以称呼为均值降噪和高斯降噪。不过模糊算法对原来的图像特征的…...

Scrapy管道设置和数据保存

1.1 介绍部分&#xff1a; 文字提到常用的Web框架有Django和Flask&#xff0c;接下来将学习一个全球范围内流行的爬虫框架Scrapy。 1.2 内容部分&#xff1a; Scrapy的概念、作用和工作流程 Scrapy的入门使用 Scrapy构造并发送请求 Scrapy模拟登陆 Scrapy管道的使用 Scrapy中…...

D84【python 接口自动化学习】- pytest基础用法

day84 pytest常用断言类型 学习日期&#xff1a;20241130 学习目标&#xff1a;pytest基础用法 -- pytest常用断言类型 学习笔记&#xff1a; 常用断言类型 代码实践 def test_assert():assert 11assert 1!2assert 1<2assert 2>1assert 1>1assert 1<1assert a…...

如何正确书写sh文件/sh任务?bash任务

正确书写xx.sh文件的方式为&#xff1a; source /usr/local/miniconda3/bin/activate condaEnv export CUDA_VISIBLE_DEVICES0 cd /hy-tmp/test export PYTHONPATH"xxx:$PYTHONPATH" python AAA.py python BBB.py python CCC.py 直接运行&#xff1a; bash xx.sh 即可…...

消费级显卡也能跑!cv_resnet101_face-detection_cvpr22papermogface GPU算力适配实战

消费级显卡也能跑&#xff01;cv_resnet101_face-detection_cvpr22papermogface GPU算力适配实战 1. 项目简介与核心价值 今天给大家分享一个特别实用的人脸检测工具——基于MogFace模型的高精度人脸检测系统。这个工具最大的亮点就是消费级显卡就能流畅运行&#xff0c;不需…...

ZeroOmega代理规则引擎:构建智能化网络访问策略

ZeroOmega代理规则引擎&#xff1a;构建智能化网络访问策略 【免费下载链接】ZeroOmega Manage and switch between multiple proxies quickly & easily. 项目地址: https://gitcode.com/gh_mirrors/ze/ZeroOmega 在数字化生活中&#xff0c;我们每天都在与各种网络…...

Android开发避坑指南:RecyclerView最后一行被截断的5种原因及对应解决方案

Android开发避坑指南&#xff1a;RecyclerView最后一行被截断的5种原因及对应解决方案 在Android应用开发中&#xff0c;RecyclerView作为列表展示的核心组件&#xff0c;其灵活性和高性能深受开发者喜爱。然而&#xff0c;在实际项目中&#xff0c;我们经常会遇到一个令人头疼…...

Java 新纪元 — JDK 25 + Spring Boot 4 全栈实战(十七):Boot 3 → Boot 4 迁移避坑指南——那些文档不会告诉你的迁移血泪史

系列导航 | ← 上一篇:D16 Spring Boot 4 + AI推理后端集成 | 下一篇:D18 云原生部署:Docker + K8s + GraalVM → 适用读者:正在从 Spring Boot 3.x 升级到 4.x 的开发者,或在评估升级可行性的架构师。 前置知识:熟悉 Spring Boot 3.x 开发,了解 JDK 21+ 基本特性。 本文…...

sdkman 一键切换 JDK 版本管理工具

&#x1f449; 这是一个或许对你有用的社群&#x1f431; 一对一交流/面试小册/简历优化/求职解惑&#xff0c;欢迎加入「芋道快速开发平台」知识星球。下面是星球提供的部分资料&#xff1a; 《项目实战&#xff08;视频&#xff09;》&#xff1a;从书中学&#xff0c;往事中…...

2026年嘎嘎降AI用了30天,说几句真心话

论文写完用AI检测一查&#xff0c;知网AIGC率60%多&#xff0c;心里一凉。 这种情况现在太常见了。2026年各大高校对AIGC检测的要求比以前严了不少&#xff0c;很多人都在找降AI工具。这篇文章就是把我用过的几款主流工具汇总一下&#xff0c;帮你少走弯路。 测试前说一件重要…...

Hunyuan-MT-7B在Win11系统下的高效部署与性能调优

Hunyuan-MT-7B在Win11系统下的高效部署与性能调优 最近腾讯开源的Hunyuan-MT-7B翻译模型挺火的&#xff0c;70亿参数就拿下了WMT2025比赛里31个语种中的30个第一&#xff0c;支持33种语言互译&#xff0c;包括一些少数民族语言和方言。性能这么强&#xff0c;很多朋友都想在本…...

OpenClaw+GLM-4.7-Flash实战:个人自动化办公助手搭建指南

OpenClawGLM-4.7-Flash实战&#xff1a;个人自动化办公助手搭建指南 1. 为什么选择本地AI办公助手 去年夏天&#xff0c;我发现自己每天要花3小时处理重复性办公任务&#xff1a;整理邮件、归档文档、撰写会议纪要。当我尝试用传统RPA工具时&#xff0c;发现它们要么太死板&a…...

MacOS极简部署OpenClaw:GLM-4.7-Flash云端沙盒体验

MacOS极简部署OpenClaw&#xff1a;GLM-4.7-Flash云端沙盒体验 1. 为什么选择云端沙盒体验 作为一个长期在本地折腾各种AI工具的技术爱好者&#xff0c;我最近被OpenClaw的自动化能力深深吸引。但在第一次尝试本地部署时&#xff0c;就被Node环境配置、依赖冲突等问题劝退。直…...

eClinMed(IF=10)上海交通大学医学院附属仁济医院泌尿外科陈锐教授等团队:用于原发性腹膜后肿瘤诊断与分割的端到端深度学习模型

01 文献学习 今天分享的文献是由上海交通大学医学院附属仁济医院泌尿外科陈锐教授等团队于2025年9月在《eClinicalMedicine》&#xff08;中科院1区top&#xff0c;IF10&#xff09;上发表的研究”End-to-end deep learning model for the diagnosis and segmentation of prim…...