CompletableFuture异步异常处理需可感知、可分类、可恢复：exceptionally()用于统一兜底；handle()支持成功/异常双路径精细化处理；whenComplete()专注副作用清理；组合策略实现分层捕获与主动恢复。
在 CompletableFuture 中做异步异常处理，关键不是“吞掉异常”或“抛出后不管”，而是让异常可感知、可分类、可恢复，并与业务逻辑自然衔接。
用 exceptionally() 捕获链路中任意上游异常
这是最常用也最直观的方式：当整个异步链（从创建到当前）中任一环节抛出未捕获异常时，exceptionally() 会接收该 Throwable 并返回一个默认值或兜底结果。
注意它只触发一次，且不会中断后续链式调用（除非你主动返回另一个异常 CompletableFuture）：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
if (Math.random() > 0.5) throw new RuntimeException("模拟失败");
return "success";
}).exceptionally(ex -> {
log.error("任务执行失败", ex);
return "fallback-result"; // 返回替代结果，类型需匹配
});
- 适合兜底场景：如远程调用失败时返回缓存值、空列表或默认文案
- 不适用于需要重试、转换异常类型或分情况处理的复杂逻辑
- 无法区分是哪个阶段出错，仅知道“链上某处炸了”
用 handle() 同时处理成功与异常结果
handle() 提供统一出口：无论上游是正常完成还是抛异常，都会进入该回调，参数包含结果（可能为 null）和异常（可能为 null），由你自行判断分支。
CompletableFuture<Integer> result = CompletableFuture.supplyAsync(() -> 42)
.thenApply(x -> x / 0) // 故意除零
.handle((val, ex) -> {
if (ex != null) {
if (ex instanceof ArithmeticException) {
return -1;
} else if (ex instanceof TimeoutException) {
return -2;
}
throw new RuntimeException("不可预期异常", ex);
}
return val;
});
- 适合需要按异常类型精细化响应的场景
- 可对成功结果再加工（比如加日志、转格式），比
thenApply+exceptionally更集中 - 注意：若在
handle中抛异常，该异常会传播给下游的exceptionally或whenComplete
用 whenComplete() 做“事后清理”，不改变结果
whenComplete() 类似 finally：一定执行，但不干预计算结果本身。常用于记录日志、释放资源、发监控指标等副作用操作。
CompletableFuture<Data> load = fetchDataAsync()
.whenComplete((data, ex) -> {
if (ex != null) {
metrics.counter("load.fail").increment();
auditLogger.warn("加载失败，ID={}", id, ex);
} else {
metrics.timer("load.success").record(Duration.between(start, Instant.now()));
}
});
- 不影响返回值，下游仍能拿到原始结果或异常
- 不能返回新值，也不能阻止异常传播
- 适合可观测性建设，避免把日志/埋点逻辑散落在各处
组合策略：分层捕获 + 异常转译 + 主动恢复
真实业务中往往需要多层协作。例如：网络请求失败 → 降级查本地缓存 → 缓存也无则返回友好提示；过程中任何一步异常都需归类上报。
CompletableFuture<User> userFuture = fetchRemoteUser(id)
.exceptionally(ex -> {
if (ex instanceof IOException) {
return loadFromCache(id).join(); // 同步查缓存（谨慎！）
}
throw new ServiceException("获取用户失败", ex);
})
.thenApply(user -> {
if (user == null) {
throw new UserNotFoundException("用户不存在: " + id);
}
return enrichUser(user);
})
.exceptionally(ex -> {
notifyAlert(ex); // 上报告警
return buildDefaultUser(id); // 构造兜底用户
});
- 第一层
exceptionally处理网络层异常，尝试降级 - 第二层
thenApply内做业务校验，主动抛业务异常 - 最后一层兜底，确保返回非 null 结果，并同步告警
- 所有异常都应保留原始堆栈（用
new Xxx(msg, ex)而非ex.getMessage()）
