在scala-stream流中组合akka-http流的最佳方法是什么

Question

val stream1:Flow[T,String,NotUsed] = Flow[T].map(_.toString)

val stream2: Flow[String,Future[HttpRespone],NotUsed] = Flow[String].map(param => Http.singleRequest(HttpRequest(uri=s"host.com/$param")))

val stream3 = stream1 via stream2

这是最好的方法吗？你们会推荐哪种方法？为什么？在这个用例的范围内有几个最好的实践示例将是很棒的！

提前致谢：）

Answer 1

您的实现将为每个新参数创建一个到“host.com”的新连接。这是不必要的，并阻止akka进行某些优化。实际上，akka保留了一个连接池来重用开放的连接，但我认为最好在代码中指定您的意图，而不是依赖底层实现。

您可以按照文档中的描述建立单个连接：

val connectionFlow: Flow[HttpRequest, HttpResponse, _] = 
  Http().outgoingConnection("host.com")

要利用此连接流，您需要将字符串路径转换为httpRequest对象：

import akka.http.scaladsl.model.Uri
import akka.http.scaladsl.model.Uri.Path

def pathToRequest(path : String) = HttpRequest(uri=Uri.Empty.withPath(Path(path)))

val reqFlow = Flow[String] map pathToRequest

val stream3 = stream1 via reqFlow via connectionFlow