spring boot 的全局异常处理无法直接捕获 vert.x 事件循环中的异常，因为 vert.x 运行在独立的线程模型中，其异常不会自动传播到 spring 的 dispatcherservlet 线程。要解决这个问题，必须通过 setexceptionhandler 注册全局异常处理器，并在其中手动将异常转换为 http 响应或触发 spring 的异常处理机制。
如何配置 Vert.x 全局异常处理器以拦截错误
需要在创建 VertxHttpAdapter 或 Router 时设置异常处理器。通过调用 router.exceptionHandler() 可以捕获所有路由处理中抛出的异常。在这个处理器中，你可以记录日志、收集指标，或者将异常包装为标准的 HTTP 错误响应返回给客户端。
import io.vertx.core.Vertx;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.handler.BlockingHandler;
public class VertxConfig {
public Router createRouter(Vertx vertx) {
Router router = Router.router(vertx);
// 注册全局异常处理器
router.exceptionHandler(exception -> {
System.err.println("Caught exception: " + exception.getMessage());
exception.response()
.setStatusCode(500)
.putHeader("content-type", "text/plain")
.end("Internal Server Error");
});
// 添加你的路由...
return router;
}
}
上述代码展示了如何在 Vert.x 层面捕获异常并返回 500 状态码。这确保了即使业务逻辑抛出未检查异常，客户端也能收到明确的错误响应，而不是连接挂起或超时。
如何将 Vert.x 异常桥接到 Spring Boot 的全局异常处理
如果你希望复用 Spring Boot 的 @ControllerAdvice 或 ResponseEntityExceptionHandler，可以在 Vert.x 的异常处理器中手动触发 Spring 的异常解析流程。这需要获取 Spring 的 HandlerExceptionResolver 链，并模拟一个请求上下文来传递异常信息。
import org.springframework.web.servlet.HandlerExceptionResolver;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import io.vertx.core.http.HttpServerResponse;
import io.vertx.ext.web.RoutingContext;
public class SpringVertxBridge {
private final HandlerExceptionResolver exceptionResolver;
public void handleException(RoutingContext context, Throwable ex) {
HttpServerResponse response = context.response();
HttpServletRequest servletRequest = context.request().getDelegate();
HttpServletResponse servletResponse = new HttpServletResponseWrapper(response);
try {
ModelAndView mav = exceptionResolver.resolveException(
servletRequest, servletResponse, null, ex
);
if (mav != null && mav.getModel() != null) {
// 根据 ModelAndView 构建响应
response.setStatusCode(200); // 假设成功
response.end("Handled by Spring");
} else {
response.setStatusCode(500);
response.end("Unhandled Exception");
}
} catch (Exception e) {
response.setStatusCode(500);
response.end("Error resolving exception");
}
}
}
这种桥接方式允许你利用现有的 Spring 异常处理逻辑，如自定义错误页面或 JSON 错误体。注意，由于 Vert.x 是非阻塞的，确保 HandlerExceptionResolver 的实现也是非阻塞的，或者使用 BlockingHandler 包裹可能阻塞的操作。
当 Vert.x 处理异步回调失败时，全局异常处理会失效吗
是的，如果异常发生在异步回调内部且未被捕获，它不会触发 exceptionHandler。这是因为 Vert.x 的事件循环线程在回调执行期间是独立的，除非你在回调中显式抛出异常并被 Vert.x 框架捕获，否则异常会被静默丢弃或导致线程崩溃。因此，必须在每个异步回调中显式处理错误或向上层传递异常。
import io.vertx.core.Future;
import io.vertx.core.Vertx;
public class AsyncExample {
public void processAsync(Vertx vertx) {
vertx.executeBlocking(future -> {
try {
// 模拟耗时操作
Thread.sleep(1000);
future.complete("Result");
} catch (Exception e) {
future.fail(e); // 正确地将异常传递给 Vert.x
}
}, res -> {
if (res.succeeded()) {
System.out.println(res.result());
} else {
// 这里可以再次抛出异常以触发 exceptionHandler
throw new RuntimeException(res.cause());
}
});
}
}
在 executeBlocking 的完成处理器中，如果 res.failed()，我们选择抛出一个新的运行时异常。这个异常会在当前事件循环线程中传播，从而被之前注册的 router.exceptionHandler() 捕获。这是确保异步操作错误能被全局处理的关键步骤。如果不这样做，错误将仅限于回调内部，无法被上层统一处理。
