SpringBoot RabbitMQTemplate消费者确认机制怎么选?

 更新时间:2026年07月24日 14:46:34   作者:Quare_feifei  
本文详解SpringBoot中RabbitMQTemplate的消费者消息确认机制,包括manual、auto、none三种模式的区别,同时介绍消费者失败重试与失败策略,助你避免消息丢失和无限重试,确保系统可靠

这里主要是针对springboot中的rabbitmqtemplate来说的

基础代码以查看此专栏相关文章

消费者消息确认

RabbitMQ是阅后即焚机制,RabbitMQ确认消息被消费者消费后会立刻删除。

而RabbitMQ是通过消费者回执来确认消费者是否成功处理消息的:消费者获取消息后,应该向RabbitMQ发送ACK回执,表明自己已经处理消息。

设想这样的场景

  • 1)RabbitMQ投递消息给消费者
  • 2)消费者获取消息后,返回ACK给RabbitMQ
  • 3)RabbitMQ删除消息
  • 4)消费者宕机,消息尚未处理

这样,消息就丢失了。因此消费者返回ACK的时机非常重要。

SpringAMQP则允许配置三种确认模式

  • manual:手动ack,需要在业务代码结束后,调用api发送ack。
  • auto:自动ack,由spring监测listener代码是否出现异常,没有异常则返回ack;抛出异常则返回nack
  • none:关闭ack,MQ假定消费者获取消息后会成功处理,因此消息投递后立即被删除

由此可知:

  • none模式下,消息投递是不可靠的,可能丢失
  • auto模式类似事务机制,出现异常时返回nack,消息回滚到mq;没有异常,返回ack
  • manual:自己根据业务情况,判断什么时候该ack

一般,我们都是使用默认的auto即可。

配置方式

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: 确认模式

消费者失败重试机制

当消费者出现异常后,消息会不断requeue(重入队)到队列,再重新发送给消费者,然后再次异常,再次requeue,无限循环,导致mq的消息处理飙升,带来不必要的压力

本地重试

我们可以利用Spring的retry机制,在消费者出现异常时利用本地重试,而不是无限制的requeue到mq队列。

修改consumer服务的application.yml文件,添加内容:

spring:
  rabbitmq:
    listener:
      simple:
        retry:
          enabled: true # 开启消费者失败重试
          initial-interval: 1000ms # 初识的失败等待时长为1秒
          multiplier: 1 # 失败的等待时长倍数,下次等待时长 = multiplier * last-interval
          max-attempts: 3 # 最大重试次数
          stateless: true # true无状态;false有状态。如果业务中包含事务,这里改为false

重启consumer服务,重复之前的测试。可以发现:

  • 在重试3次后,SpringAMQP会抛出异常AmqpRejectAndDontRequeueException,说明本地重试触发了
  • 查看RabbitMQ控制台,发现消息被删除了,说明最后SpringAMQP返回的是ack,mq删除消息了

结论:

  • 开启本地重试时,消息处理过程中抛出异常,不会requeue到队列,而是在消费者本地重试
  • 重试达到最大次数后,Spring会返回ack,消息会被丢弃

失败策略

在之前的测试中,达到最大重试次数后,消息会被丢弃,这是由Spring内部机制决定的。

在开启重试模式后,重试次数耗尽,如果消息依然失败,则需要有MessageRecovery接口来处理,它包含三种不同的实现:

  • RejectAndDontRequeueRecoverer:重试耗尽后,直接reject,丢弃消息。默认就是这种方式
  • ImmediateRequeueMessageRecoverer:重试耗尽后,返回nack,消息重新入队
  • RepublishMessageRecoverer:重试耗尽后,将失败消息投递到指定的交换机

比较优雅的一种处理方案是RepublishMessageRecoverer,失败后将消息投递到一个指定的,专门存放异常消息的队列,后续由人工集中处理。

1)在consumer服务中定义处理失败消息的交换机和队列

    @Bean("error_direct")
    public  DirectExchange errorMessageExchange(){
        return new DirectExchange("error_direct");
    }
    @Bean("error_queue")
    public Queue errorQueue(){
        return new Queue("error_queue",true);
    }
    @Bean
    public Binding bindingerror(DirectExchange error_direct,Queue error_queue){
        return  BindingBuilder.bind(error_queue).to(error_direct).with("error");
    }

2)定义一个RepublishMessageRecoverer,关联队列和交换机

@Bean
    public MessageRecoverer messageRecoverer(RabbitTemplate rabbitTemplate){
        return new RepublishMessageRecoverer(rabbitTemplate,"error_direct","error");
    }

完整代码

    @Bean("error_direct")
    public  DirectExchange errorMessageExchange(){
        return new DirectExchange("error_direct");
    }
    @Bean("error_queue")
    public Queue errorQueue(){
        return new Queue("error_queue",true);
    }
    @Bean
    public Binding bindingerror(DirectExchange error_direct,Queue error_queue){
        return  BindingBuilder.bind(error_queue).to(error_direct).with("error");
    }
    @Bean
    public MessageRecoverer messageRecoverer(RabbitTemplate rabbitTemplate){
        return new RepublishMessageRecoverer(rabbitTemplate,"error_direct","error");
    }

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java使用Knife4j优化Swagger接口文档的操作步骤

    Java使用Knife4j优化Swagger接口文档的操作步骤

    在现代微服务开发中,接口文档的质量直接影响了前后端协作效率,Swagger 作为一个主流的接口文档工具,虽然功能强大,但其默认界面和部分功能在实际使用中略显不足,而 Knife4j 的出现为我们提供了一种增强的选择,本篇文章将详细介绍如何在项目中集成和使用 Knife4j
    2024-12-12
  • 基于Java实现进制转换工具类的示例代码

    基于Java实现进制转换工具类的示例代码

    这篇文章主要为大家详细介绍了如何基于Java实现进制转换工具类,从而实现减少参数长度的效果,文中的示例代码讲解详细,需要的可以参考一下
    2023-02-02
  • formfile文件上传使用示例

    formfile文件上传使用示例

    这篇文章主要介绍了formfile文件上传使用示例,代码已加注释,需要的朋友可以参考下
    2014-03-03
  • SpringIOC容器Bean的作用域及生命周期实例

    SpringIOC容器Bean的作用域及生命周期实例

    这篇文章主要为大家介绍了SpringIOC容器Bean的作用域及生命周期实例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-05-05
  • spring声明式事务解析

    spring声明式事务解析

    这篇文章主要为大家详细介绍了spring声明式事务,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-10-10
  • Spring实现IoC的多种方式小结

    Spring实现IoC的多种方式小结

    本篇文章主要介绍了Spring实现IoC的多种方式小结,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-02-02
  • Java使用JDBC连接数据库的实现方法

    Java使用JDBC连接数据库的实现方法

    这篇文章主要介绍了Java使用JDBC连接数据库的实现方法,包括了详细的加载步骤以及完整实现示例,需要的朋友可以参考下
    2014-09-09
  • Spring Boot整合Spring Cache及Redis过程解析

    Spring Boot整合Spring Cache及Redis过程解析

    这篇文章主要介绍了Spring Boot整合Spring Cache及Redis过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • Lucene实现索引和查询的实例讲解

    Lucene实现索引和查询的实例讲解

    下面小编就为大家分享一篇Lucene实现索引和查询的实例讲解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2017-12-12
  • IDEA中使用Typora编辑md文件的方法

    IDEA中使用Typora编辑md文件的方法

    这篇文章主要介绍了IDEA中使用Typora编辑md文件的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-09-09

最新评论