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

zer*_*ing 2 java vert.x vertx-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);
  }
}
Run Code Online (Sandbox Code Playgroud)

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

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

事件循环线程是否MyVerticle

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

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

上面的代码并不清楚两个verticle如何相互通信。如果有人能澄清它那就太好了。

更新

我试图描述这个场景:

在此输入图像描述

假设我部署了同一个 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);
  }
}
Run Code Online (Sandbox Code Playgroud)

当我改变状态时,我必须在Verticles?

我很确定我错了,这意味着我还不理解 verticle 的概念。

小智 5

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

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

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