使用Reactor Mono记录重试次数

import reactor.core.publisher.Mono;

public class RetryExample {
    private static int retryCount = 0;

    public static void main(String[] args) {
        retryOperation()
                .doOnError(throwable -> System.out.println("Error occurred: " + throwable.getMessage()))
                .subscribe();
    }

    private static Mono<Void> retryOperation() {
        return performOperation()
                .retry(3) // 设置最大重试次数为3次
                .doOnNext(result -> System.out.println("Operation succeeded"))
                .doOnError(throwable -> System.out.println("Operation failed"));
    }

    private static Mono<Void> performOperation() {
        return Mono.fromRunnable(() -> {
            if (retryCount < 3) {
                retryCount++;
                throw new RuntimeException("Simulated error");
            } else {
                System.out.println("Operation completed");
            }
        });
    }
}