rabbittemplate.confirmcallback

时间: 2023-05-01 21:05:04 浏览: 101

RabbitMQ-高级篇.pdf

### RabbitMQ 高级篇知识点解析 #### 一、消息可靠性消息从生产者发出到被消费者接收的过程中，会经历多个阶段，其中任一环节都可能导致消息丢失。常见的情况包括： 1. **发送时丢失**：生产者发送的消息未能到达交换机（Exchange）。 2. **到达交换机后未到达队列**：即使消息到达了交换机，也可能未能成功存储到队列（Queue）中。 3. **MQ服务宕机**：队列中的消息可能因MQ服务故障而丢失。 4. **Consumer端故障**：消费者接收到消息但未能成功处理消息即发生故障。针对以上问题，RabbitMQ提供了以下解决方案： 1. **生产者确认机制**（Producer Confirm）：确保消息能够成功到达交换机。 2. **消息持久化**：使消息能够在队列中持久保存，避免服务重启导致数据丢失。 3. **消费者确认机制**（Consumer Acknowledgment）：确认消息已成功处理。 4. **失败重试机制**：对于处理失败的消息进行重试。 #### 二、生产者确认机制详解 RabbitMQ 提供了两种确认机制，分别为`publisher-confirm`和`publisher-return`。 ##### 1.1.1 修改配置为了启用生产者确认机制，需要在`application.yml`配置文件中添加以下内容： ```yaml spring: rabbitmq: publisher-confirm-type: correlated publisher-returns: true template: mandatory: true ``` - `publisher-confirm-type`: 开启确认模式，支持两种类型： - `simple`: 同步等待确认结果，直到超时。 - `correlated`: 异步回调，定义`ConfirmCallback`接口，在消息处理完成时调用此接口。 - `publisher-returns`: 开启`publisher-return`功能，同样是基于回调机制，定义`ReturnCallback`接口，用于处理消息路由失败的情况。 - `template.mandatory`: 定义消息路由失败时的策略。如果设置为`true`，则会调用`ReturnCallback`接口；如果设置为`false`，则直接丢弃消息。 ##### 1.1.2 定义Return回调由于每个`RabbitTemplate`实例只能配置一个`ReturnCallback`，因此需要在项目启动时配置： ```java import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.context.ApplicationContext; public class CommonConfig implements ApplicationContextAware { @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { // 获取RabbitTemplate RabbitTemplate rabbitTemplate = applicationContext.getBean(RabbitTemplate.class); // 设置ReturnCallback rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> { // 投递失败，记录日志 log.error("消息投递失败，replyCode: {}, replyText: {}, exchange: {}, routingKey: {}", replyCode, replyText, exchange, routingKey); }); } } ``` ##### 1.1.3 定义ConfirmCallback 在`SpringAmqpTest`类中定义一个单元测试方法，用于实现`ConfirmCallback`接口，该接口允许在发送消息时指定，以便根据不同业务场景处理确认成功或失败的情况： ```java import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback; import org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback; import org.springframework.test.context.TestPropertySource; import org.springframework.test.context.junit.jupiter.SpringJUnitConfig; @SpringJUnitConfig(CommonConfig.class) @TestPropertySource(locations = "classpath:application.yml") public class SpringAmqpTest { @Autowired private RabbitTemplate rabbitTemplate; @Test public void testConfirm() { rabbitTemplate.setConfirmCallback(new ConfirmCallback() { @Override public void handle(Long deliveryTag, boolean multiple, boolean ack) { if (ack) { log.info("消息处理成功，deliveryTag: {}", deliveryTag); } else { log.warn("消息处理失败，deliveryTag: {}", deliveryTag); } } }); rabbitTemplate.convertAndSend("exchange", "routingKey", "test message"); } } ``` #### 三、总结本文主要介绍了RabbitMQ高级篇中的关键概念之一——消息可靠性及其解决方案。通过详细解析生产者确认机制的配置与实现，展示了如何确保消息在从生产者到消费者的整个传递过程中不会丢失。这对于构建可靠的消息中间件系统至关重要。此外，还探讨了消息持久化、消费者确认机制以及失败重试机制等其他重要的可靠性保障措施。这些技术点对于实际应用中的系统设计与开发具有重要意义。

b'rabbittemplate.confirmcallback' 是 RabbitMQ 中使用的一个回调函数，用于确认消息是否已成功发送到消息队列。当消息被成功发送到消息队列时，会调用该回调函数来进行确认。

阅读全文

rabbittemplate.confirmcallback

相关推荐

基于企业微信的开源 SCRM 系统，采用主流的 Java 微服务架构

rabbitmq.zip

RabbitTemplate.ConfirmCallback

Srping boot中 实现 RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnsCallback 无法触发回调函数

rabbitTemplate.setConfirmCallback

RabbitTemplate的confirmCallback和returnCallback如何使用

解释RabbitTemplate的confirmCallback和returnCallback

Only one ConfirmCallback is supported by each RabbitTemplate 如何解决

rabbitmq confirmcallback

spring boot 整合rabbitmq 使用 RabbitTemplate 实现 ACK 消息确认 最简单实现

confirmCallback

rabbitmq中confirm模式通过yml文件中的publisher-confirm-type: correlated设置后，还需要调用confirmSelect()方法吗

springboot rabbitmq 生产端设置消费成功后 自动删除队列里面的数据，配置rabbitTemplate

RabbitMQ保证消息的一致性java实现

rabbitmq confirm spring代码

springboot rabbitmq可靠性

使用了rabbitmq的convertAndSend方法没有报错但是队列没有新增的消息

testRabbitMq.zip

最新推荐

python入门-30.寻找列表中只出现一次的数字-寻找单身狗.py

布尔教育linux优化笔记

知识付费系统-直播+讲师入驻+课程售卖+商城系统-v2.1.9版本搭建以及资源分享下载

美妆神域-JAVA-基于springBoot美妆神域设计与实现

原生js制作Google粘土logo动画涂鸦代码.zip

火炬连体网络在MNIST的2D嵌入实现示例

管理建模和仿真的文件

L2正则化的终极指南：从入门到精通，揭秘机器学习中的性能优化技巧

如何构建一个符合GB/T19716和ISO/IEC13335标准的信息安全事件管理框架，并确保业务连续性规划的有效性？

Angular插件增强Application Insights JavaScript SDK功能

Srping boot中实现 RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnsCallback 无法触发回调函数

spring boot 整合rabbitmq 使用 RabbitTemplate 实现 ACK 消息确认最简单实现

springboot rabbitmq 生产端设置消费成功后自动删除队列里面的数据，配置rabbitTemplate