Java CompletableFuture 怎么处理异步任务异常-java教程-PHP中文网

completablefuture异常处理分“捕获感知”和“恢复兜底”：handle统一收口做可观测性与分支判断，exceptionally专做同类型降级返回，whencomplete专注副作用清理；三者常链式组合使用。

java completablefuture 怎么处理异步任务异常

CompletableFuture 处理异步任务异常，核心是区分“捕获感知”和“恢复兜底”两个层次：用 handle 统一收口做可观测性与分支判断，用 exceptionally 专做类型一致的降级返回，二者常串联使用。

exceptionally：只在出错时执行，返回同类型默认值

它像一道安全闸门，仅当前链中任意上游阶段抛出未捕获异常（包括 RuntimeException、NPE、流操作异常等）时触发，正常完成则完全跳过。

参数是 Throwable，必须返回与原始 CompletableFuture 泛型类型相同的值
适合提供缓存数据、空集合、占位字符串等轻量级 fallback
无法拿到原始成功结果，也不方便按异常类型做多路分支（需配合 instanceof）

示例：
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
  if (Math.random() > 0.5) throw new IOException("连接超时");
  return "data";
}).exceptionally(ex -> {
  log.warn("降级响应", ex);
  return "fallback"; // 类型匹配 String
});

handle：无论成败都执行，支持结果与异常双路径处理

它接收两个参数：result（成功时非 null，失败时为 null）和 ex（失败时非 null，成功时为 null），天然支持“二选一”逻辑分支。

Gradle 9.8.0

下载

可统一加日志、打监控指标、转换结果格式，或根据异常类型返回不同降级值
返回类型可变（泛型自由），比如从 String 转成 Result
若在 handle 中主动 throw 新异常，该异常会继续向下游传播

示例：
CompletableFuture future = CompletableFuture.supplyAsync(() -> 100)
  .thenApply(x -> x / 0) // 故意触发 ArithmeticException
  .handle((result, ex) -> {
    if (ex != null) {
      if (ex instanceof ArithmeticException) return -1;
      else throw new RuntimeException("不可恢复异常", ex);
    }
    return result * 2;
  });

whenComplete：不改变结果，专注副作用清理

类似 finally，一定执行，但不参与结果计算。适合资源释放、最终状态上报、耗时统计等不影响业务值的操作。

参数也是 (result, ex)，但方法签名返回 void
不能修改结果或返回新值，仅用于“事后记录”
常与 exceptionally 或 handle 配合：前者管恢复，后者管收尾

示例：
future.whenComplete((result, ex) -> {
  if (ex != null) {
    metrics.counter("api.fail").increment();
  } else {
    metrics.timer("api.latency").record(System.nanoTime() - start);
  }
});