Actorul obtinerea BufferOverflowException la trimiterea Singur

0

Problema

Încerc să trimită câteva sute de cereri http de la akka actor cu toate acestea sunt obtinerea

akka.stream.BufferOverflowException: Exceeded configured max-open-requests value of [16]. This means that the request queue of this pool (HostConnectionPoolSetup(places.api.here.com,443,ConnectionPoolSetup(ConnectionPoolSettings(16,1,5,16,1,Duration.Inf,100 milliseconds,2 minutes,30 seconds,ClientConnectionSettings(Some(User-Agent: akka-http/10.2.0)...

această aplicație.conf

   http {
          host-connection-pool {
            max-connections = 16
            min-connections = 1
            max-open-requests = 16
          }
        }

Acest cod

override def receive: Receive = {
      case Foo(_) => 
       val res: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://..."))
   // do something for the result

Am încercat să-controlul de stat e.g

override def receive: Receive = run(0)
def run(openRequests: Int) : Receive = {
  case Foo(_) if openRequests <= 16 => 
     context.become(run(openRequests + 1))
       val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://..."))
       responseFuture.foreach(context.become(run(openRequests - 1)))
        //...

oricum am aceeași excepție de BufferOverflowException

orice sfat va fi apreciat foarte mult

akka akka-http akka-stream scala
2021-10-22 05:31:19
1

Cel mai bun răspuns

2

Folosind context asincron în interiorul unui Future este o idee proastă. context acesta este valabil doar în timpul apelurilor la actor.

Bug-ul este că context.become(run(openRequests - 1)) utilizează valoarea de openRequests în momentul în care Future este creat, nu valoarea atunci când este chemat. Deci, atunci când prima completeaza cererea se va apela context.become(run(-1)) (care este în mod clar fals), chiar dacă pot exista 15 cereri restante.

Soluția este de a trimite un mesaj privat pentru a vă în foreach mai degrabă decât de asteptare context.become direct. Atunci când actorul se ocupă de acest mesaj se decrementeaza la curent cerere conta și trimite o nouă cerere, dacă este necesar.

2021-10-22 07:52:58

În alte limbi

Această pagină este în alte limbi

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................