异步Feign调用场景下，如何在CompletableFuture异常时立即在主线程抛错

要实现书籍校验失败时立即在主线程抛出异常、终止作者校验的需求，核心是调整异步任务的等待逻辑，优先处理书籍校验结果，而非等待所有任务完成。

调整后的调用逻辑 #

替换原有的CompletableFuture.allOf逻辑，改为主动等待书籍校验结果，一旦异常则终止后续流程：

// 触发异步校验任务
CompletableFuture<JsonNode> bookFuture = getBookAsync(bookId);
CompletableFuture<JsonNode> authorFuture = getAuthorAsync(authorId);

try {
    // 优先等待书籍校验结果，异常会立即抛出
    bookFuture.get();
    // 书籍校验通过后，再等待作者校验结果
    authorFuture.get();
    // 双校验通过，执行记录保存
    recordRepository.save(record);
} catch (InterruptedException e) {
    // 恢复线程中断状态
    Thread.currentThread().interrupt();
    throw new RuntimeException("校验流程被中断", e);
} catch (ExecutionException e) {
    // 取消未完成的作者校验，避免无效资源消耗
    authorFuture.cancel(true);
    // 抛出底层异常，交由全局异常处理器处理
    throw new RuntimeException(e.getCause());
}

代码逻辑说明 #

• bookFuture.get()会阻塞主线程直到书籍校验完成，若校验失败（bookClient.getBook(id)抛出异常），会直接进入ExecutionException分支。
• 在异常分支中调用authorFuture.cancel(true)，可以终止未完成的作者校验任务，避免不必要的远程调用。
• 最后将底层异常抛出，全局异常处理器即可捕获并处理该异常。

优化异步方法实现（可选） #

原有的异步方法手动创建CompletableFuture的写法可以简化，Spring的@Async支持直接返回CompletableFuture，异常会自动被包装：

@Async
public CompletableFuture<JsonNode> getBookAsync(Long id) {
    return CompletableFuture.supplyAsync(() -> bookClient.getBook(id));
}

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