RabbitMQ-消费者确认机制

这篇具有很好参考价值的文章主要介绍了RabbitMQ-消费者确认机制。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、确认模式

none：不做任何处理，消息投递到消费者了之后，立即返回ACK，并且从MQ将消息删除，非常不安全，不建议使用。

manual：手动模式，需要在业务中调用api，ack或者reject。

auto：自动模式，SpringAMQP利用AOP对我们的消息处理做了环绕增强，当业务正常执行时返回ACK，执行异常时，根据异常的情况返回不同的结果：

如果是业务异常，会自动返回nack，nack会再次投递MQ消息。

如果是消息处理或校验异常，自动返回reject，拒绝之后不再投递MQ，删除MQ中的消息。一般是以错误的消息，就会这么错里

2、yml文件配置

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: auto #开启自动模式

3、重试机制

消息失败之后会重新入队，然后再次异常，再次入队，无限循环，这会导致mq消息处理飙升，带来不必要的压力。为了缓解这种压力，利用Spring的retry机制，在消费者出现异常的情况下，利用本地重试，重试次数用完之后，再进行消息的投递或者消息的拒绝。

yml文件配置：

spring:
  rabbitmq:
    listener:
      simple:
        retry:
          # 是否启用
          enabled: true
          # 初始时间间隔
          initial-interval: 1000ms
          # 下次失败的等待时长的倍数
          multiplier: 1
          # 最大尝试次数
          max-attempts: 3
          # 无状态
          stateless: true

开启重试之后，当重试次数耗尽的时候，如果消息依然失败，则需要调用MessageRecoverer接口来处理，这个接口有三种实现：文章来源地址https://www.toymoban.com/news/detail-810927.html

RejectAndDontRequeueRecoverer：重试耗尽，直接reject，丢弃消息。默认方式。

ImmediateRequeueMessageRecoverer：重试耗尽后，返回nack，消息重新入队。

RepublishMessageRecoverer：重试耗尽后，将失败消息投递到指定的交换机。然后交给人工处理。

到了这里，关于RabbitMQ-消费者确认机制的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！