将响应处理程序与 VertX 中的请求匹配

Question

假设我在 1..n 个 VertX (V) 实例前面有一个负载均衡器 (LB)，每个 VertX 实例都连接到一个队列 (Q)，并且我有 1..m 个后端 (BE)。

用户单击一个按钮，该按钮发出一个发布请求，甚至打开一个 Web 套接字，负载均衡器将请求转发到其中一个 VertX 实例，该实例向队列触发一个请求，其中一个后端使用该消息并发回响应；如果正确的 VertX 实例使用它，它可以查找响应处理程序并向用户写入响应，如果错误的 VertX 实例使用它，则不会有响应处理程序来写入响应，用户将无限期等待回复。

看这个草图：

或者，V2 死机并且负载平衡器将用户重新连接到 V1，这意味着即使我可以将其发送回发出请求的完全相同的用户，但不能保证在响应返回后仍然存在，但是用户可能仍在等待来自另一个 VertX 实例的响应。

我目前正在做的是为每个新连接生成一个 GUID，然后一旦 websocket 连接，将 websocket 处理程序存储在针对 GUID 的 hashmap 中，然后当 BE 想要响应时，它会进行扇出对于所有 1..n VertX 实例，当前在其哈希图中具有正确 GUID 的实例可以向用户写入响应。 以这种方式处理 POST / GET 也是如此。

伪代码：

queue.handler { q ->

  q.handler {
    val handler = someMap.get(q.guid)
    // only respond if handler exists
    if (handler != null){
        handler.writeResponse(someresponsemessagehere)
    }
  }

}

vertx.createHttpServer().websocketHandler { ws ->
  val guid = generateGUID()
  someMap.put(guid, ws)                                                                    
  ws.writeFinalTextFrame("guid=${guid}")
  ws.handler { 
    val guid = extractGuid(it)
    // send request to BE including generated GUID
    sendMessageToBE(guid, "blahblah")
  }

}.requestHandler { router.accept(it) }.listen(port)

但这确实意味着，如果我有 1000 个 VertX 应用程序正在运行，那么后端需要将其消息扇出到 1000 个前端实例，其中只有一个会使用该消息。

VertX 似乎已经很好地处理了异步操作，VertX 中有没有一种方法可以识别每个 websocket 连接，而不必维护映射到 websocket 处理程序/post 处理程序的 GUID 映射？

另外，参考图片，有没有办法让 V3 消费消息，但仍然能够向当前连接到 V2 的 websocket 处理程序写回响应？

Answer 1

您的图表中缺少的是 Vertx EventBus。

基本上你可以假设你的 V1...Vn 是相互关联的：

V1<->V2<->...<->Vn

假设 Va 收到您的出站 Q 消息（红线），该消息是针对 Vb 的。
然后它应该使用 EventBus 将其发送到 Vb：

eventBus.send("Vb UUID", "Message for Vb, also containing WebSocket UUID", ar -> {
  if (ar.succeeded()) {
    // All went well
  }
  else {
    // Vb died or has other problems. Your choice how to handle this
  }
});