具有重试配置的 Resiliency4j 断路器不起作用

Question

我在服务方法上同时使用 @CircuitBreaker 和 @Retry 注释。当我应用这两种配置时，重试配置不会生效。

下面是配置：

resilience4j:
  circuitbreaker:
    instances:
      inventorymicroservice:
        registerHealthIndicator: true
        ringBufferSizeInClosedState: 5
        ringBufferSizeInHalfOpenState: 3
        waitDurationInOpenState: 30000
        failureRateThreshold: 50
        slowCallRateThreshold: 50
        recordExceptions:
          - java.io.IOException
          - java.util.concurrent.TimeoutException
          - java.net.ConnectException
          - org.springframework.web.reactive.function.client.WebClientRequestException
  retry:
    instances:
      retryConfig:
        maxAttempts: 3
        waitDuration: 10s
        enableExponentialBackoff: true
        exponentialBackoffMultiplier: 2
        retryExceptions:
          - org.springframework.web.client.HttpServerErrorException
          - java.io.IOException
          - java.io.IOException
          - java.util.concurrent.TimeoutException
          - java.net.ConnectException
          - org.springframework.web.reactive.function.client.WebClientRequestException

服务方法：

   @CircuitBreaker(name = "inventorymicroservice", fallbackMethod = "fallBack")
    @Retry(name = "retryConfig", fallbackMethod = "fallBack")
    public Order saveOrder(Order order){
        Order savedOrder = this.orderRepository.save(order);
        log.info("Calling the inventory service to update the quantity :: ");
        //ResponseEntity<Integer> integerResponseEntity = this.restTemplate.postForEntity("http://localhost:9222/api/inventory", null, Integer.class);
        Integer response = this.webClient
                .post()
                .uri("/api/inventory")
                .retrieve()
                .bodyToMono(Integer.class)
                .block();
        log.info("Response from the inventory microservice :: {}", response);
        return savedOrder;
    }

    private Order fallBack(Throwable exception){
        log.error("Exception while invoking the REST endpoint :: ", exception.getMessage());
        return Order.builder().build();
    }

我哪里出错了？另外，如何使用函数式编程将此配置转换为编程配置。

Answer 1

默认的Resilience4j方面顺序是

Retry( CircuitBreaker( RateLimiter( TimeLimiter( Bulkhead( function)))))

你的CircuitBreaker有一个后备，所以它永远不会抛出异常，因此 Retry 永远不会看到失败的重试调用。

删除重试后备，并更改方面顺序，以便 CircuitBreaker 在重试后继续工作。

resilience4j:
  circuitbreaker:
    circuitBreakerAspectOrder: 1
  retry:
    retryAspectOrder: 2