completablefuture异常处理核心是“异常也是结果”,通过exceptionally(失败兜底)、handle(统一成败处理)、whencomplete(仅清理)三类回调实现可传递、可分类、可恢复的错误流。

CompletableFuture 的异常处理不是靠 try-catch 堵住,而是用链式回调把错误变成可传递、可分类、可恢复的数据流。关键在于理解“异常也是结果”这一设计哲学——它不中断链,而是让异常走另一条路径,由你决定如何收口。
exceptionally:专注失败兜底,返回替代值
这是最常用也最轻量的异常处理方式。它只在上游任一环节抛出未捕获异常时触发,接收 Throwable,返回与原始类型一致的备用结果。
- 适合远程调用失败后返回缓存、空集合、默认文案等降级场景
- 不会改变链的状态:返回值会让整个 CompletableFuture 变为正常完成,下游 thenApply 等可继续执行
- 注意它不区分异常来源阶段,也无法修改异常本身;若需重抛或转成业务异常,可在 lambda 内手动 throw new BusinessException(..., ex)
示例:
CompletableFuture
if (Math.random() > 0.7) throw new IOException("网络不可达");
return "data";
}).exceptionally(ex -> {
log.warn("获取数据失败,启用本地兜底", ex);
return "default-from-local";
});
handle:统一入口,兼顾成功与失败逻辑
handle 接收两个参数:结果(可能为 null)和异常(可能为 null),无论上游成败都会执行。它像一个“双通道开关”,让你在一个方法里做分支判断。
- 适合按异常类型精细化响应:比如 ArithmeticException 返回 -1,TimeoutException 触发重试,其他异常包装后重新抛出
- 也可用于对成功结果做统一后处理,如加日志、格式转换、埋点统计
- 若在 handle 中抛出新异常,该异常会继续向下游传播,可被后续 exceptionally 或 whenComplete 捕获
示例:
.handle((result, ex) -> {
if (ex != null) {
if (ex instanceof TimeoutException) return retryFetch();
else if (ex instanceof BusinessException) return handleBusinessError(ex);
throw new RuntimeException("未预期异常", ex);
}
return enrichResult(result); // 正常路径加工
});
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
whenComplete:只做清理,不碰结果
whenComplete 也始终执行,但它不返回新值,只接收结果和异常作副作用处理,类似 finally。它的存在意义是“不管成不成功,有些事必须做”。
- 典型用途:记录耗时日志、关闭连接、释放线程局部变量、上报监控指标、发送告警
- 不能改变 CompletableFuture 的最终状态或结果;如果想在清理后返回新值,应改用 handle
- 避免在其中阻塞操作(如同步写磁盘),以免拖慢异步链
示例:
.whenComplete((result, ex) -> {
long elapsed = System.nanoTime() - start;
if (ex == null) {
Metrics.success("fetch-user", elapsed);
} else {
Metrics.fail("fetch-user", elapsed, ex.getClass().getSimpleName());
}
});
预防胜于补救:从源头统一异常封装
很多静默失败源于同步异常逃逸——比如 supplyAsync 外部先校验参数,抛出 IllegalArgumentException,这个异常根本进不了 CompletableFuture 的异常处理链。
- 把所有可能出错的逻辑(包括参数检查、资源准备)都包进 supplyAsync 或 runAsync 的 lambda 体内
- 在 lambda 内统一 catch Exception,并包装为 CompletionException,确保所有异常走同一通道
- 这样调用方只需一套 exceptionally/handle 就能覆盖全部失败路径,无需额外 try-catch
示例:
return CompletableFuture.supplyAsync(() -> {
try {
if (id == null) throw new IllegalArgumentException("ID 不能为空");
return doRealWork(id);
} catch (Exception e) {
throw new CompletionException("任务执行异常", e);
}
});
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










