http 服务器是否在verticle 上运行并拥有自己的事件循环?

问题描述

我正在尝试了解 https://vertx.io/ Verticle 系统和事件循环线程。

考虑以下代码

public class MyVerticle extends AbstractVerticle {
  public void start() {
    vertx.createHttpServer().requestHandler(req -> {
      req.response()
        .putHeader("content-type","text/plain")
        .end("Hello from Vert.x!");
    }).listen(8080);
  }
}

上面的代码将创建一个新的 Verticle(MyVerticle),它也拥有事件循环线程。

当使用 HTTP server 创建 vertx.createHttpServer() 时,它是否会为 HTTP server 传播一个新的Verticle?如果正确,HTTP server 会在带有事件循环线程的自己的 Verticle 上运行,并且有两个 Verticle 处于活动状态。

执行 MyVerticle 事件循环线程:

requestHandler(req -> {
      req.response()
        .putHeader("content-type","text/plain")
        .end("Hello from Vert.x!");
    }

执行注册的请求处理程序?如果是,当请求传入时,MyVerticle 如何从 Http server 接收事件以运行处理程序?

上面的代码没有说清楚,两个verticle之间是怎么通信的。如果有人能澄清一下就好了。

更新

我试图描绘场景:

enter image description here

假设,我部署了同一个 Verticle 的两个实例,那么每个 Verticle 都有自己的事件循环,并且 HTTP 服务器将启动两次。

用户发送第一个请求时,它会在Verticle 1 上处理第二个请求,然后在Verticle 2 上处理。当我的假设正确时,事件循环线程彼此独立。对我来说,这意味着它不再是单线程了。

例如:

public class MyVerticle extends AbstractVerticle {
  
  final int state;

  public void start() {
    vertx.createHttpServer().requestHandler(req -> {
      state = state + 1;
      req.response()
        .putHeader("content-type","text/plain")
        .end("Hello from Vert.x!");
    }).listen(8080);
  }
}

当我改变状态时,我必须在Verticles之间进行同步?

我很确定我错了,这意味着我还没有理解垂直的概念。

解决方法

verticle 是与事件循环相关联的部署单元。在您的示例中,verticle 控制 HTTP 服务器(使用 listenclose 方法)。 HTTP 服务器将使用控制它的 Verticle 的事件循环。

当您部署同一个 Verticle 的两个实例时(将部署选项设置为两个),每个 Verticle 将有自己的事件循环,并且 HTTP 服务器将启动两次。绑定 HTTP 服务器的第一个 Verticle 触发服务器绑定操作,第二个 Verticle 将在第一个 Verticle 启动的实际服务器上注册其请求处理程序(因为它们使用相同的端口)。当服务器接受新连接时,它将在它知道的两个 Verticle 实例上对连接进行负载平衡。文档 https://vertx.io/docs/vertx-core/java/#_server_sharing 的这一部分对此进行了说明。

verticle 的推荐通信方式是事件总线。它提供了一个轻量级、快速和异步的消息在顶点之间传递。根据用例,共享数据结构也可能是合适的。