答案:CompletableFuture通过exceptionally、handle、whenComplete和内部try-catch实现异常处理。1. exceptionally在异常时提供默认值;2. handle统一处理结果与异常,适用于日志或决策;3. 回调中需主动捕获异常避免链式中断;4. whenComplete用于最终清理,类似finally块。合理选用可提升异步代码稳定性。

在Java中使用CompletableFuture时,异常处理是异步编程的关键部分。如果不妥善处理,异常可能被静默吞掉,导致程序行为不可预测。CompletableFuture提供了多种方式来捕获和处理异常,确保异步任务的健壮性。
1. 使用 exceptionally 处理异常
exceptionally 方法允许你在发生异常时提供一个备用结果。它接收一个函数,该函数参数为异常本身,返回一个与原始类型兼容的结果。
例如:假设你发起一个远程调用,网络失败时希望返回默认值:
CompletableFuturefuture = CompletableFuture.supplyAsync(() -> { throw new RuntimeException("请求超时"); }).exceptionally(ex -> { System.out.println("捕获异常: " + ex.getMessage()); return "默认响应"; }); System.out.println(future.join()); // 输出:默认响应
这种方式适合“故障恢复”场景,不会中断流程,而是提供兜底逻辑。
立即学习“Java免费学习笔记(深入)”;
2. 使用 handle 统一处理结果与异常
handle 比 exceptionally 更灵活,它无论是否发生异常都会执行,接收两个参数:结果和异常。
示例:CompletableFuturefuture = CompletableFuture.supplyAsync(() -> { if (Math.random() < 0.5) throw new RuntimeException("随机出错"); return "成功结果"; }).handle((result, ex) -> { if (ex != null) { System.out.println("处理异常: " + ex.getMessage()); return "通过 handle 恢复"; } return "处理结果: " + result; });
handle 适用于需要统一日志、监控或根据结果/异常做不同决策的场景。
3. 在回调中主动捕获异常
在 thenApply、thenAccept 等方法中,Lambda 表达式内部应主动 try-catch 异常,否则会终止后续链式调用。
正确做法:CompletableFuture.supplyAsync(() -> "初始值")
.thenApply(s -> {
try {
if (s == null) throw new IllegalArgumentException("空输入");
return s.toUpperCase();
} catch (Exception e) {
return "转换失败";
}
})
.thenAccept(System.out::println);
注意:这类异常若未在 Lambda 内部处理,会导致整个 CompletableFuture 失败。
4. 使用 whenComplete 进行最终清理
whenComplete 不改变结果,仅用于执行副作用,比如记录日志、关闭资源等。
示例:CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("业务异常");
}).whenComplete((result, ex) -> {
if (ex != null) {
System.err.println("任务完成,但出现异常: " + ex.getMessage());
} else {
System.out.println("任务成功,结果: " + result);
}
}).join();
适合做类似 finally 块的操作,不影响主流程结果。
基本上就这些。合理选择 exceptionally、handle、whenComplete 和内部 try-catch,能让你的异步代码更稳定可靠。关键是理解每个方法的用途:恢复用 exceptionally,统一处理用 handle,清理用 whenComplete。不复杂但容易忽略细节。










