跨越命名风格的鸿沟：破解Spring Data Redis中的JSON反序列化异常

2025-08-22 13:20:58 [pool-3-thread-2] ERROR ... - 处理省市队列异常
org.springframework.data.redis.serializer.SerializationException: Could not read JSON: Unrecognized field "public_ip" (class com.phone.entity.CustomerOrder), not marked as ignorable (21 known properties: "taskId", "cookie", "userId", ... "publicIp", ...])
 ...
Caused by: com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "public_ip" (class com.phone.entity.CustomerOrder) ...
 at [Source: (byte[])... "public_ip":null, ...]; (through reference chain: com.phone.entity.CustomerOrder["public_ip"])

package com.phone.entity;

import com.fasterxml.jackson.annotation.JsonProperty;
import javax.persistence.*;
import java.time.LocalDateTime;

public class CustomerOrder {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private Long userId;
    private Long taskId;
    private String customerName;
    private String trackingNumber;
    private String orderNumber;

    // ... 其他字段 ...

    // 使用@JsonProperty注解解决命名差异
    @JsonProperty("public_ip") // 关键注解：指定JSON字段名为"public_ip"
    private String publicIp; // Java字段名仍为驼峰式的publicIp

    private String matchType;
    private String matchStatus;

    // ... getter 和 setter 方法 ...

    public String getPublicIp() {
        return publicIp;
    }

    public void setPublicIp(String publicIp) {
        this.publicIp = publicIp;
    }

    // ... 其他getter和setter ...
}

package com.phone.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfig {

    /
     * 自定义RedisTemplate，配置使用Jackson序列化器并忽略未知字段
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);

        // 使用Jackson2JsonRedisSerializer来序列化value
        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper objectMapper = new ObjectMapper();

        // 核心配置：禁用失败于未知属性
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        
        // 可选配置：设置字段可见性
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 可选配置：激活默认类型信息，用于正确反序列化复杂对象类型
        // objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);

        serializer.setObjectMapper(objectMapper);

        // 使用StringRedisSerializer来序列化key
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(serializer);
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(serializer);

        template.afterPropertiesSet();
        return template;
    }
}

// 如果写入方配置了蛇形命名策略
objectMapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);