Scala Play Future[Response] 始终为空

Question

Future[Response].value:Option[Try[Response]] 始终为空。我误解了期货吗？我需要将其包装在onSuccess 中吗？但是它不会返回一个字符串，而是一个单元？

@tailrec private def initConnection: String =
  {
    val response: Future[Response] = initHeaders(WS.url(url)).post(authBody)
    val retry: Boolean = {
      response.value.isEmpty || response.value.get.isFailure || response.value.get.get.header("ConnectionID").isEmpty
    }

    if (!retry) return response.value.get.get.header("ConnectionID").get
    else initConnection
  }

Answer 1

Future#value 不会阻止未来。如果调用value的时候future已经完成，你会得到Some(_)，否则就是None。所以你只看到None，因为你在发送请求后立即检查value，但它还没有完成。您可以使用collect 和recoverWith 等未来的组合子来实现重试功能并返回Future[String] 而不是String。如果你以后真的需要这个值，你将不得不Await.result未来。

import scala.util.control.NonFatal
import scala.concurrent.Await

private def initConnectionFuture: Future[String] =
  initHeaders(WS.url(url)).post(authBody).collect {
    case response if response.header("ConnectionID").isDefined =>
      response.header("ConnectionID").get
  }.recoverWith {
    case NonFatal(_) => initConnectionFuture
  }

private def initConnection: String =
  Await.result(initConnectionFuture, 5 seconds) // or any other acceptable timeout

除了超时，您可能还想限制重试次数，例如

private def initConnectionFuture(retries: Int = 5): Future[String] =
  initHeaders(WS.url(url)).post(authBody).collect {
    case response if response.header("ConnectionID").isDefined =>
      response.header("ConnectionID").get
  }.recoverWith {
    case NonFatal(_) if retries > 0 => initConnectionFuture(retries - 1)
  }