如何在Vert.x 4.4.1中基于Vert.x Web HTTP服务器实现线程每请求模型？

问题描述 #

我尝试用Vert.x Web实现HTTP服务器的线程每请求设计，运行第一段代码时，必须等response.end()调用后才能处理更多请求：

final var server = vertx.createHttpServer(serverOptions).requestHandler(req -> {
            // workerPool是一个包含10个线程的线程池
            workerPool.execute(() -> {
              var response = req.response();
              longRunningTask();
              response.end("Done.");
            });
    });

修改代码后确认问题出在response.end()的执行时机：

final var server = vertx.createHttpServer(serverOptions).requestHandler(req -> {
                // workerPool是一个包含10个线程的线程池
                var response = req.response();
                workerPool.execute(() -> {
                  longRunningTask();
                });
                response.end("Done.");
        });

但这并非真正的线程每请求模式——只是把longRunningTask()卸载到后台线程，请求处理在主线程快速完成，线程没有被绑定到请求的全生命周期。

我还尝试了以下方法，结果都不符合预期：

• Vertx#executeBlocking()
• 将workerPoolSize设置为5
• 将eventLoopPoolSize设置为5

当前环境是Java 17 + Vert.x Web 4.4.1，该版本不支持虚拟线程，也无法修改Vert.x原生线程模型，需要可行的解决办法。

解决方案 #

核心思路 #

Vert.x的EventLoop是异步非阻塞模型，要实现线程每请求，需将**整个请求处理链路（含响应生成逻辑）**绑定到Worker线程，直到请求处理完成再释放线程，同时避免阻塞EventLoop线程。

方案1：用Worker Verticle绑定请求生命周期 #

把请求处理逻辑拆分到Worker Verticle中，利用Worker线程池的隔离性，让每个请求占用一个Worker线程直到处理完成。

代码实现

1. 编写请求转发Verticle（运行在EventLoop线程，负责接收请求并转发）：

public class RequestEntryVerticle extends AbstractVerticle {
    @Override
    public void start() {
        vertx.createHttpServer(serverOptions)
            .requestHandler(req -> {
                // 将请求委托给Worker Verticle处理
                vertx.eventBus().request("handle-request", req, ar -> {
                    if (ar.succeeded()) {
                        String result = (String) ar.result().body();
                        req.response().end(result);
                    } else {
                        req.response().setStatusCode(500).end("Process failed");
                    }
                });
            })
            .listen(8080);
    }
}

2. 编写Worker处理Verticle（运行在Worker线程，负责完整请求逻辑）：

public class RequestWorkerVerticle extends AbstractVerticle {
    @Override
    public void start() {
        vertx.eventBus().consumer("handle-request", message -> {
            HttpServerRequest req = (HttpServerRequest) message.body();
            // 完整执行阻塞任务与业务逻辑
            longRunningTask();
            // 处理完成后返回结果
            message.reply("Done.");
        });
    }
}

3. 部署Verticle时配置Worker线程池：

WorkerOptions workerOpts = new WorkerOptions()
    .setWorkerPoolSize(10) // 自定义线程池大小，匹配需求
    .setWorker(true);

// 部署Worker Verticle
vertx.deployVerticle(new RequestWorkerVerticle(), new DeploymentOptions().setWorkerOptions(workerOpts));
// 部署入口Verticle
vertx.deployVerticle(new RequestEntryVerticle());

关键说明

• Worker线程池中的每个线程会绑定一个请求的全生命周期，直到message.reply()完成才释放，符合线程每请求的设计。
• 不要直接在Worker线程操作HttpServerResponse，Vert.x响应对象绑定EventLoop线程，通过EventBus传递结果再发送响应，避免线程安全问题。

方案2：使用executeBlocking并配置并行执行 #

如果不想拆分Verticle，可直接用executeBlocking，将完整请求逻辑放入阻塞执行块，同时关闭有序执行，让Worker线程并行处理请求。

代码实现

final var server = vertx.createHttpServer(serverOptions).requestHandler(req -> {
    // ordered=false：允许Worker线程并行处理多个请求
    vertx.executeBlocking(promise -> {
        // 完整执行请求处理逻辑
        longRunningTask();
        promise.complete("Done.");
    }, false, ar -> {
        if (ar.succeeded()) {
            req.response().end(ar.result());
        } else {
            req.response().setStatusCode(500).end("Error");
        }
    });
});

关键说明

• ordered=false会让Worker线程池并行处理多个executeBlocking任务，每个任务对应一个请求，直到任务完成才释放线程，实现线程每请求的效果。
• 此方式无需拆分Verticle，适合简单场景，核心是确保所有阻塞逻辑都在executeBlocking块内执行。

内容的提问来源于stack exchange，提问作者kshep92