blocks|key|4472332|text|由于Akka+Http是基于流的，因此实体也是流的。如果您确实需要一次使用整个字符串，可以将传入的请求转换为Strict请求：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|4472333|这是通过使用toStrict(timeout:+FiniteDuration)(mat:+Materializer)接口在给定的时间限制内将请求收集到一个严格的实体中来完成的(这一点很重要，因为您不想在传入请求实际上永远不会结束的情况下“尝试永远收集实体”)：|4472334|import+akka.stream.ActorFlowMaterializer
import+akka.actor.ActorSystem

implicit+val+system+=+ActorSystem("Sys")+//+your+actor+system,+only+1+per+app
implicit+val+materializer+=+ActorFlowMaterializer()+//+you+must+provide+a+materializer

import+system.dispatcher
import+scala.concurrent.duration._
val+timeout+=+300.millis

val+bs:+Future[ByteString]+=+entity.toStrict(timeout).map+{+_.data+}
val+s:+Future[String]+=+bs.map(_.utf8String)+//+if+you+indeed+need+a+`String`|code-block|syntax|javascript|4472335|entityMap^0|1I|6|0|6|1G|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|R|8|@$9|S|A|T|B|C]]|D|@]|E|$]]|$1|H|3|I|5|J|7|U|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|V|8|@]|D|@]|E|$]]]|N|$]]

Since Akka Http is streams based, the entity is streaming as well. If you really need the entire string at once, you can convert the incoming request into a <code>Strict</code> one:

This is done by using the <code>toStrict(timeout: FiniteDuration)(mat: Materializer)</code> API to collect the request into a strict entity within a given time limit (this is important since you don't want to "try to collect the entity forever" in case the incoming request does actually never end):

<pre><code>import akka.stream.ActorFlowMaterializer
import akka.actor.ActorSystem

implicit val system = ActorSystem("Sys") // your actor system, only 1 per app
implicit val materializer = ActorFlowMaterializer() // you must provide a materializer

import system.dispatcher
import scala.concurrent.duration._
val timeout = 300.millis

val bs: Future[ByteString] = entity.toStrict(timeout).map { _.data }
val s: Future[String] = bs.map(_.utf8String) // if you indeed need a `String`
</code></pre>

blocks|key|4471881|text|import+akka.http.scaladsl.unmarshalling.Unmarshal

implicit+val+system+=+ActorSystem("System")++
implicit+val+materializer+=+ActorFlowMaterializer()+

val+responseAsString:+Future[String]+=+Unmarshal(entity).to[String]|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|4471882|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>import akka.http.scaladsl.unmarshalling.Unmarshal

implicit val system = ActorSystem("System") 
implicit val materializer = ActorFlowMaterializer() 

val responseAsString: Future[String] = Unmarshal(entity).to[String]
</code></pre>

blocks|key|4472358|text|不幸的是，在我的例子中，Unmarshal+to+String不能正常工作，抱怨：Unsupported+Content-Type,+supported:+application/json。这将是更优雅的解决方案，但我不得不使用另一种方法。在我的测试中，我使用了从响应实体中提取的Future和Await+(从scala.concurrent中)来获得来自Future的结果：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|4472359|Put("/post/item",+requestEntity)+~>+route+~>+check+{
++val+responseContent:+Future[Option[String]]+=
++response.entity.dataBytes.map(_.utf8String).runWith(Sink.lastOption)

++val+content:+Option[String]+=+Await.result(responseContent,+10.seconds)
++content.get+should+be(errorMessage)
++response.status+should+be(StatusCodes.InternalServerError)
}|code-block|syntax|javascript|4472360|如果您需要遍历响应中的所有行，您可以使用runForeach+of+Source：|4472361|+response.entity.dataBytes.map(_.utf8String).runForeach(data+=>+println(data))|4472362|entityMap^0|C|9|15|1H|0|0|K|A|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@$9|R|A|S|B|C]|$9|T|A|U|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|V|8|@]|D|@]|E|$I|J]]|$1|K|3|L|5|6|7|W|8|@$9|X|A|Y|B|C]]|D|@]|E|$]]|$1|M|3|N|5|H|7|Z|8|@]|D|@]|E|$I|J]]|$1|O|3|-4|5|6|7|10|8|@]|D|@]|E|$]]]|P|$]]

Unfortunately in my case, <code>Unmarshal</code> to String didn't work properly complaining on: <code>Unsupported Content-Type, supported: application/json</code>. That would be more elegant solution, but I had to use another way. In my test I used Future extracted from entity of the response and Await (from scala.concurrent) to get the result from the Future:

<pre><code>Put("/post/item", requestEntity) ~&gt; route ~&gt; check {
 val responseContent: Future[Option[String]] =
 response.entity.dataBytes.map(_.utf8String).runWith(Sink.lastOption)

 val content: Option[String] = Await.result(responseContent, 10.seconds)
 content.get should be(errorMessage)
 response.status should be(StatusCodes.InternalServerError)
}
</code></pre>

