play ws выполнять два (или более) запроса gzip одновременно иногда не удается

Мой запрос:

WS.url(url)
.withHeaders("Accept-Encoding" -> "gzip")
.withQueryString("xxx","xxx")

Код, используемый для распаковки тела

 def call[T](api: WeiboApi[T])(implicit mf: Manifest[T]) = {
    val param = parameters(api)
    (api match {
      case _: Get[T] => get(api.url, param)
      case _: Post[T] => post(api.url, param)
    }) map {
      resp =>
      try {
        val decompressedBody = decompressIfGzip(resp)
        api.parse(decompressedBody)
      } catch {
        case e: WeiboApiError => throw e
        case e: Exception =>
          throw new Exception("cannot parse body api " + api, e)
      }
    }
  }

private def decompressIfGzip(resp: Response) = {
    val ahcResp = resp.getAHCResponse
        ahcResp.getHeader("Content-Encoding") match {
          case "gzip" | "GZIP" =>
            val in = ahcResp.getResponseBodyAsStream
            val gzipStream = new GZIPInputStream(in)
            try {
              val source = scala.io.Source.fromInputStream(gzipStream)
              source.mkString
            } finally {
              in.close()
            }
          case _ =>
            ahcResp.getResponseBody
        }
}

Затем я отправляю два запроса одновременно.

Иногда это нормально

Но иногда повторяется

[error] Corrupt GZIP trailer
[error] sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:283)
[error] sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:325)
[error] sun.nio.cs.StreamDecoder.read(StreamDecoder.java:177)
[error] lib.weibo.Weibo$.lib$weibo$Weibo$$decompressIfGzip(Weibo.scala:138)
[error] lib.weibo.Weibo$$anonfun$call$1.apply(Weibo.scala:47)
[error] lib.weibo.Weibo$$anonfun$call$1.apply(Weibo.scala:42)
[error]

akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) [ошибка] akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala: 82) [ошибка] akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) [ошибка] akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala: 59) [ошибка] akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) [ошибка] akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) [ошибка] akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec (AbstractDispatcher.scala:386)

Что случилось ?


scala playframework asynchttpclient playframework-2.2
person jilen    schedule 10.01.2014    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Оказывается, данные ответа иногда повреждены.

person jilen    schedule 13.02.2014

arrow_upward
0
arrow_downward

Не уверен, но вам может понадобиться обернуть этот код с помощью InputStreamReader:

https://stackoverflow.com/questions/3627401/gzipinputstream-to-string/3627441#3627441< /а>

person Will Sargent    schedule 10.01.2014
comment
Я пробовал это, но не повезло. Кажется, что-то связанное с асинхронным http-клиентом. Я использую спрей для реализации той же функциональности, он отлично работает. Я попробую код снова завтра. - person jilen; 10.01.2014
comment
Вы используете SSL или прокси? - person Will Sargent; 11.01.2014
comment
Я использую ssl, но не прокси - person jilen; 11.01.2014