Vertx WebSocket：负载均衡

Question

我在一个系统上工作，我用网络套接字向服务器发送消息。为此，我使用具有多个顶点的vertx（没有Rx）Web套接字客户端，消息存储在内部队列中。我希望从消息队列中退出，并提交到具有最少负载的顶点。为了识别负载最少的顶点，我计划使用接收到的消息数量与发送的消息数量的比率。我知道vertx web套接字本质上是异步的。但是有没有规定使用任何提供的处理程序来解析指示消息已经到达服务器的响应。

Answer 1

您可以使用SharedData和常规处理程序的组合：

this.vertx.createHttpServer().websocketHandler(ws -> {
  ws.handler(data -> {
    this.vertx.sharedData().getCounter(this.deploymentID(), (c) -> {
      c.result().incrementAndGet((dummy) -> {});
    });
  });
});

这将在每次收到新的WebSocket请求时为特定的垂直点增加一个原子计数器。

现在，您可以使用vertx获取所有部署ID。deploymentIDs（）

剩下的就是迭代这些，收集计数器，然后得到最小的一个。