0

我的服务中有一个 verticle，它接收 http 请求并使用 executeBlocking 与 MySQL db 对话。我正在使用命名工作池与数据库交互。现在，为了推送应用程序指标（使用阻塞的库），我想使用不同的命名工作池。因为我不希望数据库操作被指标中断，所以我想要一个单独的工作池。我可以使用事件总线并使用工作器顶点来推送指标，但由于这会产生转换到 JsonObject 的开销，我想从同一个顶点使用 executeBlocking 本身。

正如这里提到的https://groups.google.com/d/msg/vertx/eSf3AQagGGU/9m8RizIJeNQJ ，两种情况下使用的工作池是相同的。所以，制作一个新的工人 Verticle 真的会帮助我解耦用于数据库操作的线程和用于推送指标的线程。

任何人都可以帮助我做出更好的设计选择，或者如果我使用相同的 Verticle，我该如何使用不同的工作池？

4

1 回答 1

3

尝试以下代码（用 Kotlin 编写，但你明白了）：

val workerExecutor1 = vertx.createSharedWorkerExecutor("executor1", 4)
val workerExecutor2 = vertx.createSharedWorkerExecutor("executor2", 4)

workerExecutor1.executeBlocking(...)  // execute your db code here
workerExecutor2.executeBlocking(...)  // execute your metrics code here

不要忘记在不需要时关闭 workerExecutor：

workerExecutor1.close()
于 2018-11-29T08:29:54.410 回答