SpringBoot对缓存技术的支持-自定义RedisTemplate

悠悠 2022-11-21 15:19 176阅读 0赞

RedisTemplate默认序列化方式为JdkSerializationRedisSerializer，这样会导致序列化后的数据在客户端看不懂，如果要设置为json，就需要自定义RedisTemplate，并设置为json序列化方式

@Configuration
    public class RedisConfig {
        @Bean
        public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory
                                                                   redisConnectionFactory) {
            RedisTemplate<Object, Object> template = new RedisTemplate();
            template.setConnectionFactory(redisConnectionFactory);
    		// 使用JSON格式序列化对象，对缓存数据key和value进行转换
            Jackson2JsonRedisSerializer jacksonSeial = new
                    Jackson2JsonRedisSerializer(Object.class);
    		// 解决查询缓存转换异常的问题
            ObjectMapper om = new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jacksonSeial.setObjectMapper(om);
    		// 设置RedisTemplate模板API的序列化方式为JSON
            template.setDefaultSerializer(jacksonSeial);
            return template;
        }
    }

以上这种方式只能对redisAPI的方式生效，注解方式需要定义另一种方式，这两种改造都是基于springboot源码进行的

@Bean
        public RedisCacheManager cacheManager(RedisConnectionFactory
                                                      redisConnectionFactory) {
    		// 分别创建String和JSON格式序列化对象，对缓存数据key和value进行转换
            RedisSerializer<String> strSerializer = new StringRedisSerializer();
            Jackson2JsonRedisSerializer jacksonSeial =
                    new Jackson2JsonRedisSerializer(Object.class);
    		// 解决查询缓存转换异常的问题
            ObjectMapper om = new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jacksonSeial.setObjectMapper(om);
    		// 定制缓存数据序列化方式及时效
            RedisCacheConfiguration config =
                    RedisCacheConfiguration.defaultCacheConfig()
                            .entryTtl(Duration.ofDays(1))
                            .serializeKeysWith(RedisSerializationContext.SerializationPair
                                    .fromSerializer(strSerializer))
                            .serializeValuesWith(RedisSerializationContext.SerializationPair
                                    .fromSerializer(jacksonSeial))
                            .disableCachingNullValues();
            RedisCacheManager cacheManager = RedisCacheManager
                    .builder(redisConnectionFactory).cacheDefaults(config).build();
            return cacheManager;
        }