VERTX运行多个事件循环

Question

我有一个需要垂直扩展的情况，因此我最终使用了20核和5GB的虚拟机。

问题是，当我制作大量数据时，我看不到CPU不仅使用一个核心。我期望的是，在并行中看到20核。

我尝试使用100线程的工作者创建Vertx。

VertxOptions options = new VertxOptions().setWorkerPoolSize(100);
this.asyncFlowVertx = Vertx.vertx(options);

但是，我的服务仍然没有使用所有内核。

我还能配置什么以允许服务器并行运行更多请求？

拥有此代码如何在没有bindaddress例外的情况下部署多个垂直，

@Override
public void start(Promise<Void> startPromise) {
    logger.info("Preparing Async Flow Http proxy server....");
    Router router = Router.router(asyncFlowVertx);
    router.route().handler(BodyHandler.create());
    router.route(GET, "/ready").respond(ctx -> Future.succeededFuture());
    router.route(GET, "/health").respond(ctx -> Future.succeededFuture());
    router.route(POST, "/request").respond(this::processRequest);
    router.route(POST, "/response").respond(this::processResponse);

    server = asyncFlowVertx.createHttpServer();
    server.requestHandler(router).listen(port, http -> {
        if (http.succeeded()) {
            logger.info("Async-flow-http-proxy running......");
            startPromise.complete();
        } else {
            startPromise.fail(http.cause());
        }
    });
}

如果我尝试

DeploymentOptions options = new DeploymentOptions().setInstances(20);
vertx.deployVerticle("com.bla.MyVerticle", options);

获得绑定地址异常

解决方案

我设法部署了多个垂直，但是即使部署20，我只能在日志中看到两个事件。循环线程

var vertx = Vertx.vertx();
Router router = Router.router(vertx);
IntStream.range(0,20).forEach(i -> {
    logger.info("Creating Vertx Verticle {}", i);
    vertx.deployVerticle(new AsyncFlowHttpProxy(router));
});

我的垂直需要构造函数中的一些依赖项，如果我尝试创建这样的多个垂直，

VertxOptions options = new VertxOptions();
    options.setWorkerPoolSize(100);
    var vertx = Vertx.vertx(options);
    Router router = Router.router(vertx);
    DeploymentOptions deploymentOptions = new DeploymentOptions().setInstances(20);
    vertx.deployVerticle(new AsyncFlowHttpProxy(port, nextServicePort, nextServiceName, router), deploymentOptions);

我会发现这个错误，

java.lang.IllegalArgumentException: Can't specify > 1 instances for already created verticle

任何想法为什么？

问候

Answer 1

垂直默认值的实例是让事件循环池，其螺纹数= 2 *机器上的内核数。为了参数的缘故，让我们假设有x物理内核具有超线程；这意味着有2x虚拟内核。

这并不意味着垂直的一个实例将立即创建最大数量的线程数，该线程将相应地利用所有虚拟内核，而这些虚拟内核会导致所有x物理内核。这是由操作系统管理的。这将更接近多线程行为，而不是诸如Vert.x之类的框架的反应性事件驱动的行为。

在Vert.x中，实际创建的线程数是由框架动态管理的。 在这里 是一个很好的分析。遵守Vert.x的设计原理，例如编写非阻滞代码，利用工作池将是优化性能的方法。专门用于数量的实例，我找到了 this 这表明从一个实例开始物理核心并扩展到测试。

这是我用来测试您的示例的完整代码，在该示例中，我能够通过多个实例部署垂直。

public class TestVerticle extends AbstractVerticle {

    private static final Logger LOGGER = LoggerFactory.getLogger(TestVerticle.class);

    private static Vertx vertx;

    public static void main(String[] args) {
        VertxOptions options = new VertxOptions().setWorkerPoolSize(100);
        DeploymentOptions deploymentOptions = new DeploymentOptions().setInstances(20);
        vertx = Vertx.vertx(options);
        vertx.deployVerticle(TestVerticle.class, deploymentOptions);
    }

    @Override
    public void start(Promise<Void> startPromise) {
        LOGGER.info("Preparing Async Flow Http proxy server....");
        Router router = Router.router(vertx);
        router.route().handler(BodyHandler.create());
        router.route(GET, "/ready").respond(ctx -> Future.succeededFuture());
        router.route(GET, "/health").respond(ctx -> Future.succeededFuture());
        router.route(GET, "/request").respond(ctx -> Future.succeededFuture(new JsonObject().put("hello", "world")));

        HttpServer server = vertx.createHttpServer();
        server.requestHandler(router).listen(8080, http -> {
            if (http.succeeded()) {
                LOGGER.info("Async-flow-http-proxy running......");
                startPromise.complete();
            } else {
                startPromise.fail(http.cause());
            }
        });
    }
}