在Resilience4j中集成断路器、重试和定时器

Question

我正在尝试使用Resilience4j功能。我的用例是组合断路器、重试和定时器模块。这是我尝试过的。

  Supplier<R> supplier = this::doSomething;
  timeLimiter.executeFutureSupplier(
          () -> CompletableFuture.supplyAsync(supplier));
  return Decorators.ofSupplier(supplier)
            .withCircuitBreaker(circuitBreaker)
            .withRetry(retry)
            .withBulkhead(bulkhead)
            .decorate();

这里的问题是，我的doSomething()方法执行两次。之前有没有人见过这个问题？我希望将所有这些模块组合在一起，并且只执行一次方法。谢谢你的帮助。

Answer 1

您使用的是timeLimiter.executeFutureSupplier，它执行未来，而不是装饰它。请按如下顺序使用：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(3);
Supplier<R> supplier = this::doSomething;

CompletableFuture<R> future = Decorators.ofSupplier(supplier)
    .withThreadPoolBulkhead(threadPoolBulkhead)
    .withTimeLimiter(timeLimiter, scheduledExecutorService)
    .withCircuitBreaker(circuitBreaker)
    .withRetry(retry)
    .get().toCompletableFuture();