美文网首页
spring-boot Cache redis 类型转换错误

spring-boot Cache redis 类型转换错误

作者: keetone | 来源:发表于2020-11-25 21:36 被阅读0次

最近在使用spring-boot的Cache功能时,出现了一下奇葩问题
问题现象如下图:


error.png

很滑稽的一个问题,相同的类型还出现类型转换错误
项目中的使用情况如下:
缓存配置

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    @Resource
    private LettuceConnectionFactory lettuceConnectionFactory;

    @Bean
    @Override
    public KeyGenerator keyGenerator() {
        return (target, method, params) -> {
            StringBuffer sb = new StringBuffer();
            sb.append(target.getClass().getName());
            sb.append(method.getName());
            for (Object obj : params) {
                if (obj != null) {
                    sb.append(obj.toString());
                }
            }
            return sb.toString();
        };
    }

    /**
     * 缓存管理器
     *
     * @return
     */
    @Bean
    @Override
    public CacheManager cacheManager() {
        RedisCacheManager.RedisCacheManagerBuilder builder =
                RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(lettuceConnectionFactory);
        Map<String, RedisCacheConfiguration> configurationMap = getStringRedisCacheConfigurationMap();
        builder.withInitialCacheConfigurations(configurationMap);
        return builder.build();
    }

    /**
     * 不同的缓存可采用个性化的配置
     *
     * @return
     */
    private Map<String, RedisCacheConfiguration> getStringRedisCacheConfigurationMap() {
        Map<String, RedisCacheConfiguration> configurationMap = new HashMap<>();
        // 基本配置
        configurationMap.put("codeNameCache", RedisCacheConfiguration.defaultCacheConfig());
        configurationMap.put("baseStationData", RedisCacheConfiguration.defaultCacheConfig()
                // 不缓存null
                .disableCachingNullValues()
                // 监测测站数据很少变动,保存1天
                .entryTtl(Duration.ofHours(24)));
        return configurationMap;
    }
}

缓存使用

    @Cacheable(value = "baseStationData", unless = "#result == null")
    public List<T> query(String tableEnName, String whereCond, String queryFields) throws UnsupportedEncodingException {
        ......
    }

缓存使用场景

@lombok.Data
public class User implements Serializable{
  private String username;
  private Integer age;
}

public class Service{
    public List<User> getUsers(String... args){
        ......
        // 在这里调用上面的 query 方法,假设我这里的范型 T 是 User对象
        List<User> users = xxx.query("user","username='test'","username,age");
        for(User user : users){
            // 注意:就是这里,只要调用了user对象的任何方法,都会报错,类型转换错误,说 User connot be cast to User
            System.out.println(user.getAge()); 
        }
        ......
    }
}

我们把上面出错的地方单独拿出来

        for(User user : users){
            // 注意:就是这里,只要调用了user对象的任何方法,都会报错,类型转换错误,说 User connot be cast to User
            System.out.println(user.getAge()); 
        }

对于这个问题,网上也有人遇到过,但是都说什么是spring-boot devtools工具的问题,感觉挺扯的,我没用这个devtools工具,但是看网上分析的大致可以得出以下结论:
当cache将数据放入缓存时,使用了默认的序列化方式(JdkSerializationRedisSerializer),该序列化使用了二进制保存了对象的上下文ClassLoader,而由于devtools导致服务重启,然后重启后ClassLoad和原来的ClassLoader不是同一个对象了,所以导致对象的Class也不一样,虽然看上去都是User,但是它就是不同的类型,因为它的Class也不相等。
这个就太扯了,我把数据放到缓存中,然后服务器重启了下,再去查缓存就不能用了,那这个缓存有啥用。

解决方案
这个问题肯定是和序列化有关的,我们指定一下缓存value的序列化方式,使用json来序列化对象,配置类的改造如下:

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
    ......省略不变的代码
    /**
     * 不同的缓存可采用个性化的配置
     *
     * @return
     */
    private Map<String, RedisCacheConfiguration> getStringRedisCacheConfigurationMap() {
        Map<String, RedisCacheConfiguration> configurationMap = new HashMap<>();
        // 基本配置
        configurationMap.put("codeNameCache", RedisCacheConfiguration.defaultCacheConfig());
        configurationMap.put("baseStationData", RedisCacheConfiguration.defaultCacheConfig()
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer()))
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
                // 不缓存null
                .disableCachingNullValues()
                // 监测测站数据很少变动,保存1天
                .entryTtl(Duration.ofHours(24)));
        return configurationMap;
    }

    private Jackson2JsonRedisSerializer<Object> redisSerializer() {
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, Visibility.ANY);
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        return jackson2JsonRedisSerializer;
    }
}

再重启服务,缓存读取出来反序列化后的对象,可以正常使用。
搞定!!!

相关文章

网友评论

      本文标题:spring-boot Cache redis 类型转换错误

      本文链接:https://www.haomeiwen.com/subject/yzlniktx.html