If you need to go through all lines in a response, you can use <code>runForeach</code> of Source:

<pre><code> response.entity.dataBytes.map(_.utf8String).runForeach(data =&gt; println(data))
</code></pre>

blocks|key|4471948|text|你也可以试试这个。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4471949|responseObject.entity.dataBytes.runFold(ByteString(""))(_+%2B%2B+_).map(_.utf8String)+map+println|code-block|syntax|javascript|4471950|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

You can also try this one also. 

<pre><code>responseObject.entity.dataBytes.runFold(ByteString(""))(_ ++ _).map(_.utf8String) map println
</code></pre>

blocks|key|4472429|text|这是我的工作示例，|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4472430|++import+akka.actor.ActorSystem
++import+akka.http.scaladsl.Http
++import+akka.http.scaladsl.model._
++import+akka.stream.ActorMaterializer
++import+akka.util.ByteString

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

++def+getDataAkkaHTTP:Unit+=+{

++++implicit+val+system+=+ActorSystem()
++++implicit+val+materializer+=+ActorMaterializer()
++++//+needed+for+the+future+flatMap/onComplete+in+the+end
++++implicit+val+executionContext+=+system.dispatcher

++++val+url+=+"http://localhost:8080/"
++++val+responseFuture:+Future[HttpResponse]+=+Http().singleRequest(HttpRequest(uri+=+url))

++++responseFuture.onComplete+{
++++++case+Success(res)+=>+{
++++++++val+HttpResponse(statusCodes,+headers,+entity,+_)+=+res
++++++++println(entity)
++++++++entity.dataBytes.runFold(ByteString(""))(_+%2B%2B+_).foreach+(body+=>+println(body.utf8String))
++++++++system.terminate()
++++++}
++++++case+Failure(_)+=>+sys.error("something+wrong")
++++}


++}|code-block|syntax|javascript|4472431|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Here is my working example,

<pre><code> import akka.actor.ActorSystem
 import akka.http.scaladsl.Http
 import akka.http.scaladsl.model._
 import akka.stream.ActorMaterializer
 import akka.util.ByteString

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

 def getDataAkkaHTTP:Unit = {

 implicit val system = ActorSystem()
 implicit val materializer = ActorMaterializer()
 // needed for the future flatMap/onComplete in the end
 implicit val executionContext = system.dispatcher

 val url = "http://localhost:8080/"
 val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = url))

 responseFuture.onComplete {
 case Success(res) =&gt; {
 val HttpResponse(statusCodes, headers, entity, _) = res
 println(entity)
 entity.dataBytes.runFold(ByteString(""))(_ ++ _).foreach (body =&gt; println(body.utf8String))
 system.terminate()
 }
 case Failure(_) =&gt; sys.error("something wrong")
 }


 }
</code></pre>

blocks|key|4472011|text|Unmarshaller.stringUnmarshaller(someHttpEntity)|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|4472012|像一种魅力一样工作，也需要隐含的物化|unstyled|4472013|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$B|C]]|$1|D|3|E|5|F|7|J|8|@]|9|@]|A|$]]|$1|G|3|-4|5|F|7|K|8|@]|9|@]|A|$]]]|H|$]]

<pre><code>Unmarshaller.stringUnmarshaller(someHttpEntity)
</code></pre>

works like a charm, implicit materializer needed as well

blocks|key|4472499|text|下面是从请求体中提取string的简单指令|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|4472500|def+withString():+Directive1[String]+=+{
++extractStrictEntity(3.seconds).flatMap+{+entity+=>
++++provide(entity.data.utf8String)
++}
}|code-block|syntax|javascript|4472501|entityMap^0|A|6|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@$9|N|A|O|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|P|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|Q|8|@]|D|@]|E|$]]]|L|$]]

Here is simple directive that extracts <code>string</code> from request's body

<pre><code>def withString(): Directive1[String] = {
 extractStrictEntity(3.seconds).flatMap { entity =&gt;
 provide(entity.data.utf8String)
 }
}
</code></pre>

So I have a function with this signature (akka.http.model.HttpResponse):

<pre><code>def apply(query: Seq[(String, String)], accept: String): HttpResponse
</code></pre>

I simply get a value in a test like:

<pre><code>val resp = TagAPI(Seq.empty[(String, String)], api.acceptHeader)
</code></pre>

I want to check its body in a test something like:

<pre><code>resp.entity.asString == "tags"
</code></pre>

My question is how I can get the response body as string?

akka HttpResponse read body as String scala

所以我有一个带有这个签名的函数(akka.http.model.HttpResponse)：def apply(query: Seq[(String, String)], accept: String): HttpResponse我只是在测试中获得一个值，如下所示：val resp = TagAPI(Seq.empty...

问akka HttpResponse以字符串缩放方式读取正文
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问akka HttpResponse以字符串缩放方式读取正文EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问akka HttpResponse以字符串缩放方式读取正文
EN