VertXでのリクエストに対応するレスポンスハンドラ

Question

ロードバランサ（LB）が1..n VertX（V）インスタンスの前にあり、各VertXインスタンスがキュー（Q）に接続されていて、1があるとします。 .mバックエンド（BE）。

ユーザーがポスト要求を行うボタンまたはWebソケットを開くボタンをクリックすると、ロードバランサは要求をキューに送信するVertXインスタンスの1つに要求を転送し、バックエンドの1つがメッセージを消費します応答を返送する。正しいVertXインスタンスがそれを消費すると、レスポンスハンドラをルックアップしてユーザーに応答を書き込むことができます。間違ったVertXインスタンスがそれを消費した場合、応答を書き込むレスポンスハンドラがなくなり、ユーザーは無期限に待機します応答。それはだ、

また

は、V2が死ぬと、ロードバランサは、私が要求を行ったとまったく同じものに戻ってそれを送ることができても、意味V1にユーザーを再接続：

このスケッチを参照してください。応答が返ってもまだそこにいることは保証されていませんが、ユーザーは別のVertXインスタンスを介して応答を待っている可能性があります。

私が現在行っていることは、新しい接続ごとにGUIDを生成し、websocketが接続するとすぐにGUIDに対してハッシュマップ内にwebsocketハンドラを格納し、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のフロントエンドインスタンスにそのメッセージをファンアウトする必要があることを、私が実行している1000のVERTXアプリケーションを持っている場合ことを意味しませんメッセージ。

VertXはすでに非同期操作を非常にうまく処理しているようですが、Vertexではwebsocketハンドラ/ポストハンドラにマップされたGUIDのマップを維持する代わりに、各WebSocket接続を識別する方法がありますか？

また、画像を参照すると、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 
    } 
});