美文网首页
Spring RabbitMQ 消息重试机制

Spring RabbitMQ 消息重试机制

作者: oO白眉大虾Oo | 来源:发表于2019-10-22 19:49 被阅读0次

    RabbitMQ框架提供了重试机制,只需要简单的配置即可开启,可以提升程序的健壮性。

    测试一:重试5次
    spring:
      rabbitmq:
        listener:
          simple:
            retry:
              enabled: true          
              max-attempts: 5 # 最大重试次数,包含本身
    
    2019-10-14 16:09:03.878 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:09:04.881 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler 
    2019-10-14 16:09:05.886 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:09:06.891 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:09:07.892 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    
    由结果得知:默认是每秒重试
    
    测试二:重试5次,每隔3秒重试
    spring:
      rabbitmq:
        listener:
          simple:
            retry:
              enabled: true
              max-attempts: 5 # 最大重试次数
              initial-interval: 3000 # 重试间隔
              
    2019-10-14 16:12:12.348 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:12:15.355 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:12:18.362 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:12:21.368 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:12:24.374 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    
    由结果得知:会按设置的时间间隔进行重试,这里配置的是3秒
    
    测试三:重试5次,重试间隔根据乘子计算
    spring:
      rabbitmq:
        listener:
          simple:
            retry:
              enabled: true
              multiplier: 2 # 乘子
              max-attempts: 5 # 最大重试次数
              initial-interval: 3000 # 第一次和第二次之间的重试间隔
    
    2019-10-14 16:15:10.010 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:15:13.014 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:15:19.021 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:15:29.023 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:15:39.026 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    
    结果展示有点异常,第4次和第5次都是以10秒为重试间隔,原因是默认的最大重试间隔就是10秒
    
    测试四(推荐):重试5次,重试间隔根据乘子计算,并自定义最大重试间隔
    做如下修改,设置最大重试间隔为1个小时
    
    spring:
      rabbitmq:
        listener:
          simple:
            retry:
              enabled: true
              multiplier: 2 # 乘子
              max-attempts: 5 # 最大重试次数
              initial-interval: 3000 # 第一次和第二次之间的重试间隔,后面的用乘子计算
              max-interval: 3600000 # 最大重试时间间隔
              
    2019-10-14 16:50:36.580 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler 
    2019-10-14 16:50:39.588 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:50:45.594 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:50:57.597 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    2019-10-14 16:51:21.603 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
    
    由结果得知:重试间隔为:3s 6s 12s 24s
    

    相关文章

      网友评论

          本文标题:Spring RabbitMQ 消息重试机制

          本文链接:https://www.haomeiwen.com/subject/gtjcvctx.html