时间戳

首页 > 解决方案 > http4s 客户端返回部分有效载荷

scala - http4s 客户端返回部分有效载荷

问题描述

我正在使用AsyncHttpClienthttp4s-0.19.0-M2 进行客户端调用：

for {
    resp <- http.expectOr[String](GET(url)){ error =>
                error.as[String].map(body => throw new Exception(...)
            }
    _ <- doSomethingWithResponse(resp)
} yield ()

有时远程端超时，我在日志中看到以下内容：

java.util.concurrent.TimeoutException: Request timeout to remote.server.com after 60000 ms
    at org.asynchttpclient.netty.timeout.TimeoutTimerTask.expire(TimeoutTimerTask.java:43)
    at org.asynchttpclient.netty.timeout.RequestTimeoutTimerTask.run(RequestTimeoutTimerTask.java:50)
    at shade.cda.io.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:670)
    at shade.cda.io.netty.util.HashedWheelTimer$HashedWheelBucket.expireTimeouts(HashedWheelTimer.java:745)
    at shade.cda.io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:473)
    at shade.cda.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:748)

但是，它看起来doSomethingWithResponse()仍然被调用，但带有部分resp字符串。有没有办法改变这种行为，以便在http.expectOr无法检索整个有效负载时调用失败？

标签： scalahttp4s

解决方案

推荐阅读