Spring Reactor Retry.retryWhen() 不起作用

Question

如何使用重试？我想在出错时重试调用方法，直到成功。 我的测试代码

@Test
    public void fun1() throws InterruptedException {
        this.generate()
                .retryWhen(Retry.fixedDelay(5, Duration.ofMillis(1))
                        .filter(e -> e instanceof Exception)
                        .doBeforeRetry(res -> System.out.println("retry begin"))
                        .doAfterRetry(res -> System.out.println("try finished")))
                .onErrorContinue((throwable, o) -> System.out.println(throwable))
                .subscribe(System.out::println);
    }

    private Mono<String> generate() throws InterruptedException {
        if (retryTime.get() == 3) {
            return Mono.just("Hello");
        }
        System.out.println("i am called" + retryTime.getAndAdd(1));
        return Mono.error(new IllegalArgumentException("exception test"));
    }

** 但得到这个结果**

i am called1
10:02:12.104 [main] DEBUG reactor.util.Loggers - Using Slf4j logging framework
retry begin
try finished
retry begin
try finished
retry begin
try finished
retry begin
try finished
retry begin
try finished
reactor.core.Exceptions$RetryExhaustedException: Retries exhausted: 5/5

Process finished with exit code 0

为什么不重试三次直到成功？？？

Answer 1

重试通过重新订阅上游方法的结果来工作。它不会重新调用上游方法。

具体而言，在您的情况下，每个订阅都.retryWhen订阅Mono.error从单个调用返回的generate(). 因此，每个订阅都会看到相同的异常结果。

要解决此问题，您需要推迟方法内的逻辑在订阅generate()时发生，而不是在组装时发生。

例如，使用Mono.fromCallable，如下所示：

    private Mono<String> generate() {
        return Mono.fromCallable(() -> {
            if (retryTime.get() == 3) {
                return "Hello";
            }
            System.out.println("i am called" + retryTime.getAndAdd(1));
            throw new new IllegalArgumentException("exception test");
        });
    }

每个订阅者都会调用 Callable。retryWhen具体来说，每次运营商重新订阅时都会调用它。