spring cloud resilience4j-retry 重试

亦凉 2022-12-29 06:42 256阅读 0赞

# 参数说明 #

<table> 
 <thead> 
  <tr> 
   <th>属性</th> 
   <th>默认值</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>maxAttempts</td> 
   <td>3</td> 
   <td>最大重试次数（包含最初的第一次调用）</td> 
  </tr> 
  <tr> 
   <td>waitDuration</td> 
   <td>500[ms]</td> 
   <td>固定的重试间隔</td> 
  </tr> 
  <tr> 
   <td>intervalFunction</td> 
   <td>numOfAttempts -&gt; waitDuration</td> 
   <td>计算重试等待时间的函数，默认为固定值</td> 
  </tr> 
  <tr> 
   <td>retryOnResultPredicate</td> 
   <td>result -&gt; false</td> 
   <td>配置某个结果是否要重试</td> 
  </tr> 
  <tr> 
   <td>retryOnExceptionPredicate</td> 
   <td>throwable -&gt; true</td> 
   <td>配置某个异常是否要重试</td> 
  </tr> 
  <tr> 
   <td>retryExceptions</td> 
   <td>empty</td> 
   <td>要重试的异常列表，包含子类型</td> 
  </tr> 
  <tr> 
   <td>ignoreExceptions</td> 
   <td>empty</td> 
   <td>忽略的异常列表，包含子类型</td> 
  </tr> 
 </tbody> 
</table>

# 配置文件 #

resilience4j.retry:
        instances:
            backendA:
                maxRetryAttempts: 3
                waitDuration: 10s
                enableExponentialBackoff: true
                exponentialBackoffMultiplier: 2
                retryExceptions:
                    - org.springframework.web.client.HttpServerErrorException
                    - java.io.IOException
                ignoreExceptions:
                    - io.github.robwin.exception.BusinessException
            backendB:
                maxRetryAttempts: 3
                waitDuration: 10s
                retryExceptions:
                    - org.springframework.web.client.HttpServerErrorException
                    - java.io.IOException
                ignoreExceptions:
                    - io.github.robwin.exception.BusinessException

# 代码 #

@CircuitBreaker(name = "backendA", fallbackMethod = "fallback")
    @RateLimiter(name = "backendA")
    @Bulkhead(name = "backendA")
    @Retry(name = "backendA", fallbackMethod = "fallback")
    @TimeLimiter(name = "backendA")
    public Mono<String> method(String param1) { 
        return Mono.error(new NumberFormatException());
    }
    
    private Mono<String> fallback(String param1, IllegalArgumentException e) { 
        return Mono.just("test");
    }
    
    private Mono<String> fallback(String param1, RuntimeException e) { 
        return Mono.just("test");
    }

执行顺序：

> Retry ( CircuitBreaker ( RateLimiter ( TimeLimiter ( Bulkhead ( Function ) ) ) ) )

Retry是最后执行

# 更多 #

[spring cloud resilience4j-retry 重试][spring cloud resilience4j-retry]  
[spring cloud resilience4j - Bulkhead 线程隔离 并发控制][spring cloud resilience4j - Bulkhead _]  
[spring cloud Resilience4j - 熔断器 CircuitBreaker][spring cloud Resilience4j - _ CircuitBreaker]  
[spring cloud resilience4j - RateLimiter 流控][spring cloud resilience4j - RateLimiter]

https://resilience4j.readme.io/docs/retry

[spring cloud resilience4j-retry]: https://blog.csdn.net/xgw1010/article/details/111464801
[spring cloud resilience4j - Bulkhead _]: https://blog.csdn.net/xgw1010/article/details/111300196
[spring cloud Resilience4j - _ CircuitBreaker]: https://blog.csdn.net/xgw1010/article/details/108675113
[spring cloud resilience4j - RateLimiter]: https://blog.csdn.net/xgw1010/article/details/111590574