自定义实现 redis key 序列化(serialize) 反序列化(deserialize)

系统管理员 2023-02-11 15:27 6阅读 0赞

## 使用FastJson序列化 ##

public class FastJsonRedisSerializer<T> implements RedisSerializer<T> { 
    
    
        private final Class<T> clazz;
    
        public FastJsonRedisSerializer(Class<T> clazz) { 
            super();
            this.clazz = clazz;
        }
    
        @Override
        public byte[] serialize(T t) throws SerializationException { 
            if (t == null) { 
                return new byte[0];
            }
            return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(Constant.DEFAULT_CHARSET);
        }
    
        @Override
        public T deserialize(byte[] bytes) throws SerializationException { 
            if (bytes == null || bytes.length <= 0) { 
                return null;
            }
            String str = new String(bytes, Constant.DEFAULT_CHARSET);
            return JSON.parseObject(str, clazz);
        }
    }

## Redis 配置 ##

import com.alibaba.fastjson.parser.ParserConfig;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.cache.RedisCacheConfiguration;
    import org.springframework.data.redis.cache.RedisCacheManager;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.RedisSerializationContext;
    import org.springframework.data.redis.serializer.StringRedisSerializer;
    
    import java.time.Duration;
    
    /** * Redis 配置 * * @author John * @date 2020/4/12 12:44 */
    @Configuration
    public class RedisConfig { 
    
        static { 
            // 使用Redis 配置替换fastjson 反序列化报错 com.alibaba.fastjson.JSONException: autoType is not support；
            // 在RedisSerializer<T>的实现类中添加白名单
            ParserConfig.getGlobalInstance().addAccept("john.duo.system.manage.entity");
        }
    
        @Bean(name = "redisTemplate")
        public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { 
            RedisTemplate<String, Object> template = new RedisTemplate<>();
            //使用fastjson序列化
            FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
            // value值的序列化采用fastJsonRedisSerializer
            template.setValueSerializer(fastJsonRedisSerializer);
            template.setHashValueSerializer(fastJsonRedisSerializer);
            // key的序列化采用StringRedisSerializer
            template.setKeySerializer(new StringRedisSerializer());
            template.setHashKeySerializer(new StringRedisSerializer());
            template.setConnectionFactory(redisConnectionFactory);
            return template;
        }
    
    
        @Bean
        public RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) { 
            FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
            RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMinutes(5L))
                    .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
                    .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(fastJsonRedisSerializer))
                    .disableCachingNullValues();
            return RedisCacheManager.builder(redisConnectionFactory).cacheDefaults(config).build();
        }
    
    }