java - Vert.x - 当客户端断开连接时停止分块响应

Question

我正在使用 vertx 和 vertx-web。我有一个简单的端点，它通过每秒无休止地打印一次“hello”来生成分块响应。

如何检测客户端何时断开连接？当尝试写入断开连接的客户端时，Vertx 似乎不会抛出异常，并且在客户端消失后很长时间内，routingContext.response().close() 仍然返回 false。

这是一个最小的示例，我使用curl作为客户端:

public static void main(String[] args) {
    Vertx vertx = Vertx.vertx();
    HttpServer server = vertx.createHttpServer();
    Router router = Router.router(vertx);
    router.route("/hello").handler(rc -> {
        rc.response().setChunked(true).putHeader("Content-Type", "text/plain");
        vertx.setPeriodic(1000, l -> {
            if (rc.response().closed()) {
                System.out.println("Stopping"); //Doesn't happen
                vertx.cancelTimer(l);
            }
            try {
                System.out.println("hello"); // Keeps printing long after the client disconnects
                rc.response().write("hello\n");
            } catch (Exception e) {
                e.printStackTrace(); // Doesn't happen
                rc.response().close();
            }
        });

    });
    server.requestHandler(router::accept).listen(8080);
}

Answer 1

这是等待 Vert.x 3.5.1 的解决方案。我希望这对你有帮助:)

router.route("/hello").handler(rc -> {
    rc.response().setChunked(true).putHeader("Content-Type", "text/plain");
    final long timer = vertx.setPeriodic(1000, l -> {
        try {
            System.out.println("hello");
            rc.response().write("hello\n");
        } catch (Exception e) {
            e.printStackTrace();
            rc.response().close();
        }
    });

    // Handle close event to cancel the timer
    rc.response().closeHandler(evt -> {
        System.out.println("Stopping");
        vertx.cancelTimer(timer);
    });
});