springboot2 redis缓存配置Jackson2JsonRedisSerializer和使用object.class时反序列化出现LinkedHashMap cannot be cas...

前言

最近在学习springboot的整合视频，在整合redis作为cache时序列化为json格式时，由于视频上讲述的是springboot1的修改方式，而springboot2在这部分有了较大的修改。在网上我查到的基本上大多是自己配置一个CacheManager来替换springboot默认的。但这样做就相当于把springboot默认的配置全部替换掉了。包括CacheManagerCustomizers和CacheProperties。但我只是想修改成json格式序列化而已，没必要改动其他的内容。

查看源码

最初我准备把官方的RedisCacheConfiguration中的RedisCacheManager配置源码全部复制过来，只修改序列化规则。在修改过程中发现源码中ObjectProvider这个接口多次出现，在经过百度后大致认为在springboot自动注入参数时，如果IOC容器中不存在这个bean是会报错的。使用ObjectProvider则允许参数为空。

查看cacheManager()函数

    @Bean
    RedisCacheManager cacheManager(CacheProperties cacheProperties, CacheManagerCustomizers cacheManagerCustomizers,
            ObjectProvider<org.springframework.data.redis.cache.RedisCacheConfiguration> redisCacheConfiguration,
            ObjectProvider<RedisCacheManagerBuilderCustomizer> redisCacheManagerBuilderCustomizers,
            RedisConnectionFactory redisConnectionFactory, ResourceLoader resourceLoader) {
        //创建RedisCacheManagerBuilder
        RedisCacheManagerBuilder builder = RedisCacheManager.builder(redisConnectionFactory).cacheDefaults(
                determineConfiguration(cacheProperties, redisCacheConfiguration, resourceLoader.getClassLoader()));
        List<String> cacheNames = cacheProperties.getCacheNames();
        if (!cacheNames.isEmpty()) {
            builder.initialCacheNames(new LinkedHashSet<>(cacheNames));
        }
        redisCacheManagerBuilderCustomizers.orderedStream().forEach((customizer) -> customizer.customize(builder));
        return cacheManagerCustomizers.customize(builder.build());
    }

首先可以确定的是官方默认的cacheManager便是由这个函数创建的。在创建RedisCacheManagerBuilder的时候设置的cacheDefaults是通过determineConfiguration()这个函数得到的。

查看determineConfiguration()函数

    private org.springframework.data.redis.cache.RedisCacheConfiguration determineConfiguration(
            CacheProperties cacheProperties,
            ObjectProvider<org.springframework.data.redis.cache.RedisCacheConfiguration> redisCacheConfiguration,
            ClassLoader classLoader) {
        return redisCacheConfiguration.getIfAvailable(() -> createConfiguration(cacheProperties, classLoader));
    }

可以看到这里的redisCacheConfiguration就是一个ObjectProvider接口，而这个函数本体只有一行内容

return redisCacheConfiguration.getIfAvailable(() -> createConfiguration(cacheProperties, classLoader));

而这个返回值是由ObjectProvider接口的getIfAvailable()函数产生的。点开getIfAvailable()函数

    default T getIfAvailable(Supplier<T> defaultSupplier) throws BeansException {
        T dependency = this.getIfAvailable();
        return dependency != null ? dependency : defaultSupplier.get();
    }

通过内容大致推测为如果自动注入时容器中本身就存在这个泛型的bean则返回这个bean，否则则返回参数生成的bean。而参数() -> createConfiguration(cacheProperties, classLoader)调用的createConfiguration则是springboot默认创建的RedisCacheConfiguration。而序列化等配置信息就是通过这个createConfiguration来调整的。

推测

那么是否我在config中自定义一个RedisCacheConfiguration放入容器即可修改序列化方式呢？

于是我将createConfiguration的代码复制并进行修改

@Configuration
public class MyRedisConfig {
    @Bean
    RedisCacheConfiguration myConfiguration(
            CacheProperties cacheProperties) {
        CacheProperties.Redis redisProperties = cacheProperties.getRedis();
        RedisCacheConfiguration config = RedisCacheConfiguration
                .defaultCacheConfig();
        //将原本的JdkSerializationRedisSerializer修改为Jackson2JsonRedisSerializer
        Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);
        config = config.serializeValuesWith(
                RedisSerializationContext.SerializationPair.fromSerializer(serializer));
        if (redisProperties.getTimeToLive() != null) {
            config = config.entryTtl(redisProperties.getTimeToLive());
        }
        if (redisProperties.getKeyPrefix() != null) {
            config = config.prefixCacheNameWith(redisProperties.getKeyPrefix());
        }
        if (!redisProperties.isCacheNullValues()) {
            config = config.disableCachingNullValues();
        }
        if (!redisProperties.isUseKeyPrefix()) {
            config = config.disableKeyPrefix();
        }
        return config;
    }
}

启动项目

进行查询，查看redis

果然成功了！！

踩坑

但是，当我再次刷新时发生了错误LinkedHashMap cannot be cast to。再次面向百度编程后了解到，由于我定义的是object.class作为转换。并没有给定具体的对象，所以在反序列化时，被转换成了LinkedHashMap。设置属性DefaultTyping.NON_FINAL后问题解决了。

        Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);
        //序列化时添加对象信息
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.activateDefaultTyping(objectMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(objectMapper);
        config = config.serializeValuesWith(
                RedisSerializationContext.SerializationPair.fromSerializer(serializer));

清空redis并重启项目

再次进行查询，并查看redis

数据变成了这种格式。

刷新多次进行查询。除了第一次经过了数据库后其他几次都是通过缓存，问题解决。