目前最快的 Java 框架居然是它?真的最快,秒射~
然而,事件循环只是故事的一半。另一半与Vert.x几乎没有关系。Java必备的 15 个框架,推荐看下。
要连接到数据库,客户端需要连接器驱动程序。在Java领域,Sql最常见的驱动程序是JDBC。问题是,这个驱动程序阻塞了。它在套接字级别阻塞。一个线程总会卡在那里,直到它返回一个响应。
毋庸置疑,驱动程序一直是实现完全无阻塞应用程序的瓶颈。幸运的是,在具有多个活动分叉的异步驱动程序上取得了进展(尽管是非官方的),其中包括:
https://github.com/jasync-sql/jasync-sql(适用于Postgres和MySql) https://github.com/reactiverse/reactive-pg-client(Postgres)
val vertx = Vertx.vertx()
vertx.createHttpServer().requestHandler(req => {
}).listen(8080)
方法requestHandler是事件循环传递请求事件的地方。由于Vert.x没有意见,处理它是自由的风格。但请记住非阻塞线程的唯一重要规则:不要阻止它。
在使用并发时,我们可以从如今的许多选项中获取,例如Promise,Future,Rx,以及Vert.x自己的惯用方法。但随着应用程序复杂性的增加,单独使用异步功能是不够的。我们还需要轻松协调和链接调用,同时避免回调地狱,以及优雅地传递任何错误。
Scala Future满足上述所有条件,并具有基于函数式编程原理的额外优势。虽然本文不深入探讨Scala Future,但我们可以通过一个简单的应用程序来尝试它。
假设该应用程序是一个API服务,用于查找给定其ID的用户:
val vertx = Vertx.vertx()
vertx.createHttpServer().requestHandler(req => {
req.path() match {
case p if p contains("/user") =>
val f = for {
f1 <- Future { req.getParam("id").get.toInt }
f2 <- if (f1 < 100) Future.unit else Future.failed(CustomException())
f3 <- Future { getUserFromDb(f1) }
} yield f3
f map (r => printout(req, r)) recover {case exception => printout(req, handleException(exception))}
case _ => printout(req, "Default page")
}
})
.listen(8080)
def printout(req: HttpServerRequest, msg: String) = req.response().end(msg)
def handleException(e: Throwable): String = {
e match {
case t: NoSuchElementException => "Missing parameter"
case t: NumberFormatException => "Parameter not number"
case t: CustomException => "Custom exception"
case t: SQLException => "Database error"
case _ => "Unknown error"
}
}
def getUserFromDb(id: Int) = "mock user name"
case class CustomException() extends Exception("custom exception")
涉及三个操作:检查请求参数,检查id是否有效以及获取数据。我们将把这些操作包装在Future中,并在“for comprehension”结构中协调执行。
第一步是将请求与服务匹配。
第一个furture 未来f1包装参数检查。我们特别想从get请求中检索id并将其转换为int。(如果返回值是方法中的最后一行,Scala不需要显式返回。)如您所见,此操作可能会抛出异常,因为id可能不是int或甚至不可用,但现在可以。
我们通过使用我们自己的CustomException显式调用Future.failed来阻止任何低于100的id。否则,我们以Future.unit的形式传递一个空的Future作为成功验证。
由于这只是一个示例,我们并没有真正连接到数据库。我们只返回一些模拟字符串。
在这里,我们可以将其类型与合适的恢复策略相匹配。回顾一下我们的代码,我们已经预料到了几个潜在的失败,例如缺少id,或者id不是int或者无效会导致特定异常。我们通过向客户端传递错误消息来处理handleException中的每一个。
这种安排不仅提供从开始到结束的异步流程,还提供处理错误的干净方法。由于它是跨处理程序的简化,我们可以专注于重要的事情,如数据库查询。
Verticles,Event Bus和其他陷阱
Vert.x还提供了一个名为verticle的并发模型,类似于Actor系统。Verticle隔离其状态和行为以提供线程安全的环境。与之通信的唯一方法是通过事件总线。
但是,Vert.x事件总线要求其消息为String或JSON。
这使得传递任意非POJO对象变得困难。在高性能系统中,处理JSON转换是不可取的,因为它会带来一些计算成本。如果您正在开发IO应用程序,最好不要使用Verticle或事件总线,因为这样的应用程序几乎不需要本地状态。