将Spring WebClient错误响应体从字符串转换为Java POJO对象

核心处理逻辑 #

在Spring WebFlux场景下，要将错误响应的字符串转为POJO，关键是在错误处理流程中完成正确的反序列化，而非简单替换泛型类型。

具体实现方式 #

方式1：WebClient错误分支直接解析为POJO #

如果是通过WebClient发起请求，在错误状态处理时直接指定目标POJO类型进行解析：

webClient.post()
    .uri("/target-api")
    .bodyValue(requestPayload)
    .retrieve()
    .onStatus(HttpStatus::isError, clientResponse -> 
        // 直接将响应体解析为ErrorPOJO
        clientResponse.bodyToMono(ErrorPOJO.class)
            .flatMap(errorPojo -> Mono.error(new BusinessException(errorPojo.getCode(), errorPojo.getMsg())))
    )
    .bodyToMono(SuccessPOJO.class);

方式2：手动反序列化已获取的字符串 #

如果已经拿到字符串格式的msg，用Jackson的ObjectMapper手动转换：

// 假设msg是错误响应的JSON字符串
ObjectMapper objectMapper = new ObjectMapper();
try {
    ErrorPOJO errorPojo = objectMapper.readValue(msg, ErrorPOJO.class);
    // 基于errorPojo做后续业务处理
} catch (JsonProcessingException e) {
    return Mono.error(new RuntimeException("解析错误响应失败", e));
}

关键注意点 #

• 确保POJO类的字段与错误响应的JSON结构完全匹配，字段名不一致时用@JsonProperty指定映射关系。
• 若替换Mono<String>为Mono<POJO>未生效，检查响应的Content-Type是否为application/json，若不是，可强制指定解析类型：

clientResponse.bodyToMono(new ParameterizedTypeReference<ErrorPOJO>() {})

• 确认WebClient的解码器配置正常，Jackson的Jackson2JsonDecoder已被正确注册到CodecConfigurer中。

内容的提问来源于stack exchange，提问作者Shruti Mishra