Vert.x中如何捕获onSuccess处理器中的异常？

• 外部try-catch无法捕获异步回调的异常：你写的try-catch仅作用于调用future()及链式方法的当前线程，但onSuccess回调是在Future任务完成后由独立的异步线程执行的，该线程不在外部try-catch的作用域内，因此无法捕获到异常。
• onFailure只监听Future自身的失败：onFailure的作用是处理Future任务本身执行过程中抛出的异常（比如future()内部逻辑出错导致Future失败），而你是在Future成功后的回调里抛出的异常，不属于Future本身的失败场景，所以onFailure不会触发。

1. 回调内部手动捕获异常 #

直接在onSuccess的Lambda逻辑里添加try-catch，主动处理抛出的异常：

private static void testExceptionInHandle() {
    try {
        var handler = future().onSuccess(v -> {
            try {
                throw new RuntimeException("hello exception");
            } catch (RuntimeException e) {
                // 这里执行异常处理逻辑，比如日志记录、业务补偿
                System.out.println("onSuccess内捕获异常:" + e.getMessage());
            }
        }).onFailure(e -> {
            System.out.println("onFailure:" + e.getMessage());
        });
    } catch (Exception e) {
        System.out.println("catch:" + e.getMessage());
    }
}

2. 使用handle方法统一处理 #

handle方法可以同时处理Future的成功和失败情况，并且能捕获回调内的异常，将其转化为Future的失败结果，让后续的onFailure可以统一处理：

private static void testExceptionInHandle() {
    try {
        var handler = future().handle((v, e) -> {
            if (e != null) {
                // 处理Future自身的原始失败
                System.out.println("处理Future原异常:" + e.getMessage());
                return null;
            }
            // 执行原本onSuccess的逻辑，异常会被handle捕获并转为Future失败
            throw new RuntimeException("hello exception");
        }).onFailure(e -> {
            // 这里可以捕获到Future原异常和回调内抛出的异常
            System.out.println("onFailure捕获异常:" + e.getMessage());
        });
    } catch (Exception e) {
        System.out.println("catch:" + e.getMessage());
    }
}

3. 全局异步异常捕获（针对Reactive框架） #

如果是基于Vert.x、Spring WebFlux这类Reactive框架，可以注册全局异常处理器，捕获所有未被手动处理的异步回调异常：

// 以Vert.x为例，注册全局异常处理器
Vertx vertx = Vertx.vertx();
vertx.exceptionHandler(globalException -> {
    System.out.println("全局捕获未处理的异步异常:" + globalException.getMessage());
});

内容的提问来源于stack exchange，提问作者Winter Lau