Как справиться с ответом на ответ клиента HTTP-сервера Akka

Question

Запросы клиента HTTP Akka return [HttpResponse] - как обращаться с будущим в неудачу? Просто зарегистрируйте ошибку или перебросите ее в супервизор?

Имеется документация о типах ошибок, которые могут быть возвращены клиентом (и, следовательно, автоматически переданы супервизору), а также ошибки, которые могут привести к сбою 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.