springboot2 redis緩存配置Jackson2JsonRedisSerializer和使用object.class時(shí)反序列化出現(xiàn)LinkedHashMap cannot be cas...

前言

最近在學(xué)習(xí)springboot的整合視頻，在整合redis作為cache時(shí)序列化為json格式時(shí)，由于視頻上講述的是springboot1的修改方式毛仪，而springboot2在這部分有了較大的修改排嫌。在網(wǎng)上我查到的基本上大多是自己配置一個CacheManager來替換springboot默認(rèn)的。但這樣做就相當(dāng)于把springboot默認(rèn)的配置全部替換掉了仿吞。包括CacheManagerCustomizers和CacheProperties滑频。但我只是想修改成json格式序列化而已，沒必要改動其他的內(nèi)容唤冈。

查看源碼

最初我準(zhǔn)備把官方的RedisCacheConfiguration中的RedisCacheManager配置源碼全部復(fù)制過來峡迷，只修改序列化規(guī)則。在修改過程中發(fā)現(xiàn)源碼中ObjectProvider這個接口多次出現(xiàn)你虹，在經(jīng)過百度后大致認(rèn)為在springboot自動注入?yún)?shù)時(shí)绘搞，如果IOC容器中不存在這個bean是會報(bào)錯的。使用ObjectProvider則允許參數(shù)為空傅物。

查看cacheManager()函數(shù)

    @Bean
    RedisCacheManager cacheManager(CacheProperties cacheProperties, CacheManagerCustomizers cacheManagerCustomizers,
            ObjectProvider<org.springframework.data.redis.cache.RedisCacheConfiguration> redisCacheConfiguration,
            ObjectProvider<RedisCacheManagerBuilderCustomizer> redisCacheManagerBuilderCustomizers,
            RedisConnectionFactory redisConnectionFactory, ResourceLoader resourceLoader) {
        //創(chuàng)建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());
    }

首先可以確定的是官方默認(rèn)的cacheManager便是由這個函數(shù)創(chuàng)建的看杭。在創(chuàng)建RedisCacheManagerBuilder的時(shí)候設(shè)置的cacheDefaults是通過determineConfiguration()這個函數(shù)得到的。

查看determineConfiguration()函數(shù)

    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接口挟伙，而這個函數(shù)本體只有一行內(nèi)容

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

而這個返回值是由ObjectProvider接口的getIfAvailable()函數(shù)產(chǎn)生的楼雹。點(diǎn)開getIfAvailable()函數(shù)

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

通過內(nèi)容大致推測為如果自動注入時(shí)容器中本身就存在這個泛型的bean則返回這個bean，否則則返回參數(shù)生成的bean尖阔。而參數(shù)() -> createConfiguration(cacheProperties, classLoader)調(diào)用的createConfiguration則是springboot默認(rèn)創(chuàng)建的RedisCacheConfiguration贮缅。而序列化等配置信息就是通過這個createConfiguration來調(diào)整的。

推測

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

于是我將createConfiguration的代碼復(fù)制并進(jìn)行修改

@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;
    }
}

啟動項(xiàng)目

進(jìn)行查詢谴供，查看redis

果然成功了！齿坷！

踩坑

但是桂肌，當(dāng)我再次刷新時(shí)發(fā)生了錯誤LinkedHashMap cannot be cast to。再次面向百度編程后了解到永淌，由于我定義的是object.class作為轉(zhuǎn)換崎场。并沒有給定具體的對象，所以在反序列化時(shí)遂蛀，被轉(zhuǎn)換成了LinkedHashMap谭跨。設(shè)置屬性DefaultTyping.NON_FINAL后問題解決了。

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

清空redis并重啟項(xiàng)目

再次進(jìn)行查詢，并查看redis

數(shù)據(jù)變成了這種格式螃宙。

刷新多次進(jìn)行查詢蛮瞄。除了第一次經(jīng)過了數(shù)據(jù)庫后其他幾次都是通過緩存，問題解決谆扎。