completablefuture 实现异步编排的核心是组合（thencompose 等）、并行（allof）、异常处理（exceptionally）和条件分支（thencombine），而非串行调用；thencompose 可扁平化嵌套异步链，allof 支持真正并发执行，exceptionally 用于优雅降级，条件分支应直接返回 completablefuture。
Java 中用 CompletableFuture 实现复杂异步编排，核心在于组合（thenApply、thenCompose）、并行（allOf、anyOf）、异常处理（exceptionally、handle）和条件分支（thenAcceptBoth、runAfterBoth），而不是简单串行调用。
用 thenCompose 实现真正的异步链式依赖
很多人误用 thenApply 包裹另一个 CompletableFuture，结果嵌套成 CompletableFuture<completablefuture>></completablefuture>。正确做法是用 thenCompose —— 它会“压平”一层，让下游任务真正等待上游异步结果后再启动新异步操作。
例如：先查用户，再根据 ID 查订单，最后汇总统计：
CompletableFuture<user> userF = fetchUserAsync(123);
CompletableFuture<list>> ordersF = userF.thenCompose(user ->
fetchOrdersAsync(user.getId())
);
CompletableFuture<report> reportF = ordersF.thenCompose(orders ->
generateReportAsync(orders)
);</report></list></user>
每一步都是独立异步任务，且严格按依赖顺序执行，不会阻塞线程。
并行聚合多个不相关异步任务
当多个数据源可独立拉取（如商品信息、库存、促销规则），用 CompletableFuture.allOf + join() 组合结果；注意 allOf 返回 CompletableFuture<void></void>，需手动收集结果。
- 先发起全部请求，不等待
- 用
allOf等待全部完成 - 用
thenApply在完成后的上下文中统一取值
示例：
CompletableFuture<product> pF = fetchProductAsync(id);
CompletableFuture<stock> sF = fetchStockAsync(id);
CompletableFuture<promotion> prF = fetchPromotionAsync(id);
CompletableFuture<void> all = CompletableFuture.allOf(pF, sF, prF);
CompletableFuture<detailpage> pageF = all.thenApply(v ->
new DetailPage(
pF.join(),
sF.join(),
prF.join()
)
);</detailpage></void></promotion></stock></product>
这样三路请求真正并发，总耗时约等于最慢的那个，而非累加。
优雅处理异步链中的失败与降级
不要在 lambda 里 try-catch，也不要用 get() 同步等结果。推荐组合使用：
-
exceptionally()：提供兜底值（如返回空列表、默认配置） -
handle()：需要区分成功/失败并做不同处理（如打日志+返回默认值） -
orTimeout()+exceptionally()：给关键异步操作设超时
例如订单查询超时后返回缓存数据：
CompletableFuture<order> orderF = fetchOrderAsync(orderId)
.orTimeout(2, TimeUnit.SECONDS)
.exceptionally(ex -> {
log.warn("Order fetch timeout, fallback to cache", ex);
return cache.getOrder(orderId); // 缓存读取是同步的
});</order>
条件分支与双路汇合
当后续逻辑取决于前序异步结果，避免在 thenApply 里写 if-else 启动新 CompletableFuture，而应直接返回对应任务：
userF.thenCompose(user -> {
if (user.isVip()) {
return loadVipBenefitsAsync(user.getId());
} else {
return loadBasicFeaturesAsync(user.getId());
}
});
若需等两个异步结果都就绪再处理（如比对新旧配置），用 thenCombine 或 thenAcceptBoth：
newConfF.thenCombine(oldConfF, (n, o) ->
computeDiff(n, o)
);
它内部自动处理任一失败的情况（除非显式用 handle 覆盖）。
CompletableFuture 的能力远不止“异步变非阻塞”，关键是把任务依赖关系声明化、组合操作函数化。写多了就会发现：编排逻辑越清晰，出错时定位越快，扩展新分支也越自然。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
