scala - 如何处理scala中 future 发生的异常

Question

我正在 play 框架中编写一个 Controller 方法，该方法调用一个函数，该函数返回一个也可能抛出异常的 Future。我无法弄清楚如何捕获和处理该异常。

这是我尝试过的:

  def openIDCallback = Action { implicit request =>
    Async (
      Try(OpenID.verifiedId) match {
        case Failure(thrown) => {
          PurePromise(Ok("failed: " + thrown))
        }
        case Success(successResult) => {
          successResult.map( userInfo => {
            Ok(userInfo.id + "\n" + userInfo.attributes)
          })
        }
      }
    )
  }

OpenID.verifiedId 是 Play 的 OpenId api 中返回 Future[UserInfo] 的函数。这是该函数的来源:

def verifiedId(queryString: Map[String, Seq[String]]): Future[UserInfo] = {
    (queryString.get("openid.mode").flatMap(_.headOption),
      queryString.get("openid.claimed_id").flatMap(_.headOption)) match { // The Claimed Identifier. "openid.claimed_id" and "openid.identity" SHALL be either both present or both absent.
      case (Some("id_res"), Some(id)) => {
        // MUST perform discovery on the claimedId to resolve the op_endpoint.
        val server: Future[OpenIDServer] = discovery.discoverServer(id)
        server.flatMap(directVerification(queryString))(internalContext)
      }
      case (Some("cancel"), _) => PurePromise(throw Errors.AUTH_CANCEL)
      case _ => PurePromise(throw Errors.BAD_RESPONSE)
    }
  }

如上所示，函数可以返回 PurePromise(throw Errors.AUTH_CANCEL) 和 PurePromise(throw Errors.BAD_RESPONSE)。我的解决方案尝试正确处理成功，但在异常(exception)情况下我得到:

play.api.Application$$anon$1: Execution exception[[AUTH_CANCEL$: null]]

我的问题是如何在我的 Controller 方法中捕获和处理这些异常？

Answer 1

您应该使用 recover Future的方法而不是 Try像这样:

Async (
  OpenID.verifiedId.
    map{userInfo => Ok(userInfo.id + "\n" + userInfo.attributes)}.
    recover{ case thrown => Ok("failed: " + thrown) }
)

Try万一可以帮助您 verifiedId抛出异常而不是返回 Future .在你的情况下 verifiedId成功返回 Future (即使这个 Future 会有异常(exception))。