Vert.x HTTP服务器

时间:2020-01-09 10:47:11  来源:igfitidea点击:

Vert.x使创建HTTP服务器变得容易,因此应用程序可以接收HTTP请求。我们可以根据需要创建一个或者多个HTTP服务器。在本教程中,我将研究如何从垂直内部创建HTTP服务器以及如何处理请求。

创建一个HTTP服务器

使用Vertx实例方法createHttpServer()创建HTTP服务器。这是在Vert.x中创建HTTP服务器的示例:

HttpServer httpServer = vertx.createHttpServer();

通常是从一个Verticle内启动一个HTTP服务器。这样,在HTTP服务器上注册的所有处理程序将由启动verticle的同一线程执行。

import io.vertx.core.AbstractVerticle;
import io.vertx.core.http.HttpServer;

public class VertxHttpServerVerticle extends AbstractVerticle {

    private HttpServer httpServer = null;

    @Override
    public void start() throws Exception {
        httpServer = vertx.createHttpServer();

    }
}

启动HTTP服务器

一旦创建了HTTP服务器,就可以使用它的listen()方法启动它。这是启动HTTP服务器的外观:

public class VertxHttpServerVerticle extends AbstractVerticle {

    private HttpServer httpServer = null;

    @Override
    public void start() throws Exception {
        httpServer = vertx.createHttpServer();

        httpServer.listen(9999);
    }
}

HttpServer类也具有listen()方法的更多版本,它为启动HTTP服务器提供了不同的选择。

在HTTP服务器上设置请求处理程序

为了处理传入的HTTP请求,我们必须在HTTP服务器上设置一个请求处理程序。通常,这是在启动服务器之前完成的。这是一个Vert.x HTTP服务器请求处理程序示例:

public class VertxHttpServerVerticle extends AbstractVerticle {

    private HttpServer httpServer = null;

    @Override
    public void start() throws Exception {
        httpServer = vertx.createHttpServer();

        httpServer.requestHandler(new Handler<HttpServerRequest>() {
            @Override
            public void handle(HttpServerRequest request) {
                System.out.println("incoming request!");
            }
        });

        httpServer.listen(9999);
    }
}

每当HTTP请求到达HTTP服务器时,都会调用Handler对象的handle方法。在handle()方法内部,我们可以执行处理HTTP请求所需的代码。

请求标头和参数

我们可以从作为参数传递给handle()方法的HttpServerRequest对象访问HTTP标头和参数。这是一个示例,显示了如何访问HTTP请求的一些属性:

httpServer.requestHandler(new Handler<HttpServerRequest>() {
    @Override
    public void handle(HttpServerRequest request) {
        System.out.println("incoming request!");

        request.uri();
        request.path();
        request.getParam("p1");
    }
});

处理POST请求

如果HTTP请求是HTTP POST请求,则需要以不同的方式处理它。我们需要将主体处理程序添加到HTTP请求。每当来自请求主体的数据到达时,就会调用主体处理程序。看起来是这样的:

httpServer.requestHandler(new Handler<HttpServerRequest>() {
    @Override
    public void handle(HttpServerRequest request) {
        System.out.println("incoming request!");

        if(request.method() == HttpMethod.POST){
            request.handler(new Handler<Buffer>() {
                @Override
                public void handle(Buffer buffer) {
                        
                }
            });
        }
    }
});

如果我们要等到完整的HTTP POST正文到达时,可以添加一个结束处理程序。在接收到完整的HTTP POST主体之前,不会调用结束处理程序。但是,结束处理程序无法直接访问完整的HTTP POST主体。我们需要在请求处理程序中收集它。这是一个Vert.x HTTP请求结束处理程序示例,该示例执行所有操作:

httpServer.requestHandler(new Handler<HttpServerRequest>() {

    @Override
    public void handle(HttpServerRequest request) {
        System.out.println("incoming request!");

        Buffer fullRequestBody = Buffer.buffer();
        if(request.method() == HttpMethod.POST){

            request.handler(new Handler<Buffer>() {
                @Override
                public void handle(Buffer buffer) {
                    fullRequestBody.appendBuffer(buffer);
                }
            }

            request.endHandler(new Handler<Buffer>() {
                @Override
                public void handle(Buffer buffer) {
                    // here you can access the 
                    // fullRequestBody Buffer instance.
                }
            });
        }
    }
});

传回HTTP回应

我们当然可以为传入的HTTP请求发回HTTP响应。为此,我们需要从请求对象获取HttpServerResponse实例。这是获取HttpServerResponse对象的方式:

HttpServerResponse response = request.response();

获得HttpServerResponse实例后,我们可以设置HTTP响应状态代码和标头,如下所示:

response.setStatusCode(200);
response.headers()
    .add("Content-Length", String.valueOf(57))
    .add("Content-Type", "text/html")
;

回写头之后,我们可以通过write()方法回写响应主体,如下所示:

response.write("<!DOCTYPE html>Vert.x is alive!");
response.end();

我们可以多次调用write(),以将更多数据添加到响应正文中。在以Vert.xBuffer实例为参数的版本中也存在write()方法。此方法会将Buffer的内容写入HTTP响应。

write()方法是异步的,在将字符串或者缓冲区排队后立即返回。

一旦完成了HTTP响应主体的编写,就应该结束HTTP响应。如上例所示,这是通过调用end()方法来完成的。我们还可以编写HTTP响应正文,并在单个方法调用中结束响应,如下所示:

response.end("<!DOCTYPE html>Vert.x is alive!");

end()方法可以采用String或者Buffer作为参数。该参数将被写入响应主体,然后响应结束。

关闭HTTP服务器

要关闭HTTP服务器,我们只需调用它的close()方法,如下所示:

httpServer.close();

close()方法异步执行,因此,在close()方法返回时,HTTP服务器可能尚未完全关闭。我们可以将close处理函数作为参数传递给close()方法,以便在HTTP服务器完全关闭时得到通知。