Spring WebFlux中WebClient调用返回401状态被包装为500，如何将401状态正确返回给用户？

我来帮你搞定这个问题！核心原因是：当外部权限接口返回401时，WebClient会抛出WebClientResponseException.Unauthorized异常，但这个异常没有被正确处理，导致你的全局异常处理器把它识别成了服务器内部错误（500），而不是直接将401状态返回给客户端。

解决方案：在AuthWebClient中针对性处理401异常 #

我们需要在AuthWebClient.getAuthorities()方法里，捕获WebClient抛出的401异常，并将其转换为Spring能识别的ResponseStatusException，这样就能让框架返回正确的HTTP状态码给用户。

修改后的AuthWebClient代码如下：

@Service
@Slf4j
public class AuthWebClient {
    @Autowired
    private WebClient webClient;

    public Mono<Authorities> getAuthorities(String subject, String auth) {
        URI uri = UriComponentsBuilder.fromUriString(-someUrl-).toUri();
        Authorities authoritiesRequest = Authorities.builder().includePermissions(true).build();
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", auth);
        
        return webClient.post()
                .uri(uri)
                .headers(httpHeaders -> httpHeaders.addAll(headers))
                .body(BodyInserters.fromValue(authoritiesRequest))
                .accept(MediaType.APPLICATION_JSON)
                .retrieve()
                // 新增：处理4xx客户端错误，重点捕获401
                .onStatus(HttpStatus::is4xxClientError, clientResponse -> {
                    if (HttpStatus.UNAUTHORIZED.equals(clientResponse.statusCode())) {
                        // 直接抛出401的ResponseStatusException
                        return Mono.error(new ResponseStatusException(HttpStatus.UNAUTHORIZED, "Unauthorized access to permission service"));
                    }
                    // 其他4xx错误可以根据业务需求处理，这里默认抛出原异常
                    return clientResponse.createException().flatMap(Mono::error);
                })
                .bodyToMono(AuthoritiesResponse.class);
    }
}

为什么这样修改？ #

• onStatus方法：专门用来拦截特定状态码的响应，我们在这里捕获所有4xx客户端错误，重点处理401。
• 转换为ResponseStatusException：Spring的异常处理机制会识别这个异常，并直接返回对应的HTTP状态码（这里是401），而不会将其包装成500内部错误。
• 其他4xx处理：如果外部接口返回其他客户端错误（比如403），你可以在这里添加对应的处理逻辑，保持异常处理的精准性。

额外优化建议 #

如果你希望更通用地处理所有WebClient的异常，可以在全局异常处理器中添加对WebClientResponseException的处理：

@RestControllerAdvice
public class GlobalExceptionHandler {

    @ExceptionHandler(WebClientResponseException.class)
    public ResponseEntity<String> handleWebClientException(WebClientResponseException ex) {
        return ResponseEntity.status(ex.getStatusCode()).body(ex.getResponseBodyAsString());
    }
}

但优先推荐在AuthWebClient中针对性处理，这样可以针对不同的外部接口调用做差异化的异常处理。

内容的提问来源于stack exchange，提问作者Rahul verma