akka http atar EntityStreamException: Varlık akışı kesme

Question

Akka http kitaplığını kullanarak bir geri kalan API için istemci yazıyorum. Kütüphane çok güçlü görünüyor, ama benim için çok kararsız çalışıyor. Oldukça sık (her zaman değil) Bir HttpResponse.entity tüketmeye çalışırken aşağıdaki istisna atar:

EntityStreamException: Varlık dere kesme

ve bundan sonra da hiç bir sonraki istekleri işlemeyi durdurur. Belki de bazı geri-basınçlarla uğraşmaya çalışır ya da sadece ölürsün, bilmiyorum.

Ben bir istek göndermek ne kadar da talep Düzeyli İstemci Tarafı API kullanarak, önemli değil: Bağlantı Düzey İstemci Tarafı API

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 
    } 

veya kullanma:

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 
    } 

Unsmarshaller'ı kullanarak veya getDataBytes'i kullanarak manuel olarak kullanıp kullanmamaya karar vermez, sonuç aynıdır - yukarıdaki istisna.

Yanıtın http durumu 200 OK, üstbilgiler iyi, "Varsayılan" bir varlık (öbek yok), içerik uzunluğu yaklaşık 500-2000 Kb'dir (artan akka.http.parsing.max- varsayılan değer yeterli olmasına rağmen içerik uzunluğu yardımcı olmaz. Sunucu da tamam - diğer platformlardaki diğer http kütüphaneleri bu API ile çalışıyor.

Hata mı, yoksa yanlış bir şey mi yapıyorum? Scala için en iyi engelleme olmayan, asycnhonous http kütüphanesi nedir?

Answer 1

İlk soruyla ilgili yorumum var, ama aynı zamanda burada cevap veriyor, bu da herhangi birinin yardımcı olması durumunda bu durumun düşürülmesini sağlayabilir.

Bir yönlendirme yolu sorunuydu (evet, ciddi olarak). Aynı seviyede başka bir yolla bir şekilde çelişen iç içe geçmiş bir yol vardı (temelde başka bir yolu geçersiz kılmak için bir rotaya neden olan gariplik vardı ...). Bir kez rotaların yapısını yeniden çalıştım, her şey iyi çalıştı.