如何用CompletableFuture实现连续递归？解决前置递归未等待问题

原代码的核心问题在于getServiceReady的重试逻辑没有正确串联到返回的CompletableFuture中：当健康检查失败时，你异步调用了getServiceReady()，但这个新任务和当前方法返回的Future没有关联，导致原Future在第一次失败时就进入完成状态，直接触发了后续的registerWithRetry。

以下是修复后的代码，通过正确的CompletableFuture链式调用实现"等待服务就绪后再执行注册"的逻辑：

@PostConstruct
void registerMetadata() {
    // 直接调用getServiceReady，它会返回一个直到服务就绪才完成的Future
    getServiceReady()
        // 服务就绪后，异步执行注册逻辑
        .thenRunAsync(() -> registerWithRetry(0), executor);
}

private void registerWithRetry(int retryAttempt) {
    serviceRegistrationOperations.registerService(serviceMetadataMedia)
        .thenAccept(data -> {
            this.isMetadataRegistered = true;
            log.info("Metadata registered successfully");
        })
        .whenComplete((data, ex) -> {
            if (ex != null) {
                Throwable cause = ExceptionUtils.cleanseTop(ex);
                String message = cause.getMessage();
                int delayInSeconds = getDelaySecondsBeforeNextRetry(retryAttempt);
                log.error("Failed to register metadata: {}, will retry again in {} seconds", message, delayInSeconds, cause);
                // 延迟重试注册，用链式调用确保异步逻辑正确
                CompletableFuture.delayedExecutor(delayInSeconds, TimeUnit.SECONDS, executor)
                    .execute(() -> registerWithRetry(retryAttempt + 1));
            }
        });
}

private CompletableFuture<Boolean> getServiceReady() {
    log.info("Checking service readiness");
    if (this.exitFlag) {
        return CompletableFuture.completedFuture(true);
    }
    return healthOperations.getReadiness()
        .thenApply(isServiceReady -> {
            this.exitFlag = true;
            log.info("Service is ready");
            return true;
        })
        .exceptionallyCompose(ex -> {
            log.error("Service is not ready, retrying in 5 seconds", ex);
            // 失败时，延迟5秒后递归调用getServiceReady，将重试的Future串联到当前链路中
            return CompletableFuture.delayedExecutor(5, TimeUnit.SECONDS, executor)
                .submit(this::getServiceReady)
                .thenCompose(future -> future);
        });
}

关键修复点说明： #

• getServiceReady的重试逻辑：使用exceptionallyCompose替代原有的whenComplete，当健康检查失败时，返回一个新的Future（延迟后递归调用getServiceReady的结果），确保整个链路的Future只有在服务真正就绪时才会完成。
• registerMetadata的调用链路：直接基于getServiceReady返回的Future调用thenRunAsync，保证注册逻辑只会在服务就绪后触发。
• 延迟执行优化：使用CompletableFuture.delayedExecutor（JDK 9+支持，JDK 8可自行实现类似逻辑）替代自定义DelayedExecutor，让延迟逻辑更贴合CompletableFuture的链式风格。
• 语法错误修正：修复了原registerWithRetry中的大括号匹配错误，以及log.error的参数顺序问题。

内容的提问来源于stack exchange，提问作者TsB