O ator ficar BufferOverflowException ao enviar Único

Question 1

Eu estou tentando enviar algumas centenas de solicitações http de akka ator no entanto, eu estou chegando

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

este aplicativo.conf

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

Este código

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

Eu tentei de controle pelo estado 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)))
        //...

de qualquer forma eu tenho a mesma exceção de BufferOverflowException

qualquer conselho será muito apreciada

Question 2

Usando context de forma assíncrona dentro de um Future é uma má ideia. context isso é válido somente durante as chamadas para o ator.

O erro é que context.become(run(openRequests - 1)) usa o valor de openRequests no momento em que o Future é criada, e não o valor quando é chamado. Assim, quando a primeira solicitação completa ele irá chamar context.become(run(-1)) (o que é claramente falso) mesmo que não pode ser de 15 de pedidos pendentes.

A solução é enviar uma mensagem privada para si mesmo no foreach em vez de chamar context.become diretamente. Quando o ator que manipula a mensagem diminui a atual contagem de pedido e envia uma nova solicitação, se necessário.

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

Usando context de forma assíncrona dentro de um Future é uma má ideia. context isso é válido somente durante as chamadas para o ator.

O erro é que context.become(run(openRequests - 1)) usa o valor de openRequests no momento em que o Future é criada, e não o valor quando é chamado. Assim, quando a primeira solicitação completa ele irá chamar context.become(run(-1)) (o que é claramente falso) mesmo que não pode ser de 15 de pedidos pendentes.

A solução é enviar uma mensagem privada para si mesmo no foreach em vez de chamar context.become diretamente. Quando o ator que manipula a mensagem diminui a atual contagem de pedido e envia uma nova solicitação, se necessário.

O ator ficar BufferOverflowException ao enviar Único

Pergunta

Melhor resposta

Em outros idiomas

Esta página está em outros idiomas

Popular nesta categoria

Perguntas populares nesta categoria