【发布时间】:2021-04-06 19:13:29
【问题描述】:
我正在尝试了解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),它也拥有事件循环线程。
当使用vertx.createHttpServer() 创建HTTP server 时,它是否会为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 的事件以在请求进来时运行处理程序?
上面的代码不清楚,两个verticles是如何相互通信的。如果有人能澄清一下就好了。
更新
我正在尝试描绘场景:
假设我部署了同一个verticle的两个实例,那么每个verticle都有自己的event-loop,并且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的概念。
【问题讨论】:
标签: java vert.x vertx-verticle