Akka Http客戶端+負載均衡器

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

我寫了一個在幾個星期前的一個實驗：

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

它採用圖形化的DSL來平衡通過多個單獨的連接池的請求。