1. CompletableFuture 链式调用概述在 Java 8 中引入的 CompletableFuture 类彻底改变了异步编程的方式。它不仅仅是一个简单的 Future 实现更是一个强大的异步编程工具特别适合处理复杂的异步任务链。通过链式调用我们可以优雅地编排多个异步操作避免了传统回调地狱的问题。CompletableFuture 的核心优势在于它提供了丰富的组合方法允许我们将多个异步操作以声明式的方式连接起来。这种编程模式特别适合 I/O 密集型应用比如网络请求、数据库操作等场景能够显著提高系统的吞吐量。2. 基础链式调用模式2.1 thenApply 方法thenApply 是最基础的转换方法它接受一个 Function对上一个阶段的结果进行转换CompletableFutureString future CompletableFuture.supplyAsync(() - Hello) .thenApply(s - s World) .thenApply(String::toUpperCase); System.out.println(future.get()); // 输出 HELLO WORLD这里需要注意thenApply 会在前一个阶段完成后立即执行且执行线程取决于前一个阶段的完成方式。如果前一个阶段已经完成则可能由当前线程直接执行。2.2 thenAccept 和 thenRun对于不需要返回值的场景可以使用 thenAccept消费结果和 thenRun不关心结果CompletableFuture.supplyAsync(() - Data) .thenAccept(result - System.out.println(Processing: result)) .thenRun(() - System.out.println(Clean up));提示thenAccept 和 thenRun 通常用于链的末端作为最终处理步骤。3. 组合多个 Future3.1 thenCompose 方法thenCompose 用于将一个 CompletableFuture 的结果作为另一个 CompletableFuture 的输入CompletableFutureString getUser CompletableFuture.supplyAsync(() - user123); CompletableFutureInteger getScore getUser.thenCompose(user - CompletableFuture.supplyAsync(() - user.length() * 100));这种模式特别适合需要连续异步操作的场景比如先查询用户再根据用户ID查询分数。3.2 thenCombine 方法当需要合并两个独立的 CompletableFuture 结果时可以使用 thenCombineCompletableFutureString future1 CompletableFuture.supplyAsync(() - Hello); CompletableFutureString future2 CompletableFuture.supplyAsync(() - World); CompletableFutureString combined future1.thenCombine(future2, (s1, s2) - s1 s2);4. 异常处理机制4.1 exceptionally 方法CompletableFuture 提供了专门的异常处理方法CompletableFuture.supplyAsync(() - { if (Math.random() 0.5) throw new RuntimeException(Error); return Success; }).exceptionally(ex - { System.out.println(Handled: ex.getMessage()); return Fallback; });4.2 handle 方法handle 方法无论成功还是失败都会执行可以统一处理两种场景CompletableFuture.supplyAsync(() - Task) .handle((result, ex) - { if (ex ! null) return Error case; return result processed; });5. 高级组合模式5.1 allOf 和 anyOf处理多个 CompletableFuture 的集合CompletableFutureVoid all CompletableFuture.allOf(future1, future2, future3); CompletableFutureObject any CompletableFuture.anyOf(future1, future2, future3);5.2 自定义线程池默认使用 ForkJoinPool.commonPool()但可以指定自定义线程池ExecutorService executor Executors.newFixedThreadPool(10); CompletableFuture.supplyAsync(() - Task, executor);6. 实际应用示例6.1 服务调用链模拟一个完整的服务调用流程CompletableFutureUser userFuture CompletableFuture.supplyAsync(() - userService.getUser(id)); CompletableFutureOrder orderFuture userFuture.thenCompose(user - CompletableFuture.supplyAsync(() - orderService.getLatestOrder(user.getId()))); CompletableFutureRecommendation recommendationFuture userFuture.thenCompose(user - CompletableFuture.supplyAsync(() - recommendationService.getForUser(user.getId()))); CompletableFutureUserProfile profileFuture userFuture.thenCombine( orderFuture.thenCombine(recommendationFuture, Pair::new), (user, pair) - new UserProfile(user, pair.getLeft(), pair.getRight()) );6.2 超时处理Java 9 引入了 orTimeout 和 completeOnTimeout 方法CompletableFuture.supplyAsync(() - longRunningTask()) .orTimeout(1, TimeUnit.SECONDS) .exceptionally(ex - Fallback due to timeout);7. 性能优化技巧避免阻塞不要在 thenApply/thenAccept 中执行阻塞操作合理分阶段将长任务分解为多个阶段提高并行度线程池隔离不同类型的任务使用不同的线程池结果缓存对相同参数的调用缓存 CompletableFuture 实例8. 常见问题排查链未执行检查是否漏掉了终端操作如 get/join线程饥饿监控线程池使用情况避免所有线程被阻塞内存泄漏注意未完成的 CompletableFuture 持有大对象异常丢失确保每个阶段都有适当的异常处理CompletableFuture 的链式调用为 Java 异步编程带来了革命性的改变。掌握这些模式可以显著提高代码的可读性和性能特别是在微服务架构中能够优雅地处理跨服务调用。实际使用中建议结合项目需求制定统一的异步编程规范。