PlayからAkkaへのWebSocketの移動HTTP

Question

PlayアプリケーションにWebSocketサーバーがあり、これをakka-httpサービスに移動したいとします。私は現在、Acckaには存在しないPlayの一部であるActorFlow.actorRefを使用しています。

WebSocketが承認されると、私はRabbitMQキューに登録し、各メッセージをWebSocketに転送します。 WebSocketからメッセージを受け取ると、ローカルで処理し、他の人をRabbitMQ交換に転送します。

akka-httpを使用して同じことを行うにはどうすればよいですか？ Sink.actorRefを使用してシンクを作成し、そこにある受信メッセージを処理できますが、送信元はどうですか？

Source.actorRefでソースを作成できますが、マテリアライズされたときにメッセージを送信するアクターにどのようにアクセスできますか？私のRabbitMQサブスクリプションのforeachからメッセージを送信するために使用すべき種類のソースがありますか？

これを取得したら、Flow.fromSinkAndSourceを使用して必要なフローを返すことができるように見えます。

Answer 1

私はあなたの要件に言い換えます

あなたはローカル

1. プロセスにいくつかの要求を必要とし、RabbitMQのために、クライアント
フォワード
2. いくつかの要求に応答を送るのWebSocketエンドポイントを持っている
3. rabbitMQを購読し、rabbitMQからwebsocketクライアントにメッセージを転送します。

私の提案に必要な場合を除き、その回避の俳優で、俳優は強力ですが、私はそれがモデルにフィットする場合は、以下の

がどのようにパイプの源であり、俳優

せずに一緒にシンク読みやすくし、約理由ストリームを見つけます

def wshandler: Flow[Message, Message, _] = { 
    val rabbit = new Rabbit() 
    val src = 
     Source 
     .actorRef(100, OverflowStrategy.dropBuffer) 
     .mapMaterializedValue(ref => { 
      rabbit 
      .subscribe[String]("updates", queueName, topics) { 
       (body, topic) => 
       log.debug("Received from rabbit") 

       // here you forward everything from rabbitmq to  
       // client using materialized actorRef 
       ref ! TextMessage(body) 
      } 
     }) 

    // you need to implement your own pattern matching logic to differentiate between request to process 
    // locally and request to route to rabbitMQ 
    val sink = Sink.foreach[Message](m => m match { 
     case localReq => // your request response processing logic 

     case rabbitMq => // publish to rabbitMQ 
    }) 

    Flow.fromSinkAndSource(sink, src) 
    } 

このスニペットは、あなたが示した主旨のものを実装していないことが