RabbitMQ 消息确认机制

server/2024/11/29 21:28:58/

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：具体的消息内容。
    • replyCode 和 replyText：返回码及返回的文本，表明返回的原因。
方法执行的时机
  • 当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()中处理ack和nack，使得开发者可以及时知道消息是否被交换机接收并正确处理。
提高系统健壮性
  • 确保消息传递的可靠性，当消息未被正确确认（例如nack）时，可以及时记录日志或者进行补救措施（例如重新发送消息）。
  • 特别适用于金融系统、电商订单等需要高可靠性的场景。

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

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

在这里插入图片描述

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

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

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


http://www.ppmy.cn/server/145996.html

相关文章

如何利用蓝燕云零代码平台构建工程企业成本控制系统？

如何利用蓝燕云零代码平台构建工程企业成本控制系统？

随着工程项目管理逐步走向数字化&#xff0c;企业对成本控制的精细化需求不断提升。利用蓝燕云零代码平台&#xff0c;可快速构建一套高效、智能的成本控制系统&#xff0c;实现从预算编制到分析决策的全流程管理。 一、核心功能模块 1. 预算与成本管理 预算编制&#xff1a;…
阅读更多...
什么是Web Worker？如何使用Web Worker？

什么是Web Worker？如何使用Web Worker？

1. 什么是 Web Worker&#xff1f; JavaScript 语言采用的是单线程的&#xff0c;也就是说&#xff0c;所有任务只能在一个线程上完成&#xff0c;一次只能做一件事。前面的任务没做完&#xff0c;后面的任务只能等着。 Web Worker 是一种在浏览器中实现多线程处理的技术&…
阅读更多...
详谈面试题：Vue、React为什么使用虚拟DOM

详谈面试题：Vue、React为什么使用虚拟DOM

虚拟DOM是一种在前端框架中广泛使用的技术&#xff0c;它可以提升开发效率。那么国外流行的框架svelte没有使用虚拟DOM&#xff0c;而是直接操作真实DOM&#xff0c;效率依然很高。为什么Vue和React不采用这种方式呢&#xff1f; 目录 一、框架设计 二、解耦运行环境 三、总…
阅读更多...
GPU 选型指南

GPU 选型指南

根据 GPU 架构的不同&#xff0c;可分为以下几类&#xff1a; NVIDIA Volta 架构 代表型号&#xff1a; V100 配备第二代 Tensor Core&#xff0c;是较早支持深度学习的 GPU&#xff0c;仍适用于部分训练任务。性能特点&#xff1a;相比后续架构&#xff0c;V100 的训练性能…
阅读更多...
【es6】原生js在页面上画矩形添加选中状态高亮及显示调整大小控制框(三)

【es6】原生js在页面上画矩形添加选中状态高亮及显示调整大小控制框(三)

接上篇文章&#xff0c;这篇实现下选中当前元素显示调整大小的控制框&#xff0c;点击document取消元素的选中高亮状态效果。 实现效果 代码逻辑 动态生成控制按钮矩形,并设置响应的css // 动态添加一个调整位置的按钮addScaleBtn(target) {const w target.offsetWidth;con…
阅读更多...
Flutter：encrypt插件 AES加密处理

Flutter：encrypt插件 AES加密处理

1、pubspec.yaml导入插件 cupertino_icons: ^1.0.8 # 密码加密 encrypt: 5.0.3encrypt封装 import package:encrypt/encrypt.dart; /// 加密类 class EncryptUtil {static final EncryptUtil _instance EncryptUtil._internal();factory EncryptUtil() > _instance;Encrypt…
阅读更多...
C#身份证识别接口集成、身份证文字信息提取、身份证信息录入

C#身份证识别接口集成、身份证文字信息提取、身份证信息录入

身份证识别接口为什么会受到互联网平台的青睐&#xff1f;传统的身份验证方式往往需要用户手动输入个人信息&#xff0c;这不仅耗时耗力&#xff0c;还容易出现误操作影响身份认证结果的现象。翔云身份证识别接口通过先进的OCR&#xff08;光学字符识别&#xff09;技术&#x…
阅读更多...
使用 Python 的 pdfplumber 库高效解析 PDF 文件

使用 Python 的 pdfplumber 库高效解析 PDF 文件

使用 Python 的 pdfplumber 库高效解析 PDF 文件 PDF 文件是日常办公和数据处理中常见的文件格式&#xff0c;而 pdfplumber 是一个专为 PDF 文件解析设计的 Python 库&#xff0c;可以轻松提取文本、表格、图像等内容。本文将介绍 pdfplumber 的基本功能、使用方法&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023