akka http 客户端跟随重定向
akka http client follow redirect
akka-http 文档提供了一个查询 http 服务的例子:
http://doc.akka.io/docs/akka-http/current/scala/http/client-side/request-level.html
如何让 akka-http 自动跟随重定向,而不是接收代码 == 302 的 HttpResponse?
akka 2.5.3,akka-http 10.0.9
import akka.actor.{ Actor, ActorLogging }
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.{ ActorMaterializer, ActorMaterializerSettings }
import akka.util.ByteString
class Myself extends Actor
with ActorLogging {
import akka.pattern.pipe
import context.dispatcher
final implicit val materializer: ActorMaterializer = ActorMaterializer(ActorMaterializerSettings(context.system))
val http = Http(context.system)
override def preStart() = {
http.singleRequest(HttpRequest(uri = "http://akka.io"))
.pipeTo(self)
}
def receive = {
case HttpResponse(StatusCodes.OK, headers, entity, _) =>
entity.dataBytes.runFold(ByteString(""))(_ ++ _).foreach { body =>
log.info("Got response, body: " + body.utf8String)
}
case resp @ HttpResponse(code, _, _, _) =>
log.info("Request failed, response code: " + code)
resp.discardEntityBytes()
}
}
您不能让 Akka-http 客户端自动执行此操作。这是 Akka 项目的未决问题:https://github.com/akka/akka-http/issues/195
您可以使用以下方式手动处理此问题:
case resp @ HttpResponse(StatusCodes.Redirection(_, _, _, _), headers, _, _) =>
//Extract Location from headers and retry request with another pipeTo
您可能希望对重定向的次数进行计数,以避免无限循环。
akka-http 文档提供了一个查询 http 服务的例子:
http://doc.akka.io/docs/akka-http/current/scala/http/client-side/request-level.html
如何让 akka-http 自动跟随重定向,而不是接收代码 == 302 的 HttpResponse?
akka 2.5.3,akka-http 10.0.9
import akka.actor.{ Actor, ActorLogging }
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.{ ActorMaterializer, ActorMaterializerSettings }
import akka.util.ByteString
class Myself extends Actor
with ActorLogging {
import akka.pattern.pipe
import context.dispatcher
final implicit val materializer: ActorMaterializer = ActorMaterializer(ActorMaterializerSettings(context.system))
val http = Http(context.system)
override def preStart() = {
http.singleRequest(HttpRequest(uri = "http://akka.io"))
.pipeTo(self)
}
def receive = {
case HttpResponse(StatusCodes.OK, headers, entity, _) =>
entity.dataBytes.runFold(ByteString(""))(_ ++ _).foreach { body =>
log.info("Got response, body: " + body.utf8String)
}
case resp @ HttpResponse(code, _, _, _) =>
log.info("Request failed, response code: " + code)
resp.discardEntityBytes()
}
}
您不能让 Akka-http 客户端自动执行此操作。这是 Akka 项目的未决问题:https://github.com/akka/akka-http/issues/195
您可以使用以下方式手动处理此问题:
case resp @ HttpResponse(StatusCodes.Redirection(_, _, _, _), headers, _, _) =>
//Extract Location from headers and retry request with another pipeTo
您可能希望对重定向的次数进行计数,以避免无限循环。