如何生成完成工作后将未部署的顶点

Question

我目前正在开发我的第一个vert.x服务，我对我的部署是如何实现的并不十分有信心。

我有几个垂直点来接受来自其他服务的请求，并将大量工作委托给其他垂直点。我如何可以旋转每个任务的垂直线并在工作完成后将其杀死，或者通过编程方式将垂直线按任务数量放大。

我目前正在启动时生成十个顶点，并使用事件总线将这些任务分布在顶点上。

class MainVerticle : CoroutineVerticle() {

  private val databaseConfig by lazy { config.getJsonObject("migration") }

  override suspend fun start() {
    vertx.deployVerticle(AdministrationVerticle::class.java, DeploymentOptions().setConfig(config))
    vertx.deployVerticle(UpdateVerticle::class.java, DeploymentOptions().setConfig(config))
  }
}

private suspend fun handleRolloutRequest(ctx: RoutingContext) {
  val version = ctx.request().getParam("version")?.toInt() ?: findLatestVersion()
  val systems = findOutdatedSystems(version)

  for (system in systems) {
    vertx.eventBus().send("rollout", system.id, options)
  }

  ctx.response().end()
}

override suspend fun start() {
  client.connectAwait(mqttServerConfig.getInteger("port"), mqttServerConfig.getString("hostname"))

  vertx.eventBus().consumer<String>("rollout") {
    launch(vertx.dispatcher()) {
      // actual rollout
    }
  }
}

Answer 1

deployVerticle将回调作为最后一个参数。此回调的结果是部署ID：

vertx.deployVerticle("your.class", res -> {
    if (res.succeeded()) {
        String deploymentID = res.result();
        ...
    }
}

从理论上讲，您可以使用它在您的垂直设备完成任务后取消部署它们。

实际上，我会保持它们的数量不变，并在容器级别上进行扩展。