处理WebClient中有正文和无正文的错误

Question

我已经在如下所示的过滤器中实现了错误处理：

public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) {
  URI url = request.url();
  HttpMethod method = request.method();
  return next.exchange(request).flatMap(response -> {
    if (response.statusCode().isError()) {
      return response.bodyToMono(String.class).flatMap(responseBody -> {
        Optional<Exception> exception = errorResponseHandler.handleError(method, response.statusCode(), url, responseBody);
        if (exception.isPresent()) {
          return Mono.error(exception.get());
        } else {
          // fallback
          return Mono.error(new UnsupportedOperationException("The fallback functionality is still missing"));
        }
      });
    } else {
      return Mono.just(response);
    }
  });
}

如果响应带有一个主体，那么< code > response . bodytomono(string . class ),这样做应该没问题。平面地图(...)被执行。然而当身体是空的时候，什么都不会发生，但是我想要的是也处理错误。我的理解是，我会这样做:

response.bodyToMono(String.class).flatMap(...)
.switchIfEmpty(Mono.error(new UnsupportedOperationException("The body was empty")));

这不起作用，因为预期返回的类型是Mono而不是Mono。

我如何在有响应体和无响应体的情况下实现对错误的处理，这是纠正异常所需的构造？

Answer 1

这个问题让我走上了正确的轨道：switchIfEmpty 调用必须在 flatMap 之前出现。由于没有主体，flatMap 不会执行，之后的任何内容也不会执行，因此 switchIfEmpty 必须排在第一位：

public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) {
  URI url = request.url();
  HttpMethod method = request.method();
  return next.exchange(request).flatMap(response -> {
    if (response.statusCode().isError()) {
      return response.bodyToMono(String.class)
        .switchIfEmpty(Mono.error(new UnsupportedOperationException("The body was empty")));
        .flatMap(responseBody -> {
          Optional<Exception> exception = errorResponseHandler.handleError(method, response.statusCode(), url, responseBody);
          if (exception.isPresent()) {
            return Mono.error(exception.get());
          } else {
            // fallback
            return Mono.error(new UnsupportedOperationException("The fallback functionality is still missing"));
          }
        });
    } else {
      return Mono.just(response);
    }
  });
}