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

Question

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

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

看这张草图：

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)

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

另外，参照图片，V3是否有一种方法可以使用消息，但仍然能够将响应写回当前连接到V2的websocket处理程序？

Answer 1

图中缺少的是Vertx EventBus。

基本上你可以假设你的V1...VN是互连的：

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

让我们假设Va接收到针对Vb的出站Q消息（红线）。
然后它应该使用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
  }
});