Aktor dostaje wyjątek BufferOverflowException podczas wysyłania jednego

Question 1

Staram się wysłać kilkaset http aktora akka, ale dostaję

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)...

ta aplikacja.conf

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

To jest kod

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

Starałem się kontrolować, na przykład, państwo

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)))
        //...

w każdym razie, mam to samo wyjątek BufferOverflowException

wszelkie porady będą ci bardzo wdzięczni

Question 2

Z pomocą context asynchronicznie wewnątrz Future to jest zły pomysł. context on jest ważny tylko podczas rozmów aktora.

Błąd w tym, że context.become(run(openRequests - 1)) używa wartości openRequests w czasie, gdy Future jest tworzony, a nie wartość, gdy jest to spowodowane. Dlatego, gdy pierwszy wniosek zakończy się, to spowoduje context.become(run(-1)) (co oczywiście fałszywe), choć może być 15 prób zakończonych niepowodzeniem.

Rozwiązanie polega na tym, aby wysłać prywatną wiadomość do samego siebie w foreach zamiast dzwonić context.become bezpośrednio. Gdy podmiot przetwarza komunikat, zmniejsza aktualna liczba zapytań i w razie potrzeby wysyła nowy wniosek.

Tim · Answer 1 · 2021-10-22T07:52:58

Z pomocą context asynchronicznie wewnątrz Future to jest zły pomysł. context on jest ważny tylko podczas rozmów aktora.

Błąd w tym, że context.become(run(openRequests - 1)) używa wartości openRequests w czasie, gdy Future jest tworzony, a nie wartość, gdy jest to spowodowane. Dlatego, gdy pierwszy wniosek zakończy się, to spowoduje context.become(run(-1)) (co oczywiście fałszywe), choć może być 15 prób zakończonych niepowodzeniem.

Rozwiązanie polega na tym, aby wysłać prywatną wiadomość do samego siebie w foreach zamiast dzwonić context.become bezpośrednio. Gdy podmiot przetwarza komunikat, zmniejsza aktualna liczba zapytań i w razie potrzeby wysyła nowy wniosek.

Aktor dostaje wyjątek BufferOverflowException podczas wysyłania jednego

Pytanie

Najlepsza odpowiedź

W innych językach

Ta strona jest w innych językach

Popularne w tej kategorii

Najczęściej zadawane pytania w tej kategorii