【SpringBoot】五十、SpringBoot为Redis的key加上前缀

我不是女神ヾ 2022-09-04 07:50 162阅读 0赞

我们在实际的项目应用中，Redis一般都是用来缓存热点数据，一台服务器可能部署了多个应用，应用直接的 Redis 数据需要加上前缀区分开来，我们可以使用序列化的方式，统一为所有的 key 加上前缀

## 一、关于在 [SpringBoot 中整合 Redis][SpringBoot _ Redis] ##

https://lizhou.blog.csdn.net/article/details/98358258

## 二、关于在 [SpringBoot 中整合 Redis 实现序列化存储Java对象][SpringBoot _ Redis _Java] ##

https://lizhou.blog.csdn.net/article/details/109236398

## 三、基于第二步更改了 Redis 本身的序列化方式的基础上，我们可以自定义序列化的方式 ##

*  1、自定义序列化方式

package com.asurplus.common.redis;
    
    import com.asurplus.common.consts.SystemConst;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.data.redis.serializer.RedisSerializer;
    
    import java.nio.charset.Charset;
    
    /** * 为redis key 统一加上前缀 */
    @Slf4j
    public class RedisKeySerializer implements RedisSerializer<String> { 
    
        /** * 编码格式 */
        private final Charset charset;
    
        /** * 前缀 */
        private final String PREFIX_KEY = "prefix";
    
        public RedisKeySerializer() { 
            this(Charset.forName("UTF8"));
        }
    
        public RedisKeySerializer(Charset charset) { 
            this.charset = charset;
        }
    
        @Override
        public String deserialize(byte[] bytes) { 
            String saveKey = new String(bytes, charset);
            int indexOf = saveKey.indexOf(PREFIX_KEY + ":");
            if (indexOf > 0) { 
                log.error("key缺少前缀");
            } else { 
                saveKey = saveKey.substring(indexOf);
            }
            return (saveKey.getBytes() == null ? null : saveKey);
        }
    
        @Override
        public byte[] serialize(String string) { 
            String key = PREFIX_KEY + string;
            return (key == null ? null : key.getBytes(charset));
        }
    }

*  2、更改 key 的序列化方式

@Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { 
        // 配置redisTemplate
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        // 设置序列化
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // key序列化，使用自定义序列化方式
        redisTemplate.setKeySerializer(new RedisKeySerializer());
        // value序列化
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        // Hash key序列化，使用自定义序列化方式
        redisTemplate.setHashKeySerializer(new RedisKeySerializer());
        // Hash value序列化
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }

至此，我们就实现了为 Redis 的 key 统一加上前缀

如您在阅读中发现不足，欢迎留言！！！

[SpringBoot _ Redis]: https://lizhou.blog.csdn.net/article/details/98358258
[SpringBoot _ Redis _Java]: https://lizhou.blog.csdn.net/article/details/109236398