Запрос POST иногда попадает не в ту конечную точку в программе Akka-http

У меня есть сервер Akka-http 2 для обработки HTTP-запросов.

На любой конечной точке я перехожу к классу случая A или B:

case class caseClassA(data: String, eventID: String)
case class caseClassB(data: String, otherData: JsObject)

У меня есть такой объект маршрутов:

   val routes = {
     logRequestResult("akka-http-microservice") {        
       pathPrefix("some_endpoint")
        (post & entity(as[caseClassA])) {
        Request =>
          val future = someFunction(Request)
            complete {
              future.map(result =>
                result
              )
            }
        } ~
        pathPrefix("other_endpoint") {
          (post & entity(as[caseClassB])) {
          Request =>
            val future = otherFunction(Request)
              complete {
                future.map(result =>
                  result
                ) 
              }
            }
          }
        }

Проблема: Иногда при вызове из приложения iOS с помощью Alamofire я получаю ответ об ошибке с ошибочными данными на some_endpoint при выполнении запрос other_endpoint с преобразуемым объектом JSON caseClassB:

[DEBUG] [01/22/2016 16:30:16.350] [ReactiveKafka-akka.actor.default-dispatcher-23] [ActorSystem(ReactiveKafka)] akka-http-microservice: Response for
  Request : HttpRequest(HttpMethod(POST),http://192.168.2.141:9004/other_endpoint,List(Host: 192.168.2.141:9004, Connection: keep-alive, Accept: */*, User-Agent: myapp/myco.myapp (1; OS Version 9.2  (Build 13C75)), Accept-Language: en-US, zh-Hans-US;q=0.9, Accept-Encoding: gzip, compress;q=0.5),HttpEntity.Strict(application/json,ByteString(XXX, XXX, XXX, XXX, ETC <REPLACED FOR READABILITY, THIS WAS GOOD DATA>)),HttpProtocol(HTTP/1.1))
  Response: Complete(HttpResponse(200 OK,List(),HttpEntity.Strict(application/json,ByteString(XXX, XXX, XXX, XXX, ETC <REPLACED FOR READABILITY, THIS WAS GOOD DATA>)),HttpProtocol(HTTP/1.1)))
[DEBUG] [01/22/2016 16:30:21.347] [ReactiveKafka-akka.actor.default-dispatcher-5] [akka://ReactiveKafka/user/$a/flow-17-2-prefixAndTail] Cancelling akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@454147bb (after: 5000 ms)
[DEBUG] [01/22/2016 16:30:26.259] [ReactiveKafka-akka.actor.default-dispatcher-7] [ActorSystem(ReactiveKafka)] akka-http-microservice: Response for
  Request : HttpRequest(HttpMethod(POST),http://192.168.2.141:9004/other_endpoint,List(Host: 192.168.2.141:9004, Connection: keep-alive, Accept: */*, User-Agent: myapp/myco.myapp (1; OS Version 9.2  (Build 13C75)), Accept-Language: en-US, zh-Hans-US;q=0.9, Accept-Encoding: gzip, compress;q=0.5),HttpEntity.Default(application/json,319,akka.stream.scaladsl.Source@c3e53bd),HttpProtocol(HTTP/1.1))
  Response: Rejected(List(MalformedRequestContentRejection(Object is missing required member 'eventID',Some(java.util.NoSuchElementException: key not found: eventID)), TransformationRejection(<function1>), MalformedRequestContentRejection(Unexpected end-of-input at input index 0 (line 1, position 1), expected JSON Value:

^
,None), TransformationRejection(<function1>)))

Как вы можете видеть, пропустив eventID, это пытается преобразовать в caseClassA. Оба запроса в выходных данных выше показывают, что я пытаюсь попасть в other_endpoint. Когда я вызываю эту конечную точку из Postman с теми же данными, она работает 100% времени.

Что дает?


alamofire scala akka-http spray
person olympia    schedule 22.01.2016    source источник
comment
Будет ли это просто отсутствующим набором фигурных скобок после директивы pathPrefix (some_endpoint)?   -  person Richard Sitze    schedule 23.01.2016
comment
Ага. После долгих испытаний выяснилось, что это приводило к периодическим сбоям. Кажется странным, что у sbt / IntelliJ не было проблем с плохим синтаксисом. Чертовы фигурные скобки.   -  person olympia    schedule 25.01.2016

Ответы (1)


arrow_upward
0
arrow_downward

Как видно из комментариев выше, проблема заключалась в отсутствии скобок ({}) вокруг кода для "some_endpoint". Вот исправленный блок кода:

val routes = {
  logRequestResult("akka-http-microservice") {        
    pathPrefix("some_endpoint") {
      (post & entity(as[caseClassA])) {
         Request =>
         val future = someFunction(Request)
         complete {
           future.map(result =>
             result
           )
         }
       }
     } ~
     pathPrefix("other_endpoint") {
       (post & entity(as[caseClassB])) {
         Request =>
         val future = otherFunction(Request)
         complete {
           future.map(result =>
             result
           ) 
         }
       }
     }
   }
person olympia    schedule 10.02.2016