Akka HTTP:如何让流Http().superPool()在遇到错误的网址时不抛出异常？

在Akka HTTP中，可以通过使用recover操作符来处理遇到错误的网址时不抛出异常。recover操作符可以捕获并处理流中的错误，然后返回一个新的流。

下面是一个示例代码，展示了如何使用recover操作符来处理错误的网址：

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._

implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()
implicit val executionContext = system.dispatcher

val urls = List("https://example.com", "https://invalid-url", "https://example.org")

val requestFlow = Flow[String].map(url => (HttpRequest(uri = url), url))
val responseFlow = Flow[(Try[HttpResponse], String)].map {
  case (Success(response), url) =>
    // 处理成功的响应
    response.discardEntityBytes()
    s"Request to $url succeeded"
  case (Failure(ex), url) =>
    // 处理失败的响应
    s"Request to $url failed: ${ex.getMessage}"
}

val resultFuture = Source(urls)
  .via(requestFlow)
  .mapAsync(4) { case (request, _) => Http().superPool().singleRequest(request) }
  .zip(Source(urls))
  .via(responseFlow)
  .runWith(Sink.foreach(println))

resultFuture.onComplete(_ => system.terminate())

在上述代码中，我们首先定义了一个包含多个网址的列表urls。然后，我们创建了一个流requestFlow，用于将网址转换为HTTP请求。接下来，我们创建了一个流responseFlow，用于处理HTTP响应。在responseFlow中，我们使用recover操作符来处理失败的响应，并返回相应的错误信息。

最后，我们使用Source和Sink来组合整个流，并通过runWith方法运行流。运行结果会通过println打印出来。

这样，当遇到错误的网址时，流不会抛出异常，而是会输出相应的错误信息。

关于Akka HTTP的更多信息和使用方法，可以参考腾讯云的相关产品和文档：