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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM