如何异步编写http REST服务

Question

在vert. x中编写异步请求处理程序的推荐方法是什么？

在此服务中，请求处理通常涉及调用DB、调用外部服务等。但是，我不想阻止请求处理线程。使用vet实现这一目标的推荐方法是什么。十、在一个典型的异步处理链中，我将使用请求处理线程向带有请求对象的消息总线发出消息。另一个处理程序将选择此消息并进行一些处理，例如检查请求参数。然后，这个处理程序可以向总线发出一条新消息，下一个处理程序将执行远程调用，该消息可以被接收。此处理程序将发出一条新消息，其中包含调用的结果，下一个处理程序将执行错误检查等。下一个处理程序将负责创建响应并将其发送给客户端。

如何使用vert创建类似的管道。十、

Answer 1

包括HttpServer请求处理程序在内的一切都是异步的，不是吗？

var server = vertx.createHttpServer(HttpServerOptions())
server.requestHandler { req ->
    req.setExpectMultipart(true) // for handling forms
    var totalBuffer = Buffer.buffer()
    req.handler { buff -> b.appendBuffer(buff) }
        .endHandler { // the body has now been fully read
            var formAttributes = request.formAttributes()
            req.response().putHeader("Content-type","text/html");
            req.response().end("Hello HTTP!");
        }
    // the above is so common that Vertx provides: bodyHandler{totalbuff->..}
}.listen(8080, "127.0.0.1", { res -> if(res.succeeded()) ... });

您只需（结束）写入req。response（），位于管道的最终处理程序上。

对于更类似流的实现（即，不是基于回调的），您可以使用Vert. x Rx/ReactiveStreams API。例如，您可以使用Vert. x Web Client发出请求，可能使用其Rx化API。