CompletableFuture 中异常处理后怎么继续链式调用
在 java completablefuture 中，处理异常后继续链式调用的核心方法是使用 exceptionally() 或 handle()。这两个方法都会返回一个新的 completablefuture，其值取决于你提供的回调函数：如果原任务成功，新任务将直接传递结果；如果原任务抛出异常，新任务将执行你的异常处理逻辑并返回一个默认值或替代结果，从而让链式调用得以继续。
exceptionally() 与 handle() 的区别及选择
exceptionally() 专门用于处理异常情况，它接收一个 Function<throwable extends t></throwable>，仅在发生异常时触发，并允许你返回一个替代的 T 类型结果。而 handle() 更通用，它接收一个 BiConsumer super T, ? super Throwable>（注意：handle 实际上接收的是 BiFunction<t throwable extends u></t>），无论成功还是失败都会执行，适合需要同时处理正常结果和异常的复杂场景。对于简单的“出错给个默认值”需求，exceptionally() 更简洁。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class ExceptionHandlingDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 模拟一个可能失败的异步任务
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
if (true) { // 模拟异常条件
throw new RuntimeException("模拟业务异常");
}
return "正常结果";
});
// 使用 exceptionally 处理异常并继续链式调用
CompletableFuture<String> resultFuture = future
.exceptionally(ex -> {
System.out.println("捕获异常: " + ex.getMessage());
return "默认返回值"; // 返回替代值，使链式调用继续
})
.thenApply(result -> {
System.out.println("后续处理: " + result);
return result.toUpperCase();
});
// 获取最终结果
String finalResult = resultFuture.get();
System.out.println("最终结果: " + finalResult);
}
}基于程序中某个输入、条件或结果的具体问题
在上述代码中，当 supplyAsync 中的 lambda 表达式抛出 RuntimeException 时，exceptionally 块会被触发。此时，thenApply 不会执行原任务的异常堆栈传播，而是接收 exceptionally 返回的字符串 "默认返回值"。这意味着链式调用并未中断，而是进入了正常的流处理路径。如果希望区分不同异常类型，可以在 exceptionally 内部进行判断，或者使用 handle 方法同时访问正常值和异常对象，以实现更精细的控制。
立即学习“Java免费学习笔记（深入）”；
