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

lawou6xi  于 2021-06-27  发布在  Java
关注(0)|答案(1)|浏览(372)

我在努力理解https://vertx.io/ 垂直系统和事件循环线程。
考虑以下代码:

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 ? 如果正确,则 HTTP server 使用事件循环线程在自己的垂直体上运行,两个垂直体处于活动状态。
是吗 MyVerticle 事件循环线程:

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

执行已注册的请求处理程序?如果是,怎么做 MyVerticle 从接收事件 Http server 在请求传入时运行处理程序?
上面的代码不清楚,两个垂直轴如何相互通信。如果有人能澄清就好了。
更新
我试着描述这个场景:

假设我部署了同一个verticle的两个示例,那么每个verticle都有自己的事件循环,http服务器将启动两次。
当用户发送第一个请求时,它将在垂直1上处理第二个请求,在垂直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 ?
我很确定我错了,那意味着我还不了解垂直的概念。

hgqdbh6s

hgqdbh6s1#

verticle是与事件循环关联的部署单元。在您的示例中,verticle控制http服务器(使用 listen 以及 close 方法)。http服务器将使用控制它的verticle的事件循环。
当您部署同一个verticle的两个示例(将部署选项设置为2)时,每个verticle将有自己的事件循环,并且http服务器将启动两次。绑定http服务器的第一个verticle触发服务器绑定操作,而第二个verticle将在第一个verticle启动的实际服务器上注册其请求处理程序(因为它们使用相同的端口)。当服务器接受一个新连接时,它将在它知道的两个垂直示例上对连接进行负载平衡。本节将对此进行说明https://vertx.io/docs/vertx-core/java/#_server_sharing.
verticle推荐的通信方式是事件总线。它提供了一个轻量级的、快速的、异步的消息在垂直体之间传递。根据用例的不同,共享数据结构也可以是适当的。

相关问题