resilience4j.ratelimiter:
  instances:
    backendA: # 名稱(chēng)
      limit-for-period: 3 #限制連續(xù)請(qǐng)求3次
      limit-refresh-period: 1s #1s刷新統(tǒng)計(jì)值
      timeout-duration: 5s #超時(shí)等待時(shí)長(zhǎng)
    backendB: # 名稱(chēng)
      limit-for-period: 5 #限制連續(xù)請(qǐng)求5次
      limit-refresh-period: 1s #1s刷新統(tǒng)計(jì)值
      timeout-duration: 10s #超時(shí)等待時(shí)長(zhǎng)

@RateLimiter(name = "backendA")

resilience4j.retry:
  instances:
    backendA:
      max-retry-attempts: 3 # 重試次數(shù)
      wait-duration: 600 # 重試等待時(shí)間
      # 判斷異常是否需要重試
      retryExceptionPredicate: com.test.manager.exception.RecordFailurePredicate
      retry-exceptions: # 需要重試的異常
        - java.net.SocketTimeoutException
        - java.io.IOException
      ignore-exceptions: # 重試忽略的異常
          - io.github.robwin.exception.BusinessException

class RecordFailurePredicate : Predicate<Throwable> {

    /**
     * 判斷是否需要重試
     *
     * @param t 異常
     * @return
     */
    override fun test(t: Throwable): Boolean {
        // 返回true --> 重試,返回false-->不重試
        return true
    }
}

@Retry(name = "backendA")

<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot2</artifactId>
    <version>1.7.0</version>
</dependency>

@Service
public class MyService {
 
    @CircuitBreaker(name = "myService", fallbackMethod = "fallback")
    public String doSomething() {
        // ...
        代碼邏輯
    }
 
    public String fallback(Throwable t) {
        // ...
       回調(diào)邏輯
    }
}
 
//在上面的示例中，
@CircuitBreaker注解將MyService.doSomething()方法標(biāo)記為使用名

resilience4j:
  circuitbreaker:
    configs:
      default:
        registerHealthIndicator: true # 是否啟用健康檢查
        ringBufferSizeInClosedState: 5 # 斷路器關(guān)閉時(shí)環(huán)形緩沖區(qū)大小
        ringBufferSizeInHalfOpenState: 3 # 斷路器半開(kāi)時(shí)環(huán)形緩沖區(qū)大小
        waitDurationInOpenState: 10s # 斷路器打開(kāi)后等待時(shí)間
        failureRateThreshold: 50 # 失敗率閾值
        minimumNumberOfCalls: 10 # 最小請(qǐng)求數(shù)
        permittedNumberOfCallsInHalfOpenState: 3 # 斷路器半開(kāi)時(shí)允許的請(qǐng)求數(shù)
    instances:
      backendService:
        circuitBreakerConfig: default # 引用 default 已定義的配置
        registerHealthIndicator: true # 是否啟用健康檢查

@ControllerAdvice
public class GlobalExceptionHandler {
    @ExceptionHandler(value = {
            CircuitBreakerOpenException.class,
            BulkheadFullException.class,
            RateLimiterFullException.class,
            RequestNotPermitted.class,
            RetryException.class
    })
    public ResponseEntity<Object> handleResilience4jExceptions(Exception ex) {
        // 處理 Resilience4j 異常
    }
}
 
//這里通過(guò) @ControllerAdvice 注解聲明了一個(gè)全局異常處理器，
并使用 @ExceptionHandler 注解指定要處理的 Resilience4j 異常。

@EnableCircuitBreaker
@SpringBootApplication
public class Application {
    // ...
}