Java CompletableFuture异常处理的艺术

在现代Java编程中，CompletableFuture无疑是一个强大的工具，它让我们能够以非阻塞的方式处理异步任务。然而，正如任何强大的工具一样，正确处理异常是确保程序稳定运行的关键。本文将深入探讨CompletableFuture的异常处理机制，并分享一些实用的技巧。

异常处理的必要性

在使用CompletableFuture时，任务可能会因为各种原因失败，比如网络问题、资源不足或逻辑错误。如果不妥善处理这些异常，程序可能会崩溃或表现出不可预测的行为。因此，理解并掌握CompletableFuture的异常处理机制是每个Java开发者的必修课。

基本异常处理

使用`exceptionally`方法

exceptionally方法是处理CompletableFuture异常的最直接方式。它接受一个Function接口的实现，该接口的输入参数是Throwable，输出是一个新的结果。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟一个可能抛出异常的任务
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
}).exceptionally(ex -> "Error: " + ex.getMessage());

System.out.println(future.join());

在上面的例子中，如果任务成功完成，future将返回"Success"；如果任务抛出异常，future将返回错误信息。

使用`handle`方法

handle方法比exceptionally更灵活，它无论任务是否成功都会被调用。它的输入参数是一个BiFunction，包含结果和异常。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟一个可能抛出异常的任务
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
}).handle((result, ex) -> {
    if (ex != null) {
        return "Error: " + ex.getMessage();
    }
    return result;
});

System.out.println(future.join());

在这个例子中，handle方法允许我们在一个地方处理正常结果和异常情况。

高级异常处理

组合多个`CompletableFuture`

在实际应用中，我们经常需要组合多个异步任务。使用thenCompose和thenCombine可以优雅地处理这种情况。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Result1");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Result2");

CompletableFuture<String> combined = future1.thenCombine(future2, (result1, result2) -> result1 + " + " + result2);

System.out.println(combined.join());

如果任何一个任务失败，组合后的CompletableFuture也会失败。我们可以使用handle或exceptionally来处理这些异常。

使用`allOf`和`anyOf`

CompletableFuture.allOf和anyOf用于处理多个CompletableFuture的聚合结果。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Result1");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Result2");

CompletableFuture<Void> allFutures = CompletableFuture.allOf(future1, future2);
CompletableFuture<String> combined = allFutures.thenApply(v -> future1.join() + " + " + future2.join());

System.out.println(combined.join());

如果任何一个任务失败，allOf会立即完成，但不会提供失败的详细信息。我们可以通过单独处理每个CompletableFuture的异常来解决这个问题。