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;

    @PostConstruct
    public void init() {
        rabbitTemplate.setReturnsCallback(new RabbitTemplate.ReturnsCallback() {
            @Override
            public 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. 创建CorrelationData
    CorrelationData cd = new CorrelationData();
    
    // 2. 给Future添加ConfirmCallback
    cd.getFuture().addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {
        @Override
        public void onFailure(Throwable ex) {
            // 2.1. Future发生异常时的处理逻辑,基本不会触发
            log.error("handle message ack fail", ex);
        }

        @Override
        public 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,告知投递失败。

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/924883.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

租辆酷车小程序开发(二)—— 接入微服务GRPC

vscode中golang的配置 设置依赖管理 go env -w GO111MODULEon go env -w GOPROXYhttps://goproxy.cn,direct GO111MODULEauto 在$GOPATH/src 外面且根目录有go.mod 文件时&#xff0c;开启模块支持 GO111MODULEoff 无模块支持&#xff0c;go会从GOPATH 和 vendor 文件夹寻找包…

Qt6.8安卓Android开发环境配置

时隔多年&#xff0c;重拾QtCreator下Android开发。发现Qt6下安卓开发环境配置变简单不少&#xff01;只需三步即可在QtCreator下进行Android开发&#xff1a; 一、使用Qt Mantenance Tool进行Android模块的安装&#xff1a; 如果感觉安装网速较慢&#xff0c;可以查看本人另外…

Java篇——Java通过JNA调用c++库时传参含有结构体时数据错乱的解决办法

Java通过JNA调用c库时传参含有结构体时&#xff0c;只继承Structure是不够的&#xff0c;还需要实现Structure.ByValue&#xff0c;或者强制指定结构体字节对齐。示例如下&#xff1a; 1、c库中的结构体定义&#xff1a; 2、java中结构体定义&#xff1a; 3、java中调用 如果没…

websocket前后端长连接之java部分

一共有4个类,第一个WebSocketConfig 配置类 Configuration EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer {Autowiredprivate WebSocketHandler webSocketHandler;Autowiredprivate WebSocketInterceptor webSocketInterceptor;Overridepubli…

微软企业邮箱:安全可靠的企业级邮件服务!

微软企业邮箱的设置步骤&#xff1f;如何注册使用烽火域名邮箱&#xff1f; 微软企业邮箱作为一款专为企业设计的邮件服务&#xff0c;不仅提供了高效便捷的通信工具&#xff0c;更在安全性、可靠性和功能性方面树立了行业标杆。烽火将深入探讨微软企业邮箱的多重优势。 微软…

【R安装】VSCODE安装及R语言环境配置

目录 VSCODE下载及安装VSCODE上配置R语言环境参考 Visual Studio Code&#xff08;简称“VSCode” &#xff09;是Microsoft在2015年4月30日Build开发者大会上正式宣布一个运行于 Mac OS X、Windows和 Linux 之上的&#xff0c;针对于编写现代Web和云应用的跨平台源代码编辑器&…

3D技术如何应用到汽车营销中?

3D线上展示技术在汽车营销中的应用&#xff0c;为传统汽车销售模式带来了革命性的变化。以下详细阐述这一技术如何被应用于汽车营销中&#xff1a; 一、提供沉浸式体验 3D全景看车&#xff1a;通过高清晰度的图像和全景展示&#xff0c;3D技术能够创造出身临其境的沉浸感&…

【小白学机器学习38】用np.random 生成各种随机数,随机数数组/序列

目录 0 总结 np.random() 的一些点 1 用np.random.random() 生成[0,1) 区间内的随机数 2 生成指定范围内的随机整数/数组 np.random.randint() 3 用np.random.choice()生成指定数组范围内的随机数 3.1 np.random.choice(array6) 3.2 np.random.choice(array6) &#xff0…

本地局域 基于ip地址生成证书

将这个脚本直接执行&#xff0c;然后输入需要绑定的ip和输入证书年限就可以了&#xff0c;然后配置nginx。 脚本&#xff1a;sslzhegnhsu.sh #! /bin/bashecho "请输入服务器IP地址" read ip echo "请输入证书年限" read yearyear$(expr $year 0)days…

影响因子和期刊质量之间有什么关系?

影响因子与期刊质量之间存在一定的联系&#xff0c;但这种关系并非绝对。以下是对两者关系的详细分析&#xff1a; 影响因子的定义&#xff1a;影响因子&#xff08;Impact Factor&#xff0c;简称IF&#xff09;是汤森路透出品的期刊引证报告&#xff08;Journal Citation Rep…

Js-对象-04-Array

重点关注&#xff1a;Array String JSON BOM DOM Array Array对象时用来定义数组的。常用语法格式有如下2种&#xff1a; 方式1&#xff1a; var 变量名 new Array(元素列表); 例如&#xff1a; var arr new Array(1,2,3,4); //1,2,3,4 是存储在数组中的数据&#xff0…

《Unity Shader 入门精要》高级纹理

立方体纹理 图形学中&#xff0c;立方体纹理&#xff08;Cubemap&#xff09;是环境映射&#xff08;Environment Mapping&#xff09;的一种实现方法。环境映射可以模拟物体周围的环境&#xff0c;而使用了环境映射的物体可以看起来像镀了层金属一样反射出周围的环境。 对立…

算法编程题-合并石头的最低成本

算法编程题-合并石头的最低成本 原题描述方法一、动态规划思路简述代码实现复杂度分析 方法二、动态规划&#xff08;状态优化&#xff09;思路简述代码实现复杂度分析 参考 摘要&#xff1a;本文将对LeetCode原题合并石头的最低成本进行介绍&#xff0c;思路基于动态规划&…

VirtualBox中设置共享文件夹(ubuntu系统)

一、在自己的电脑&#xff08;宿主机&#xff09;上新建一个文件夹 文件夹名字任意&#xff08;我的文件夹的名称为vgateshare&#xff09;&#xff0c;建完之后记住自己建的文件夹的路径&#xff0c;后续需要使用 二、在 VirtualBox进行设置 打开对应虚拟机界面&#xff0c…

【Flink】快速理解 FlinkCDC 2.0 原理

快速理解 FlinkCDC 2.0 原理 要详细理解 Flink CDC 原理可以看看这篇文章&#xff0c;讲得很详细&#xff1a;深入解析 Flink CDC 增量快照读取机制 (https://juejin.cn/post/7325370003192578075)。 FlnkCDC 2.0&#xff1a; Flink 2.x 引入了增量快照读取机制&#xff0c;…

华为悦盒【EC6108V9】通用刷机固件及详细教程

固件特点&#xff1a; 高度精简&#xff0c;删除原机 IPTV 等 APP。删除在线升级功能。支持多屏互动功能。内置 U 盘自动安装程序功能&#xff0c;或用当贝市场-文件管理安装程序。 自动安装说明&#xff1a;在 U盘 根目录新建名为“YueMe_BOX”的文件夹&#xff0c;把需要安装…

算法的NPU终端移植:深入探讨与实践指南

目录 ​编辑 引言 算法选择 模型压缩 权重剪枝 量化 知识蒸馏 硬件适配 指令集适配 内存管理 并行计算 性能测试 速度测试 精度测试 功耗测试 案例分析 图像识别算法的NPU移植案例 结论 引言 在人工智能技术的浪潮中&#xff0c;神经网络处理器&#xff08;…

尚硅谷学习笔记——Java设计模式(一)设计模式七大原则

一、介绍 在软件工程中&#xff0c;设计模式&#xff08;design pattern&#xff09;是对软件设计中普遍存在&#xff08;反复出现&#xff09;的各种问题&#xff0c;提出的解决方案。我们希望我们的软件能够实现复用性、高稳定性、扩展性、维护性、代码重用性&#xff0c;所以…

CentOS7如何同时安装Java8和Java17

Java17是长期支持版本&#xff0c;升级到Java17的公司越来越多&#xff0c;特别是Spring Boot3.0最低要求Java17&#xff0c;放弃了对Java8的支持。 但是在升级的时候&#xff0c;还不能保证服务器上的所有Java进程都同步升级&#xff0c;所以系统需要同时安装Java8和Java17。 …

Python Turtle召唤童年:《哆啦A梦的奇妙世界》

Python Turtle召唤童年&#xff1a;《哆啦A梦的奇妙世界》 &#x1f438; 前言 &#x1f438;&#x1f40b; 效果图 &#x1f40b;&#x1f409; 代码 &#x1f409; &#x1f438; 前言 &#x1f438; 欢迎来到 《哆啦A梦的奇妙世界》&#xff0c;在这个博客里&#xff0c;我们…