当前位置:   article > 正文

RabbitMQ消费失败重试策略、及重试策略应用场景详解_mq消费失败一直循环处理

mq消费失败一直循环处理

前言:
RabbitMQ消费者一般情况下,如果消费失败出现异常,那么消费端默认是无限重试消费,这样就会带来非常不好的一个情况,就是陷入死循环,一直报错一直重试。所以我们需要对消费异常重试次数、重试间隔时间进行限制

一、限制消费异常重试次数、重试间隔时间

1、配置限制策略,如下:

  1. rabbitmq:
  2. host: xxx
  3. port: 5672
  4. username: guest
  5. password: guest
  6. virtual-host: /
  7. listener:
  8. simple:
  9. default-requeue-rejected: false
  10. acknowledge-mode: manual # 确认模式为手动确认-需要在代码中手动ACK
  11. retry:
  12. enabled: true # 开启消费者出现异常情况下,进行重试消费,默认false
  13. max-attempts: 5 # 最大重试次数,默认为3
  14. initial-interval: 3000 # 重试间隔时间,默认1000(单位毫秒)

其中 retry 节点及以下的属性就是重试策略

2、验证重试策略是否生效
这里使用一张 user 信息表作演示

【1】演示代码

  1. @RabbitListener(queues = {MqConstants.DIRECT_QUEUE_1})
  2. public void listenerDirectQueue1(Message message, Channel
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/603963
推荐阅读
相关标签
  

闽ICP备14008679号