Akka Http 客户端在 HttpRequest 上设置 Cookie

Question

我正在尝试使用 Akka Http Client 向 REST Web 服务发出 GET 请求。

在进行 GET 之前，我无法弄清楚如何在请求上设置 cookie。

我在网上搜索，我找到了在服务器端读取 cookie 的方法。但我找不到任何向我展示如何在客户端请求上设置 cookie 的内容。

根据我自己的研究，我尝试了以下方法在 http 请求上设置 cookie

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.stream.scaladsl.{Sink, Source}
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
import akka.http.scaladsl.model.headers.HttpCookie
import akka.stream.ActorMaterializer
import spray.json._

import scala.util.{Failure, Success}

case class Post(postId: Int, id: Int, name: String, email: String, body: String)

trait JsonSupport extends SprayJsonSupport with DefaultJsonProtocol {
   implicit val postFormat = jsonFormat5(Post.apply)
}

object AkkaHttpClient extends JsonSupport{
   def main(args: Array[String]) : Unit = {
      val cookie = headers.`Set-Cookie`(HttpCookie(name="foo", value="bar"))
      implicit val system = ActorSystem("my-Actor")
      implicit val actorMaterializer = ActorMaterializer()
      implicit val executionContext = system.dispatcher
      val mycookie = HttpCookie(name="foo", value="bar")
      val httpClient = Http().outgoingConnection(host = "jsonplaceholder.typicode.com")
      val request = HttpRequest(uri = Uri("/comments"), headers = List(cookie))
      val flow = Source.single(request)
         .via(httpClient)
         .mapAsync(1)(r => Unmarshal(r.entity).to[List[Post]])
         .runWith(Sink.head)

      flow.andThen {
         case Success(list) => println(s"request succeded ${list.size}")
         case Failure(_) => println("request failed")
      }.andThen {
         case _ => system.terminate()
      }
   }
}

但这给出了一个错误

[WARN] [08/05/2016 10:50:11.134] [my-Actor-akka.actor.default-dispatcher-3] [akka.actor.ActorSystemImpl(my-Actor)] 
HTTP header 'Set-Cookie: foo=bar' is not allowed in requests

Answer 1

为 akka-http 客户端构造任何标头的惯用方法是使用akka.http.scaladsl.model.headers.

在你的情况下，这将是

val cookieHeader = akka.http.scaladsl.model.headers.Cookie("name","value")
HttpRequest(uri = Uri("/comments"), headers = List(cookieHeader, ...))