Akka Http Client +ロードバランサ

Question

akka httpを使用してロードバランサを起動する正しい方法は何ですか？現在、私は、コードのフォローピースを使用しています：私は前に接続を開くので

val poolClientFlow = Http().cachedHostConnectionPool[String](host, port) 

source 
    .map(url => HttpRequest(uri = url) -> url) 
    .via(poolClientFlow) 
    .to(Sink.actorRef(myActor, IsDone)) 
    .run() 

、ロードバランサは、私が同じマシンに送りたい理解し、そのラウンドロビンが正しく動作しません。 poolClientFlowを.viaに移動する必要がありますが、毎回開閉しますか？

Answer 1

私は数週間前実験として1を書いた：

https://github.com/agemooij/stream-experiments/blob/master/src/main/scala/scalapenos/experiments/streams/LoadBalancingHttpClient.scala

をそれは別の接続プールの数を超える要求のバランスをとるために、グラフのDSLを使用しています。