问题标签 [vertx-eventbus]

我想在 EventBus 频道上发布一条消息，并收到所有收听该频道的人的回复。问题是，如果我不知道预期有多少响应，我怎么知道每个人都已经响应了？

我假设我需要知道有多少消费者才能知道我是否已经收到所有回复。

有什么方法可以知道当前有多少消费者正在“收听”一个 Vert.x EventBus 地址？

我正在使用一个 vertx 服务器 v3.7.0 作为我的应用程序的网关。我有一个服务需要超过 2 分钟来处理数据（我几乎没有其他服务需要超过 2 分钟）。当我使用服务的端点直接调用该服务时，它工作正常。但是当我从 vertx 网关尝试类似的事情时，它会超时并给出504 Gateway Time-out。

我在 vertx 文档部分读到默认超时为 30 sec。（https://vertx.io/docs/vertx-core/java/#_sending_with_timeouts）。我们对 vertx 网关有相同的要求吗？我试图寻找类似的属性以放入 json 配置中，但找不到任何相关文档。

我们如何配置这个超时的值？

我是 VertX 的新手，我想使用“GET”方法阅读 pdf。我知道将使用缓冲区。但是互联网上没有关于如何做到这一点的资源。

当我们在 Verticle 中创建 HTTP 服务器时，是否意味着事件循环线程创建了这个服务器？如果不是，事件循环的工作是什么？谁创建了这个 HTTP 服务器？当我们创建一个顶点的多个实例时，事件循环会发生什么？

我有一个 vertx 应用程序，我在其中部署了 verticle A (HttpVerticle.java) 的多个实例和 verticle B (AerospikeVerticle.java) 的多个实例。Aerospike verticles 需要共享一个 AerospikeClient。HttpVerticle 监听端口 8888 并使用事件总线调用 AerospikeVerticle。我的问题是：

1. 使用 sharedData 是共享单例客户端实例的正确方法吗？还有其他推荐/更清洁的方法吗？我计划在应用程序中创建和共享更多这样的单例对象（cosmos db 客户端、meterRegistry 等）。我计划使用 sharedData.localMap 以类似的方式共享它们。
2. 是否可以使用 vertx 的事件循环作为 aerospike 客户端的支持事件循环？这样 aerospike 客户端初始化不需要创建自己的新事件循环？目前看起来 aerospike get 调用的 onRecord 部分在 aerospike 的事件循环上运行。

主.java

HttpVerticle.java

AerospikeVerticle.java

我在我的 openfaas 函数中使用 Vert.x，我想使用 vert.x 事件总线在它们之间进行通信，但我不确定如何在函数外部使用事件总线。它具有相同的功能。我没有找到任何有关此的文档或资源。目前我正在为 openfaas 函数使用 vertx java11 模板，但我也想为 ml 模型使用 python 版本，并希望使用事件总线在它们之间进行通信。在 openfaas 中可以吗？

我想做一个带有大厅系统的简单问答游戏。我对在我的系统中使用的架构有一些疑问，我的想法是使用中央服务器来管理大厅，每次创建大厅时，实例化一个新LobbyVerticle的，客户端和服务器之间的通信委托给事件Vert.x总线。游戏必须尊重可扩展性和分布。感谢您的建议。

假设我们创建了一个标准的verticle和一个worker verticle。现在我们将实例增加到 2 个。那么，当我们说 10 个用户一次请求之前发生了什么以及现在内部会发生什么？

根据文档和一些测试，我看到 Vert.x 以循环方式为 Vertical 实例排队消息，例如，如果我有 2 个“通知”工作者垂直实例并且有 10 条消息传入，

实例 #1 进程 - 消息 #1,3,5,7,9

实例 #2 进程 - 消息 #2,4,6,8,10

即使实例#1 更快地完成了所有消息的处理（由于某些决策流程），它仍然没有收到实例#2 的待处理消息。这似乎是默认的排队行为。

有没有办法在消息到达时将其更改为动态排队而不是简单的循环？