为什么akka http不会继续请求？

我有一个问题与AKK-HTTP。我试图在一个流程中多次请求，但是它以4次的默认配置停止。这是我使用的代码。有人能帮我理解为什么它在等待吗？为什么akka http不会继续请求？

非常感谢

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() 
    } 
}

来源

2015-09-09 Bounkong KHAMPHOUSONE

您需要阅读响应主体，即使用'r.entity.dataBytes'做某些事情。否则，连接不能重新使用。 – jrudolph

谢谢jrudolph，它的工作原理。读取实体后，流程继续并释放连接。 –

酷，很高兴它的作品！ :) – jrudolph

为了释放连接，身体已经被读取。这可以通过

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

来源

2015-10-31 14:09:28

为什么akka http不会继续请求？

回答

相关问题