如何处理Akka HTTP客户端响应失败

Question

Akka HTTP客户端请求返回Future [HttpResponse] - 应该如何处理Future失败？只要记录一个错误或重新扔给主管？

是否存在客户端抛出的错误类型（因此会自动传播给主管）以及可能导致Furure失败的错误的文档。

Answer 1

大部分是味道的问题。我通常转换Future[HttpResponse]到Future[Try[HttpResponse]]，然后如果你使用基于流的客户端处理它作为

response.flatMap { tryResp => 

    tryResp match { 
    case Success(res) => 
     res.status match { 
     case OK => 
      // Unmarshal response here into Future[Something] 
     case Found => 
      // Handle redirect by calling requestBlhBlah() again with anotehr URI 
     case _ => 
      // I got status code I didn't expect so I wrap it along with body into Future failure 
      Unmarshal(res.entity).to[String].flatMap { body => 
      Future.failed(new IOException(s"The response status is ${res.status} [${request.uri}] and response body is $body")) 
      } 
     } 
    case Failure(ex) => 
     Future.failed(ex) 
    } 
} 

你也可以指定Decider处理错误

val decider: Decider = { 
    case ex => 
    ex.printStackTrace() 
    Supervision.Stop // Passes error down to subscriber 
} 

，然后在任何materializer

使用

implicit val materializer = ActorMaterializer(ActorMaterializerSettings(system).withSupervisionStrategy(decider))(system) 

或每个流的基础上经由.withAttributes(ActorAttributes.supervisionStrategy(decider))

根据Future故障，由您决定如何处理。您可以使用recoverWith将故障转换为别的东西，或将其记录在Future.onFailure中。