成功和错误时记录响应时间 - Webflux即使出现错误也会调用 doOnSuccess

如何解决成功和错误时记录响应时间 - Webflux即使出现错误也会调用 doOnSuccess

我编写了这个过滤器来测量 API 的响应时间。当我收到错误时触发 onSuccess 。 有没有办法分别登录成功和错误以更好地记录。

public class RequestTimingFilter implements WebFilter {

  @Override
  public Mono<Void> filter(ServerWebExchange exchange,WebFilterChain chain) {
    if (exchange.getRequest().getPath().value().contains("something")) {
      long startMillis = System.currentTimeMillis();
      return chain
          .filter(exchange)
          .doOnSuccess(
              success ->
                  log.info(
                      "Api call successfull: {}ms",System.currentTimeMillis() - startMillis));
    }
    return chain.filter(exchange);
  }
}

解决方法

我能够通过使用以下代码来实现这一点 -

return chain
          .filter(exchange)
          .then(
              Mono.fromRunnable(
                  () -> {
                    ServerHttpResponse response = exchange.getResponse();
                    if (Objects.requireNonNull(response.getStatusCode()).is2xxSuccessful()) {
                      log.info(
                          "Success: {}ms",System.currentTimeMillis() - startMillis);
                    } else {
                      log.info("Failure");
                    }
                  }));