Java CompletableFuture异步消费异常处理的艺术

在Java并发编程中，CompletableFuture无疑是一个强大的工具，它提供了灵活的异步编程模型，使得我们能够轻松地处理异步任务。然而，在享受其便利的同时，如何优雅地处理异步消费中的异常，成为了一个不可忽视的问题。

异常处理的挑战

在使用CompletableFuture时，我们常常会遇到异步任务执行过程中抛出的异常。这些异常如果不被妥善处理，可能会导致程序崩溃或者状态不一致。传统的异常处理方式在异步环境下显得力不从心，因为异步任务的执行和结果的消费是分离的。

CompletableFuture的异常处理机制

CompletableFuture提供了一系列方法来处理异常，例如exceptionally、handle和whenComplete。这些方法各有千秋，适用于不同的场景。

exceptionally方法

exceptionally方法用于处理异步任务中的异常。它接受一个Function接口的实现，该接口的输入参数是Throwable，输出参数是任务的返回类型。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
}).exceptionally(ex -> "Failed with exception: " + ex.getMessage());

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

handle方法

handle方法不仅可以处理异常，还可以处理正常的任务结果。它接受一个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 "Failed with exception: " + ex.getMessage();
    }
    return result;
});

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

whenComplete方法

whenComplete方法用于在异步任务完成时执行一些操作，无论任务是成功还是失败。它接受一个BiConsumer接口的实现，该接口的输入参数是任务的结果和异常。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
}).whenComplete((result, ex) -> {
    if (ex != null) {
        System.out.println("Failed with exception: " + ex.getMessage());
    } else {
        System.out.println("Result: " + result);
    }
});

future.join();

创意应用：异常日志记录

在实际应用中，我们可以结合这些方法来实现更复杂的异常处理逻辑。例如，我们可以使用whenComplete方法来记录异常日志，同时使用handle方法来处理异常并返回一个默认值。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
}).whenComplete((result, ex) -> {
    if (ex != null) {
        System.err.println("Error occurred: " + ex.getMessage());
    }
}).handle((result, ex) -> {
    if (ex != null) {
        return "Default value due to exception";
    }
    return result;
});

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