Vertx 网络服务器仅使用一个事件循环线程，而 16 个可用

Question

我使用 Vert.x v3.5.1。 有最简单的代码示例：

vertx.createHttpServer()
                    .requestHandler(anyRouter::accept)
                    .listen(8080);

在我的例子中，事件循环组的大小是 16，所以我希望我的请求会影响 16 个线程。服务器已成功启动，但它仅在一个线程中工作。 （我使用不同的 tcp-connections 发送请求，所以 keep-alive 不是这里的原因。）
HttpServerImpl 类包含 httpHandlerMgr，这个管理器处理一个事件循环池（命名为 availableWorkers）。在调试过程中，我看到这个池只包含 一个 工人。

使用 Verticle 模型并不能解决问题，仍然没有使用所有线程。

如果我在循环中多次创建服务器，它会有所帮助。结果，我有许多受影响的线程和一台共享服务器。但它看起来像解决方法。

问题是如何创建使用所有可用事件循环线程的 Web 服务器？

Verticle 下面的实现

因此，此实现使用了一半的可用线程（8 个线程）。但我希望它使用 16 :)

public static void main(String[] args) throws Exception {
        int eventLoopSize = 16;
        Vertx vertx = new VertxOptions().setEventLoopPoolSize(eventLoopSize);
       for (int i=0;i<eventLoopSize; i++) {
           vertx.deployVerticle(new MyServer(vertx), deploymentOptions);
       }
    }

public class MyServer implements Verticle {
final Vertx vertx;
public MyServer(Vertx vertx) {
   this.vertx = vertx;
}

@Override
void init(Vertx vertx, Context context) {
vertx.createHttpServer()
                    .requestHandler(anyRouter::accept)
                    .listen(8080);
}
}

Answer 1

涉及一个线程，这正是事件循环模型。我推荐观看Philip Roberts: What the heck is the event loop anyway? | JSConf EU 2014。示例适用于浏览器，但概念与 Vert.x 或 Node 等服务器端事件循环系统相同。

但是，使用 Vert.x，您通常会在 verticles 中组织代码（想想小型服务）。每个 Verticle 都分配了一个事件循环，但您可以部署多个实例。这就是您使用 CPU 的所有内核的方式。如果您是 Java 程序员并且第一次编写 Vert.x 应用程序，我建议您阅读此guide。

至于将您的 verticle 扩展到所有核心，问题是当您自己实例化 verticle 时，您实际上创建了单独的部署，并且无法保证使用不同的事件循环。

正如Specifying number of verticle instances 中所解释的，您必须使用verticle 名称：

使用 Verticle 名称部署 Verticle 时，您可以指定 您要部署的 Verticle 实例数：

DeploymentOptions options = new DeploymentOptions().setInstances(16);
vertx.deployVerticle("com.mycompany.MyOrderProcessorVerticle", options);

这对于跨多个内核轻松扩展很有用。例如 您可能需要部署一个 Web 服务器 Verticle 和多个核心 你的机器，所以你想部署多个实例来利用所有 核心。

Answer 2

据此：https://vertx.io/docs/vertx-core/java/#_reactor_and_multi_reactor

即使一个 Vertx 实例维护多个事件循环，任何特定的处理程序都不会同时执行，并且在大多数情况下（除了工作程序 Verticle）将始终使用完全相同的事件循环调用。

所以如果你想使用其他线程，你可以：

• 在单独的 pid 中使用多个 verticle 实例（例如，使用 systemd 服务的多值实例，或 docker 容器或任何允许您运行微服务的多个 java 进程并使监控和故障恢复更容易的东西)。

• 多次将您的 verticle 部署为 worker verticle：https://vertx.io/docs/vertx-core/java/#worker_verticles

• 使用executeBlocking 方法：https://vertx.io/docs/vertx-core/java/#blocking_code，但我不建议您使用它。

如果您的 Verticle 公开了一个 http restfull API，我建议您使用经典的 http 反向代理并管理容器内的多个实例，或者如果您不能或端口使用不同的主机。并通过事件总线（或其他基于消息队列的系统）将操作委托给其他 Verticle。这是design 的示例。

Answer 3

经过一些尝试和讨论后我了解到（感谢 tsegismont），处理池中所有线程的唯一正确方法是：

DeploymentOptions deploymentOptions = new DeploymentOptions()
        .setInstances(vertxOptions.getEventLoopPoolSize());

vertx.deployVerticle(() -> new MyServerVerticle(), deploymentOptions);

下面的实现有意外的行为：

for (int i=0;i<vertxOptions.getEventLoopPoolSize();++i) {
   vertx.deployVerticle(new MyServerVerticle());
}

class MyServerVerticle implements Verticle {
 @Override
public void init(Vertx vertx, Context context) {
    this.vertx=vertx;
}

 @Override
 public void start(Future<Void> startFuture) throws Exception {
vertx.createHttpServer()
            .requestHandler(anyRouter::accept)
            .listen(8080);
}
}

并且没有正确的方法来创建不使用具有多个事件循环的 Verticle 模型的 Web 服务器。在这种情况下，我们只能循环创建服务器，但我不确定它是否总是正确的：

class MyServerNotVerticle {
  public void start() {
   for (int i=0;i<vertxOptions.getEventLoopPoolSize();++i) {
       vertx.createHttpServer()
                .requestHandler(anyRouter::accept)
                .listen(8080);
    }
  }
}