如何通过 CompletableFuture 的 exceptionallyCompose 实现异步重试的容错链路？

本文共计970个文字，预计阅读时间需要4分钟。

javaexceptionallyCompose() 不是标准的 Java CompletableFuture 方法 — 它不存在于 JDK 8/11/17/21 的任何版本中。

你看到的 exceptionallyComposeAsync() 是 .NET for Android（即 Mono.Android）平台对 Java API 的非标准绑定，仅在 Android 上通过 C# 实现。

如果你的目标是在 Java 中实现「异常发生后触发异步重试」的容错链路，必须绕过这个不存在的方法，改用原生组合能力。

---

exceptionally 只能返回值，不能返回新的 CompletableFuture

exceptionally 接收 Function<Throwable, T>，要求你同步返回一个 T 类型值，比如字符串、对象或 null。它不接受返回 CompletableFuture<t></t> 的函数：

// ❌ 编译失败：类型不匹配 future.exceptionally(ex -> CompletableFuture.supplyAsync(() -> "retry")); // ✅ 正确：只能返回 String，不能返回 CompletableFuture<String> future.exceptionally(ex -> "fallback");

想在异常后发起新异步任务（比如重试），必须用 exceptionallyCompose 的语义替代品 —— 实际上是 handle + thenCompose 组合。

---

用 handle 捕获异常并触发异步重试逻辑

handle 是唯一既能拿到结果又能拿到异常、且允许返回 CompletableFuture 的入口点：

• 它接收 BiFunction<T, Throwable, U>，但注意：返回值可以是 CompletableFuture<u></u>，只要你在内部手动包装
• 真正的异步重试必须由你自己构造新 CompletableFuture，不能依赖框架自动“重放”

典型模式如下：

CompletableFuture<String> withRetry = CompletableFuture.supplyAsync(() -> { if (Math.random() < 0.7) throw new RuntimeException("fail on purpose"); return "success"; }).handle((result, ex) -> { if (ex != null) { // 异常时，启动重试（最多 2 次） return retryAsync(() -> supplyAsyncWithLogic(), 2); } return CompletableFuture.completedFuture(result); }).thenCompose(Function.identity()); // 展开嵌套的 CompletableFuture

其中 retryAsync 是你写的工具方法，核心逻辑包括：

• 判断是否达到最大重试次数
• 捕获每次执行的异常，不抛出而是继续下一次
• 使用 delayedExecutor 或 ScheduledExecutorService 控制退避间隔

---

容易踩的坑：allOf / thenCombine 后的异常会静默丢失

CompletableFuture.allOf 返回的是 CompletableFuture<void></void>，它不携带任何子任务的异常信息。即使某个子 future 失败，allOf 本身也不会失败，除非你显式调用 join() 或 get()。

同样，thenCombine 在任一入参 future 失败时，整个 future 会进入异常状态 —— 但如果你没在链尾加 exceptionally 或 handle，异常就滞留在 future 内部，后续 join() 才暴露，且原始堆栈可能被包装成 CompletionException。

所以真实链路中，每个可能失败的分支都应尽早兜底：

CompletableFuture<String> task1 = fetchUser(); CompletableFuture<String> task2 = fetchOrder(); CompletableFuture<Void> combined = CompletableFuture.allOf(task1, task2); // ❌ 危险：combined.join() 抛出的异常无法区分是哪个子任务失败 // ✅ 应该分别处理： task1.exceptionally(ex -> { log.error("user fetch failed", ex); return "default-user"; }); task2.exceptionally(ex -> { log.error("order fetch failed", ex); return "empty-order"; });

---

exceptionallyCompose 这个名字听起来很合理，但它不是 Java 的 API。所有基于它的设计都会在编译阶段失败。真正的异步重试必须靠 handle + 手动构造 CompletableFuture + 显式调度控制来落地，而且每层组合都要预设异常出口，否则错误会在链中悄然消失。