弹性4j - 请求超时

Question

我有一个使用 Hystrix 断路器模式的服务，它调用 3rd 方服务。在

的帮助下

@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000") 我已经为第 3 方服务定义了超时。

由于 Hystrix 处于维护模式，我正在从 Hystrix 迁移到 Resilience4j 断路器模式。如何在 resiience4j 中实现类似的超时处理。

我知道可以通过使用@TimeLimiter 来实现类似的事情，它是resilience4j-timelimiter 的一部分。但是根据这个问题：https://github.com/resilience4j/resilience4j/issues/849，我必须将我的方法的返回类型修改为CompletableFuture。它将涉及对我现有服务的大量代码更改。我如何使用 Resilience4j 实现这一目标？

Answer 1

我不得不和你处理同样的问题。

对我来说，resilience4j 的 TimeLimiter 解决了我的问题，不再需要使用 Hystrix。

这是我的 application.properties：

resilience4j.timelimiter.configs.default.timeout-duration=3s
resilience4j.timelimiter.instances.paymentCalc.base-config=default
# The max amount of time a call can last
resilience4j.timelimiter.instances.paymentCalc.timeout-duration=1s
# Cancel the Running Completable Futures After TimeOut.
resilience4j.timelimiter.instances.paymentCalc.cancel-running-future=true

# Max amount of parallel executions allowed by the bulkhead
resilience4j.bulkhead.configs.default.max-concurrent-calls=2
# Max amount of time a thread should be blocked for when attempting to enter a saturated bulkhead.
resilience4j.bulkhead.configs.default.max-wait-duration=0
resilience4j.bulkhead.instances.paymentCalc.base-config=default

这是我的实现：

    // Bulkhead module is added because TimeLimiter needs separate execution thread instead of request thread
    @Bulkhead(name = "paymentCalc", fallbackMethod = "localPaymentGenerate", type = Bulkhead.Type.THREADPOOL)
    @TimeLimiter(name = "paymentCalc", fallbackMethod = "localPaymentGenerate")
    @GetMapping(value = "/{workerId}/days/{days}")
    public CompletableFuture<ResponseEntity<Payment>> getPayment(@PathVariable Long workerId, @PathVariable Integer days){
            
        ...     
    }
    
    
    public CompletableFuture<ResponseEntity<Payment>> localPaymentGenerate(Long workerId, Integer days, Exception e){
        
        System.out.println(e.getMessage()); // prints "TimeLimiter 'paymentCalc' recorded a timeout exception"
    
        ...
}

但是，请注意，使用 spring-cloud-starter-circuitbreaker-resilience4j 依赖项的代码不起作用，我花了很多时间试图解决它。 要使@TimeLimiter 正常工作，我唯一需要更改的就是更改我的依赖项。

我正在使用 spring-boot <version>2.5.4</version>、<java.version>16</java.version>，我的依赖项是：

 <dependency>
        <groupId>io.github.resilience4j</groupId>
        <artifactId>resilience4j-spring-boot2</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>