使用WebClient自定义响应时遇异常，返回error为null

1. 检查Error实体类定义 #

确保实体类符合Jackson反序列化要求：

• 字段名与响应中的error严格匹配（注意大小写，JSON键为小写error时，实体类字段需对应为error而非Error）
• 有无参构造函数（Jackson默认依赖无参构造完成实例化）
• 提供getter/setter方法，或用@Data（Lombok）注解简化
• 若error是嵌套对象类型，嵌套类同样要满足序列化规则，确保null值能被正常映射

示例实体类：

import lombok.Data;

@Data
public class ApiResponse {
    // 直接对应响应根节点的error字段
    private Error error;

    @Data
    public static class Error {
        private String code;
        private String message;
        // 按API预期响应添加其他字段
    }
}

2. 配置WebClient的消息转换器 #

默认WebClient的Jackson配置可能不兼容null值映射，需显式调整：

• 开启ACCEPT_NULL_FOR_PRIMITIVES（若Error类含基本类型字段，需改用包装类，比如Integer替代int）
• 关闭FAIL_ON_UNKNOWN_PROPERTIES，避免API返回额外字段导致反序列化失败

示例WebClient配置：

import org.springframework.http.codec.json.Jackson2JsonDecoder;
import org.springframework.web.reactive.function.client.WebClient;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;

ObjectMapper objectMapper = new ObjectMapper();
objectMapper.configure(DeserializationFeature.ACCEPT_NULL_FOR_PRIMITIVES, true);
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);

WebClient webClient = WebClient.builder()
        .codecs(configurer -> {
            configurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(objectMapper));
        })
        .baseUrl("http://x.x.x.x:8085")
        .build();

3. 确认响应媒体类型 #

确保API返回的Content-Type为application/json，请求时显式指定接受JSON格式：

webClient.post()
        .uri("/campaign/syncapi")
        .contentType(MediaType.APPLICATION_JSON)
        .accept(MediaType.APPLICATION_JSON)
        .bodyValue(yourRequestBody)
        .retrieve()
        .bodyToMono(ApiResponse.class)
        .subscribe(response -> {
            Error error = response.getError();
            // 即使error为null也能正常获取
        });

4. 调试原始响应内容 #

若以上步骤无效，先将响应转为字符串，排查是否存在格式异常：

webClient.post()
        .uri("/campaign/syncapi")
        .contentType(MediaType.APPLICATION_JSON)
        .bodyValue(yourRequestBody)
        .retrieve()
        .bodyToMono(String.class)
        .subscribe(rawResponse -> {
            System.out.println("原始响应：" + rawResponse);
            // 手动反序列化验证
            try {
                ApiResponse response = objectMapper.readValue(rawResponse, ApiResponse.class);
                System.out.println("映射后的error：" + response.getError());
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

内容的提问来源于stack exchange，提问作者Thắm Vũ