java - 多线程 Vert.x 每秒处理数千个连接

Question

我正在构建一个像服务器一样的信使，我对 vert.x 做了一些这样的更改

vertx.deployVerticle(MainDeployment.class.getCanonicalName(),res -> {
          if (res.succeeded()) {

                Logger.Log("Deployed");

              } else {
                Logger.Log(res.cause().getMessage());
              }
            });

    server.requestHandler(router::accept).listen(port);


 public void createContext(String path,MyHttpHandler handler){
    //handlersMap.put(path.split("\\/")[1], handler);
    if(!path.endsWith("/")){
        path += "/";
    }

    path+="*";

    map.put(path, handler);
}

这是我的 MainDeployment 类

 public class MainDeployment extends AbstractVerticle{



  @Override
  public void start() throws Exception {

      //GUI.display("Sub Verticle Has Deployed");

    // Different ways of deploying verticles

    // Deploy a verticle and don't wait for it to start

   for(Entry<String, MyHttpHandler> entry : MyVertxServer.map.entrySet()){
       MyVertxServer.router.route(entry.getKey()).handler(new Handler<RoutingContext>() {

            @Override
            public void handle(RoutingContext ctx) {

                String[] handlerID = ctx.request().uri().split(ctx.currentRoute().getPath());

                String suffix = handlerID.length > 1 ? handlerID[1] : null;
                entry.getValue().Handle(ctx, new VertxUtils(), suffix);

            }
        });
   }

  }
}

文档说

 Vert.x guarantees that a particular verticle instance is never executed by more than one thread concurrently. This gives you a huge advantage as a developer, since you can program all your code as single threaded

由于每个verticle都有自己的线程并且是单线程的，所以如果我的verticle上传文件，它不能同时处理2个上传，还是我误解了NIO的概念？

Answer 1

我想您应该更深入地研究 Vert.x 文档，以更熟悉支持 API 和设计。

我强烈建议的官方文档如下:

Even though a Vertx instance maintains multiple event loops, any particular handler will never be executed concurrently, and in most cases (with the exception of worker verticles) will always be called using the exact same event loop.

您尝试实现的文件上传过程被视为阻塞操作，因此应该执行:

• 通过使用阻塞 API Vertx#executeBlocking
• 或者在可通过 Vertx#createSharedWorkerExecutor 调用获取的工作池内

这两种方式都会导致事件循环线程不会因阻塞操作而停止(我说的是事件循环线程但我们实际上讨论的是所有事件循环线程，因为它们可能不止一个)。