在 java 的 completablefuture 中处理异常，核心是使用 exceptionally() 方法捕获并恢复执行流，或使用 handle() 方法同时获取结果与异常。若需区分不同异常类型进行针对性处理，可结合 iscompletedexceptionally() 判断或在前置阶段使用 supplyasync 配合 try-catch 包装。这些方法能确保异步任务即使失败也能返回默认值、抛出特定业务异常或触发补偿逻辑，从而避免整个链式调用中断。
如何为单个异步任务设置异常恢复逻辑
通过调用 exceptionally(Function 可以为当前阶段的异常提供回退方案。该方法接收一个函数，当上游任务完成 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);
}
}</string></string>
运行上述代码，控制台将输出：
Caught exception: Service unavailable
Final Result: Default Value
预期结果分析：
1. future.get() 会抛出 ExecutionException。
2. recovered.get() 不会抛出异常，而是返回字符串 "Default Value"。
3. exceptionally 中的 lambda 表达式成功拦截了上游的 RuntimeException。
如何在链式调用中统一处理下游异常
在多个步骤组成的异步链中，可以使用 exceptionally() 挂载在链的末尾，或者使用 handle() 方法。与 exceptionally 不同，handle(BiFunction 无论上游是正常完成还是异常完成，都会执行。它同时接收结果值和异常对象，允许开发者根据两者状态决定后续行为。这在需要记录日志、监控指标或根据具体错误类型做不同处理的场景中非常有用。
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
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());
}
}</string></integer>
运行上述代码，控制台将输出：
Error Handled: IllegalArgumentException
预期结果分析：
1. thenApply 因上游异常而被跳过。
2. handle 被调用，参数 result 为 null，ex 为 IllegalArgumentException。
3. 由于 ex != null，返回错误描述字符串。
4. 最终 get() 返回该字符串，无异常抛出。
当异常发生在中间步骤时如何定位源头
在链式调用中，如果某个中间步骤抛出异常，后续的 thenApply 等转换操作将被跳过，异常会向下游传播直到被 exceptionally 或 handle 捕获。要定位异常源头，可以检查堆栈跟踪信息，或者在每个关键步骤前添加 whenComplete 来观察执行状态。此外，可以使用 CompletableFuture.allOf() 或 anyOf() 组合多个任务时，每个任务的异常独立处理，不会相互干扰，除非显式地重新抛出。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
