CompletableFuture 通过链式调用（thenApply/thenAccept/thenRun）、扁平化组合（thenCompose）、统一异常处理（exceptionally/handle）及并发协调（allOf/anyOf）替代回调地狱，实现线性、可读、健壮的异步编程。
用 CompletableFuture 替代回调地狱，核心是把嵌套的异步调用“拉平”，通过链式调用和组合操作让逻辑线性表达，而不是层层缩进。
用 thenApply / thenAccept / thenRun 串行处理结果
传统回调中，每个异步操作结束后都要写一个新回调，容易形成多层嵌套。而 CompletableFuture 提供了语义清晰的后续操作方法：
-
thenApply：接收上一步结果，返回新值（适合转换） -
thenAccept：接收结果但不返回（适合消费，如打印、存库） -
thenRun：不关心结果，只执行动作（如发通知）
例如：查用户 → 查订单 → 计算总金额，可写成：
userService.findById(123)
.thenCompose(user -> orderService.findByUserId(user.getId()))
.thenApply(orders -> orders.stream().map(Order::getAmount).reduce(0.0, Double::sum))
.thenAccept(total -> System.out.println("总消费：" + total));
用 thenCompose 处理返回 CompletableFuture 的操作
当某一步本身也返回 CompletableFuture（比如另一个异步调用），直接用 thenApply 会导致 CompletableFuture<completablefuture>></completablefuture> —— 这就是“扁平化”要解决的问题。thenCompose 就是专为此设计的，它自动展平一层。
立即学习“Java免费学习笔记（深入）”；
对比：
-
thenApply：适合同步转换，或返回普通对象 -
thenCompose：适合返回新的CompletableFuture，避免嵌套
错误示范（回调地狱变体）：
在调试 Java 后端 API 故障时使用此技能，尤其适用于以下任务：分析日志、跨 Controller、Service 和 Mapper 层追踪请求、定位异常根因、检查 SQL 执行或参数流转，以及生成简洁的诊断结论与修复方案。
future1.thenApply(x -> service.asyncCall(x)) // 返回 CompletableFuture，结果类型不对
正确写法：
future1.thenCompose(x -> service.asyncCall(x)) // 类型保持 CompletableFuture<T>
用 exceptionally / handle 统一处理异常
回调地狱里，每层都得单独 try-catch，非常重复。CompletableFuture 支持集中异常处理：
-
exceptionally(Function<throwable t>)</throwable>：捕获异常并提供默认值（类似orElse） -
handle(BiFunction<t throwable r>)</t>：无论成功失败都执行，可区分处理
例如：
userService.findById(123)
.thenCompose(user -> orderService.findByUserId(user.getId()))
.exceptionally(t -> {
log.error("加载订单失败", t);
return Collections.emptyList();
})
.thenAccept(orders -> process(orders));
用 allOf / anyOf 并发协调多个任务
多个独立异步任务需要等全部完成（或任一完成），不再需要手写计数器或标志位。allOf 和 anyOf 返回新的 CompletableFuture，配合 join() 或后续链式操作使用：
-
CompletableFuture.allOf(f1, f2, f3).join()：阻塞等待全部完成（注意：不聚合结果） - 想拿到所有结果？用
stream.map(CompletableFuture::join).collect(...) -
anyOf返回最先完成的那个结果（类型为Object，需强转或统一包装）
实用小技巧：封装一个工具方法聚合多个 CompletableFuture<t></t> 的结果：
public static <T> CompletableFuture<List<T>> allAsList(List<CompletableFuture<T>> futures) {
CompletableFuture<Void> allDone = CompletableFuture.allOf(
futures.toArray(new CompletableFuture[0]));
return allDone.thenApply(v -> futures.stream()
.map(CompletableFuture::join)
.collect(Collectors.toList()));
}
不复杂但容易忽略：别忘了线程上下文（如事务、MDC）、超时控制（orTimeout）、取消传播（completeOnTimeout）这些关键点，它们共同构成健壮的异步流程。
