CompletableFuture异常需显式处理而非try-catch:handle统一处理结果与异常,exceptionally仅fallback异常且保持类型,whenComplete仅作副作用消费不改变结果。
CompletableFuture 的异常处理不是靠 try-catch 包裹,而是通过专门的异常回调方法主动捕获和响应。核心在于:异常不会自动抛出到调用线程,必须显式注册处理逻辑,否则会静默丢失。
当 CompletableFuture 执行过程中发生未捕获异常(如 supplyAsync 中抛出 RuntimeException),该异常会被封装进 CompletableFuture 内部,但不会中断主线程,也不会在 get() 之外自动暴露。若未调用 get()、join() 或注册异常处理方法,异常将被忽略。
常见误区是以为链式调用中上一个 stage 抛异常,下一个 thenApply 就会跳过——实际是整个链会短路,后续正常回调不执行,但异常仍需专门捕获。
handle(BiFunction 是最灵活的兜底方法,无论前序成功或失败,都会执行。它接收两个参数:正常结果(成功时非 null)和异常(失败时非 null),二者必居其一。
throwable 为 null,可直接处理结果result 为 null,可检查 throwable 类型并恢复或转换示例:
future.handle((result, ex) -> {
if (ex != null) {
log.error("查询失败", ex);
return "默认值";
}
return result.toUpperCase();
});
exceptionally(Function 只在前序异常时触发,返回值类型必须与原始 CompletableFuture 的泛型一致(即提供 fallback 值)。它不能访问正常结果,也不影响成功路径。
getCause() 获取示例:
future.exceptionally(ex -> {
if (ex instanceof TimeoutException) {
return "请求超时,请稍后重试";
} else if (ex.getCause() instanceof IOException) {
return "服务不可用";
}
retur
n "未知错误";
});
whenComplete(BiConsumer 类似 handle,但不返回新 CompletableFuture,常用于纯副作用操作(如清理资源、发监控告警、打日志)。
示例:
future.whenComplete((result, ex) -> {
if (ex != null) {
metrics.recordFailure(ex.getClass().getSimpleName());
} else {
metrics.recordSuccess();
}
});