Актер получает исключение BufferOverflowException при отправке одного

Question 1

Я пытаюсь отправить пару сотен http-запросов от актера akka, однако я получаю

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

это приложение.conf

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

Это код

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

Я пытался контролировать, например, государством

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

в любом случае, я получил одно и то же исключение BufferOverflowException

любые советы будут вам очень признательны

Question 2

С помощью context асинхронно внутри Future это плохая идея. context он действителен только во время звонков актеру.

Ошибка в том, что context.become(run(openRequests - 1)) использует значение openRequests в то время, когда Future создается, а не значение, когда оно вызывается. Поэтому, когда первый запрос завершится, он вызовет context.become(run(-1)) (что явно фальшиво), хотя может быть 15 невыполненных запросов.

Решение состоит в том, чтобы отправить личное сообщение самому себе в foreach вместо того, чтобы звонить context.become непосредственно. Когда субъект обрабатывает это сообщение, он уменьшает текущее количество запросов и при необходимости отправляет новый запрос.

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

С помощью context асинхронно внутри Future это плохая идея. context он действителен только во время звонков актеру.

Ошибка в том, что context.become(run(openRequests - 1)) использует значение openRequests в то время, когда Future создается, а не значение, когда оно вызывается. Поэтому, когда первый запрос завершится, он вызовет context.become(run(-1)) (что явно фальшиво), хотя может быть 15 невыполненных запросов.

Решение состоит в том, чтобы отправить личное сообщение самому себе в foreach вместо того, чтобы звонить context.become непосредственно. Когда субъект обрабатывает это сообщение, он уменьшает текущее количество запросов и при необходимости отправляет новый запрос.

Актер получает исключение BufferOverflowException при отправке одного

Вопрос

Лучший ответ

На других языках

Эта страница на других языках

Популярное в этой категории

Популярные вопросы в этой категории