Spring RabbitMQ 消息重试机制

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

最后编辑于：2019.10.31 09:39:51