Спрей-клиент Запрос времени ожидания - PullRequest
Новая
       32

Спрей-клиент Запрос времени ожидания

0 голосов
/ 05 марта 2020

Я новичок в scala. Я пытаюсь тайм-аут API-запроса. Я использую спрей, чтобы сделать запрос API. У меня есть клиент спрей, чтобы получить ответ от другого сервера. В моем application.conf я указал время ожидания запроса в spray.can что-то вроде: 

spray.can {
  server {
    idle-timeout = ${idle-timeout}
    request-timeout = ${request-timeout}
    request-chunk-aggregation-limit = 20m
    parsing {
      max-content-length = 21m
    }
  }
  client {
    idle-timeout = ${idle-timeout}
    request-timeout = ${request-timeout}
    response-chunk-aggregation-limit = 20m
  }
}

Теперь я хочу переопределить это время ожидания запроса в одном моем API. Я написал api что-то вроде: 

def completeService(jwttoken: String, completeRequest: String): Future[HttpResponse] = {
    val pipeline: HttpRequest => Future[HttpResponse] = sendReceive ~> unmarshal[HttpResponse]
        val response: Future[HttpResponse] = pipeline(Post(some-remote-url, completeRequest)
          ~> addHeader("FROM", jwttoken))
    response
}

Итак, как я могу указать здесь время ожидания запроса в этом методе? Переопределив application.conf

Я попытался 

 implicit val timeoutVal: Timeout = Timeout(scala.concurrent.duration.Duration(100, MILLISECONDS).asInstanceOf[FiniteDuration])

, и я получил это: 

  test 2020-03-06 08:48:12.147 GMT [WARN] a.k.i.AskPatternInstrumentation - Timeout triggered for ask pattern to actor [IO-HTTP] at [pipelining.scala:38]
  test 2020-03-06 08:48:12.573 GMT [INFO] akka.actor.DeadLetterActorRef - Message [spray.http.HttpResponse] from Actor[akka://test-app/user/IO-HTTP/host-connector-1/1#-1105043312] to Actor[akka://test-app/deadLetters] was not deliver

1 Ответ

0 голосов
/ 05 марта 2020

Я думаю, что вы можете добавить неявный параметр requestTimeout. Тип данных этого параметра - akka.util.Timeout. Вы можете проверить эту ссылку для получения более подробной информации или ссылку 

val _pipeline: Future[SendReceive] =
for (
  Http.HostConnectorInfo(connector, _) <-
  IO(Http) ? Http.HostConnectorSetup("www.spray.io", port = 80, settings = Some(new HostConnectorSettings(maxConnections = 3, maxRetries = 3, maxRedirects = 0, pipelining = false, idleTimeout = 5 seconds, connectionSettings = ClientConnectionSettings(...))))
) yield sendReceive(connector)

Дайте мне знать, если это поможет !!

...