akka http lancia EntityStreamException: troncamento del flusso di entità

Question

Sto scrivendo un client per un'API di resto che utilizza la libreria http di akka. La libreria sembra molto potente, ma per me è molto instabile. Molto spesso (non sempre) viene generata la seguente eccezione quando si tenta di consumare un HttpResponse.entity:

EntityStreamException: Entity flusso troncamento

e dopo questo si interrompe l'elaborazione successive richieste a tutti. Forse cerca di far fronte a qualche contropressione o agli attori che muoiono, non lo so.

Non importa come mi inviare una richiesta, utilizzando la richiesta-livello API lato client:

def pollSearchResult(searchId: String): FutureActionResult[String, SearchResult] = { 
    val request = HttpRequest(GET, s"http://***/Search/$searchId") 

    for { 
     response <- Http().singleRequest(request) 
     entity <- Unmarshal(response.entity).to[String] 
     result = entity.decodeEither[SearchResult] 
    } yield result 
    } 

o utilizzando il collegamento a livello di API lato client:

val client = Http(actorSystem).outgoingConnection("***") 

def pollSearchResult(searchId: String): FutureActionResult[String, SearchResult] = { 
    val request = HttpRequest(GET, s"Search/$searchId") 

    for { 
     response <- Source.single(request).via(client).runWith(Sink.head) 
     entity <- Unmarshal(response.entity).to[String] 
     result = entity.decodeEither[SearchResult] 
     } yield result 
    } 

Non importa se consumo l'entità usando unmarshaller o manualmente usando getDataBytes, il risultato è lo stesso - l'eccezione di cui sopra.

Lo stato http della risposta è 200 OK, le intestazioni sono ok, è un'entità "Predefinita" (quindi, nessun chunking), la lunghezza del contenuto è di circa 500-2000 Kb (in aumento akka.http.parsing.max- la lunghezza del contenuto non aiuta, sebbene il valore predefinito dovrebbe essere sufficiente). Anche il server è ok - altre librerie http su altre piattaforme funzionano bene con questa API.

È un errore o sto facendo qualcosa di sbagliato? Qual è la migliore libreria HTTP non bloccante, asinconica per scala?

Answer 1

Ho commenti sulla domanda iniziale, ma anche la risposta qui in modo che possa essere svalutato nel caso in cui questo aiuti chiunque.

Si trattava di un problema di percorso di routing (sì, sul serio). Avevo una rotta nidificata che era in qualche modo in conflitto con un'altra rotta allo stesso livello (in pratica c'erano stranezze che causavano un percorso per scavalcare un altro ...). Una volta che ho rielaborato la struttura dei percorsi, tutto ha funzionato bene.