request - 为什么akka http不继续请求？

Question

我遇到了 akka-http 的问题。我试图在一个流程中多次请求，但它在 4 次时以默认配置停止。这是我使用的代码。有人可以帮我理解它为什么要等待吗？

非常感谢

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.Http.{HostConnectionPool, OutgoingConnection}
import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
import akka.stream._
import akka.stream.scaladsl._
import com.typesafe.scalalogging.LazyLogging

import scala.concurrent.Future
import scala.util.{Try, Failure, Success}

object TestHttp extends LazyLogging {

  def main(args: Array[String]) {
    implicit val system = ActorSystem()
    import system.dispatcher
    val decider: Supervision.Decider = {
      case e => {
        logger.error(e.getMessage, e)
        Supervision.Resume
      }
    }
    implicit val materializer = ActorMaterializer(ActorMaterializerSettings(system).withSupervisionStrategy(decider).withDebugLogging(true))
    val resultSink: Sink[(Try[HttpResponse], Int), Future[Unit]] = Sink.foreach { case (hr, i) => {
      hr match {
        case Success(r) => logger.info(s"Success ${r} for ${i}")
        case Failure(e) => logger.error(s"Error ${e} for ${i}")
      }
    }
    }
    val source: Source[Int, Unit] = Source(0 to 1500).map(i => {
      logger.info(s"${i} iteration")
      i
    })

    val buildHr: Flow[Int, (HttpRequest, Int), Unit] = Flow[Int].map { case s => {
      (HttpRequest(uri = "/").withDefaultHeaders(), s)
    }
    }

    val connection: Flow[(HttpRequest, Int), (Try[HttpResponse], Int), HostConnectionPool] = Http().cachedHostConnectionPool("www.adajam.uk.com")
    import FlowGraph.Implicits._
    source.via(buildHr).via(connection).to(resultSink).run()
  }
}

Answer 1

为了释放连接，必须读取正文。这可以通过

r.entity.dataBytes.to(Sink.ignore)