Webclient错误处理-Spring Webflux

Question

我想在以下条件下抛出自定义异常：

>

如果我得到了json格式的正确错误响应，我想反序列化它，并在onStatus（）中抛出名为CommonException的异常

如果作为响应的一部分接收HTML内容或反序列化未成功执行，则我希望抛出GenericeException，这是我在onErrorMap（）中创建的

在抛出GenericException时，我希望将从下游响应获得的相同HttpStatus代码传递给上游。

 IdVerificationResponse idVerificationResponse = client.get()
 .uri(idVerificationUrl)
 .headers(headers -> headers.addAll(httpEntity.getHeaders()))
 .retrieve()
 .onStatus(HttpStatus::isError, response ->
     //Throw this one only if deserialization of error response to IdVerificationErrorResponse class happens successfully

     response.bodyToMono(IdVerificationErrorResponse.class)
         .flatMap(error -> Mono.error(CommonException.builder().message(error.getCustomMessage()).build()))
 )
 .bodyToMono(IdVerificationResponse.class)
 .onErrorMap(error -> {
     //Come over here only if there is an error in deserialization in onStatus()

     //How to get the HttpStatus we are getting as part of error response from the downstream
     HttpStatus httpStatus = HttpStatus.BAD_REQUEST;
     ApiErrorDetails errorDetailsObj = ApiErrorDetails.builder().errorCode(httpStatus.name()).errorDescription("Error related to HTML")
           .errorDetails("Error related to HTML").build();
     ErrorDetails errorDetails = ErrorDetails.builder().errors(errorDetailsObj).build();
     return GenericException.builder().errorDetails(errorDetails).httpStatus(httpStatus).build();
 }).block();

目前onErrorMap（）每次都被调用，并覆盖我在onState（）内抛出的异常

Answer 1

找到了解决办法

IdVerificationResponse idVerificationResponse = client.get()
    .uri(processCheckUrl)
    .headers(headers -> headers.addAll(httpEntity.getHeaders()))
    .retrieve()
    .onStatus(HttpStatus::isError, response -> {
            HttpStatus errorCode = response.statusCode();
            return response.bodyToMono(IdVerificationErrorResponse.class)
                .onErrorMap(error -> new Exception("Throw your generic exception over here if there is any error in deserialization"))
                .flatMap(error -> Mono.error(new Exception("Throw your custom exception over here after successful deserialization")));
        })
    .bodyToMono(IdVerificationResponse.class).block();