0

我正在基于 API 创建 Play 指标，因此我有一个过滤器，它将从请求标头中识别 URL 并基于 URL 创建指标。但是为了创建计时器指标，我们必须分别在方法的开头和结尾开始和停止上下文。

因此，在我的自定义过滤器中，它正在启动上下文，但我需要弄清楚如何停止它，因为 API 调用没有通过过滤器返回响应。只有请求通过过滤器，但响应通过控制器。

需要帮助来了解如何通过播放过滤器实现基于 API 的指标。任何线索都会受到称赞。

到目前为止取得的成就：

val getWallets = metrics.defaultRegistry.meter("GetWallets") // val lockWallet = metrics.defaultRegistry.meter("LockWallet") 

override def apply(nextFilter: (RequestHeader) => Future[Result])(requestHeader: RequestHeader): Future[Result] = {
  requestHeader.uri match {
    case IConstant.GET_WALLETS => { 
      getWallets.mark()
      nextFilter(requestHeader)
    }
    case _ => { 
      nextFilter(requestHeader)
    }
  }
}
4

1 回答 1

2

鉴于以下签名Filter.apply：

override def apply(nextFilter: (RequestHeader) => Future[Result])(requestHeader: RequestHeader): Future[Result]

此方法将返回一个Future[Result].

因此，您可以map在Future完成后停止指标，如下所示：

override def apply(nextFilter: (RequestHeader) => Future[Result])(requestHeader: RequestHeader): Future[Result] = {
  requestHeader.uri match {
    case IConstant.GET_WALLETS => { 
      getWallets.mark()
      nextFilter(requestHeader).map { result =>

        // Stop the metric here

        result
      }
    }
    case _ => { 
      nextFilter(requestHeader)
    }
  }
}
于 2018-02-13T09:47:11.430 回答