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来平衡通过多个单独的连接池的请求。