在 java 的 completablefuture 中处理异常，核心是使用 exceptionally() 方法捕获并恢复执行流，或使用 handle() 方法同时获取结果与异常。若需区分不同异常类型进行针对性处理，可结合 iscompletedexceptionally() 判断或在前置阶段使用 supplyasync 配合 try-catch 包装。这些方法能确保异步任务即使失败也能返回默认值、抛出特定业务异常或触发补偿逻辑，从而避免整个链式调用中断。
如何为单个异步任务设置异常恢复逻辑
通过调用 exceptionally(Function<throwable extends t>)</throwable> 可以为当前阶段的异常提供回退方案。该方法接收一个函数，当上游任务完成 exceptionally（即抛出异常）时，该函数会被调用，其返回值将作为当前阶段的结果继续向后传递。如果上游正常完成，则直接透传结果。这种方式适用于需要“降级”或“返回默认值”的场景，例如网络请求超时返回缓存数据。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class ExceptionalRecovery {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 模拟一个会抛出异常的异步任务
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
if (true) { // 模拟条件
throw new RuntimeException("Service unavailable");
}
return "Success";
});
// 使用 exceptionally 处理异常并返回默认值
CompletableFuture<String> recovered = future.exceptionally(ex -> {
System.out.println("Caught exception: " + ex.getMessage());
return "Default Value"; // 异常时的返回值
});
// 获取最终结果
String result = recovered.get();
System.out.println("Final Result: " + result);
}
}
运行上述代码，控制台将输出：
Caught exception: Service unavailable
Final Result: Default Value
预期结果分析：
1. future.get() 会抛出 ExecutionException。
2. recovered.get() 不会抛出异常，而是返回字符串 "Default Value"。
3. exceptionally 中的 lambda 表达式成功拦截了上游的 RuntimeException。
立即学习“Java免费学习笔记（深入）”；
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
如何在链式调用中统一处理下游异常
在多个步骤组成的异步链中，可以使用 exceptionally() 挂载在链的末尾，或者使用 handle() 方法。与 exceptionally 不同，handle(BiFunction<t throwable extends u>)</t> 无论上游是正常完成还是异常完成，都会执行。它同时接收结果值和异常对象，允许开发者根据两者状态决定后续行为。这在需要记录日志、监控指标或根据具体错误类型做不同处理的场景中非常有用。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class ChainExceptionHandler {
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
throw new IllegalArgumentException("Invalid input");
}).thenApply(i -> i * 2); // 这一步不会执行，因为上游已异常
// 使用 handle 统一处理
CompletableFuture<String> handled = future.handle((result, ex) -> {
if (ex != null) {
return "Error Handled: " + ex.getClass().getSimpleName();
} else {
return "Result: " + result;
}
});
System.out.println(handled.get());
}
}
运行上述代码，控制台将输出：
Error Handled: IllegalArgumentException
预期结果分析：
1. thenApply 因上游异常而被跳过。
2. handle 被调用，参数 result 为 null，ex 为 IllegalArgumentException。
3. 由于 ex != null，返回错误描述字符串。
4. 最终 get() 返回该字符串，无异常抛出。
当异常发生在中间步骤时如何定位源头
在链式调用中，如果某个中间步骤抛出异常，后续的 thenApply 等转换操作将被跳过，异常会向下游传播直到被 exceptionally 或 handle 捕获。要定位异常源头，可以检查堆栈跟踪信息，或者在每个关键步骤前添加 whenComplete 来观察执行状态。此外，可以使用 CompletableFuture.allOf() 或 anyOf() 组合多个任务时，每个任务的异常独立处理，不会相互干扰，除非显式地重新抛出。
