vert.x 是一个用于在 jvm 上开发反应式应用程序的工具包。我之前写过一篇简短的介绍性文章，当时我将它用于商业项目。几周前，我不得不重新审视一个基于 vert.x 的业余爱好项目，我了解到我对 vert.x 如何处理故障和错误的知识存在一些差距。为了填补这些空白，我做了一些实验，编写了一些测试，然后写了这篇博文。
大多数基于 vert.x 的 web 应用程序的核心是路由器。路由器根据请求的路径将请求路由到零个或多个请求处理程序。如果一切顺利，处理给定请求的处理程序将发出响应。当出现问题时，vert.x 提供故障处理程序和错误处理程序来处理这种情况。
如何发出请求处理程序中出现问题的信号？
请求处理程序中的错误有两种类型：要么抛出异常（有意或无意），要么通过在路由上下文上调用fail方法来显式发出错误信号。如果您想通过调用此方法来表明出现问题，您有以下三种选择：
- 您可以提供状态代码，
- 您可以提供状态代码和异常，或者
- 您可以提供例外。
抛出异常与以异常作为参数调用fail方法具有相同的效果。如果调用失败时没有提供状态码，则使用状态码500。如果调用失败时提供了异常，则该异常将可供所有失败和错误处理程序使用。
如果没有任何错误或失败处理程序，vert.x 将响应失败的请求，状态代码为 500，正文包含“内部服务器错误”。如果该响应不适合您的需求，您需要注册一个错误处理程序和/或一个或多个失败处理程序。
错误处理程序
您可以向路由器的每个状态代码注册一个错误处理程序。如果在处理请求时发生某些故障并且没有故障处理程序（更多信息见下文），则为与该故障对应的状态代码注册的错误处理程序将处理该请求：
@test
void errorhandlercanhandleexception(vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var errorhandlerexecuted = vertxtestcontext.checkpoint();
router.route("/")
.handler(rc -> {
handlerexecuted.flag();
throw new runtimeexception(request_handler_error_message);
});
router.errorhandler(500, rc -> {
errorhandlerexecuted.flag();
rc.response()
.setstatuscode(500)
.end(message_from_error_handler + ": " + rc.failure().getmessage());
});
var response = performgetrequest("/");
assertthat(response.statuscode()).isequalto(500);
assertthat(response.body()).startswith(message_from_error_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
如上所述，错误处理程序可以访问导致调用错误处理程序的异常。在此示例中，状态代码 500 的错误处理程序处理该错误，因为这是未提供其他状态代码时的默认状态代码。
vert.x 支持使用子路由器将单个（大型）路由器拆分为多个较小的路由器。虽然可以为每个子路由器注册错误处理程序，但它们将被简单地忽略：
@test
void errorhandlerforsubrouterisignored(vertx vertx, vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var rooterrorhandlerexecuted = vertxtestcontext.checkpoint();
var subrouter = router.router(vertx);
subrouter.errorhandler(500, rc ->
vertxtestcontext.failnow("error handler for sub router should not be reached"));
subrouter.route("/route")
.handler(rc -> {
handlerexecuted.flag();
throw new runtimeexception(request_handler_error_message);
});
router.route("/sub/*")
.subrouter(subrouter);
router.errorhandler(500, rc -> {
rooterrorhandlerexecuted.flag();
rc.response()
.setstatuscode(500)
.end(message_from_error_handler + ": " + rc.failure().getmessage());
});
var response = performgetrequest("/sub/route");
assertthat(response.statuscode()).isequalto(500);
assertthat(response.body()).startswith(message_from_error_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
故障处理程序
在某些情况下，您可能需要对错误的处理方式进行更细粒度的控制。这就是故障处理程序的用武之地。每个路由可以注册一个或多个故障处理程序。它们将按照注册的顺序处理错误，直到处理程序成功处理错误或引发异常。
与错误处理程序一样，失败处理程序可以访问导致其调用的异常。他们还可以访问状态代码：
使用模板与程序分离的方式构建，依靠专门设计的数据库操作类实现数据库存取，具有专有错误处理模块，通过 Email 实时报告数据库错误，除具有满足购物需要的全部功能外，成新商城购物系统还对购物系统体系做了丰富的扩展，全新设计的搜索功能，自定义成新商城购物系统代码功能代码已经全面优化，杜绝SQL注入漏洞前台测试用户名：admin密码：admin888后台管理员名：admin密码：admin888
@test
void failurehandlercanhandlefailwithstatuscodeandexception(vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var failurehandlerexecuted = vertxtestcontext.checkpoint();
router.route("/")
.handler(rc -> {
handlerexecuted.flag();
rc.fail(418, new runtimeexception(request_handler_error_message));
})
.failurehandler(rc -> {
failurehandlerexecuted.flag();
rc.response()
.setstatuscode(rc.statuscode())
.end(message_from_failure_handler + ": " + rc.failure().getmessage());
});
var response = performgetrequest("/");
assertthat(response.statuscode()).isequalto(418);
assertthat(response.body()).startswith(message_from_failure_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
一旦失败处理程序成功处理失败，就不会调用任何错误处理程序：
@test
void errorhandlerisignoredwhenfailurehandlerhandledfailure(vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var failurehandlerexecuted = vertxtestcontext.checkpoint();
router.route("/")
.handler(rc -> {
handlerexecuted.flag();
throw new runtimeexception(request_handler_error_message);
})
.failurehandler(rc -> {
failurehandlerexecuted.flag();
rc.response()
.setstatuscode(rc.statuscode())
.end(message_from_failure_handler + ": " + rc.failure().getmessage());
});
router.errorhandler(500, rc -> vertxtestcontext.failnow("error should not reach error handler"));
var response = performgetrequest("/");
assertthat(response.statuscode()).isequalto(500);
assertthat(response.body()).startswith(message_from_failure_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
如果一个故障处理程序无法处理某个故障，它可以让它由下一个故障处理程序处理：
@test
void failurehandlercandefertonextfailurehandler(vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var firstfailurehandlerexecuted = vertxtestcontext.checkpoint();
var secondfailurehandlerexecuted = vertxtestcontext.checkpoint();
router.route("/")
.handler(rc -> {
handlerexecuted.flag();
throw new runtimeexception(request_handler_error_message);
})
.failurehandler(rc -> {
firstfailurehandlerexecuted.flag();
rc.next();
})
.failurehandler(rc -> {
secondfailurehandlerexecuted.flag();
rc.response()
.setstatuscode(rc.statuscode())
.end(message_from_failure_handler + ": " + rc.failure().getmessage());
});
var response = performgetrequest("/");
assertthat(response.statuscode()).isequalto(500);
assertthat(response.body()).startswith(message_from_failure_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
如果处理失败导致异常，则原始失败的处理将由错误处理程序接管：
@test
void exceptioninfailurehandlerisignoredbyerrorhandler(vertxtestcontext vertxtestcontext) {
var handlerexecuted = vertxtestcontext.checkpoint();
var failurehandlerexecuted = vertxtestcontext.checkpoint();
var errorhandlerexecuted = vertxtestcontext.checkpoint();
router.route("/")
.handler(rc -> {
handlerexecuted.flag();
throw new runtimeexception(request_handler_error_message);
})
.failurehandler(rc -> {
failurehandlerexecuted.flag();
throw new runtimeexception(failure_handler_error_message);
});
router.errorhandler(500, rc -> {
errorhandlerexecuted.flag();
rc.response()
.setstatuscode(500)
.end(message_from_error_handler + ": " + rc.failure().getmessage());
});
var response = performgetrequest("/");
assertthat(response.statuscode()).isequalto(500);
assertthat(response.body()).startswith(message_from_error_handler);
assertthat(response.body()).endswith(request_handler_error_message);
vertxtestcontext.succeedingthencomplete();
}
如果没有为状态代码 500 注册错误处理程序，则故障处理程序中抛出的异常将导致内部服务器错误。
我们在上面看到在子路由器上注册的错误处理程序被忽略。然而，为子路由器上的路由注册的故障处理程序按预期运行。为子路由器的其中一个路由注册的失败处理程序可以返回响应本身，也可以回退到另一个匹配路由的失败处理程序：
@Test
void failureHandlerForSubRouterCanFallBackToFailureHandlerForRoot(Vertx vertx, VertxTestContext vertxTestContext) {
var handlerExecuted = vertxTestContext.checkpoint();
var rootFailureHandlerExecuted = vertxTestContext.checkpoint();
var subFailureHandlerExecuted = vertxTestContext.checkpoint();
var subRouter = Router.router(vertx);
subRouter.route("/route")
.handler(rc -> {
handlerExecuted.flag();
throw new RuntimeException(REQUEST_HANDLER_ERROR_MESSAGE);
})
.failureHandler(rc -> {
subFailureHandlerExecuted.flag();
rc.next();
});
router.route("/sub/*")
.subRouter(subRouter);
router.route()
.failureHandler(rc -> {
rootFailureHandlerExecuted.flag();
rc.response()
.setStatusCode(500)
.end(MESSAGE_FROM_FAILURE_HANDLER + ": " + rc.failure().getMessage());
});
var response = performGetRequest("/sub/route");
assertThat(response.statusCode()).isEqualTo(500);
assertThat(response.body()).startsWith(MESSAGE_FROM_FAILURE_HANDLER);
assertThat(response.body()).endsWith(REQUEST_HANDLER_ERROR_MESSAGE);
vertxTestContext.succeedingThenComplete();
}
结论
正如我们所见，错误处理程序非常简单。实际上，每个状态代码只能有一个错误处理程序，并且如果该错误尚未以其他方式处理，则该处理程序将处理给定状态代码的每个错误。
关于失败处理程序还有更多要说的。每个路由可以有多个错误处理程序，它将按照处理程序注册的顺序处理错误。如果路由重叠（与给定请求的路径匹配的多个路由），则按照注册路由的顺序调用每个路由的故障处理程序。每个故障处理程序都可以决定让下一个故障处理程序处理错误。
我希望这篇文章能为 vert.x 的官方文档提供有用的补充。如果您想自己尝试一下，请克隆并浏览 https://github.com/ljpengelen/vertx-error-and-failure-handlers 以获得一些灵感和一个不错的起点。
