SpringBoot 2.x 通过注解方式使用Redis

快来打我* 2024-04-11 11:48 76阅读 0赞

SpringBoot 2.x版本使用注解方式使用Redis与SpringBoot 1.x 有所改变，主要是类库有所不同。

Redis配置工具类如下

package com.test;
    
    import java.time.Duration;
    
    import org.springframework.cache.CacheManager;
    import org.springframework.cache.annotation.CachingConfigurerSupport;
    import org.springframework.cache.annotation.EnableCaching;
    import org.springframework.cache.interceptor.KeyGenerator;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.data.redis.cache.RedisCacheConfiguration;
    import org.springframework.data.redis.cache.RedisCacheManager;
    import org.springframework.data.redis.cache.RedisCacheWriter;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    import org.springframework.data.redis.serializer.StringRedisSerializer;
    
    import com.fasterxml.jackson.annotation.JsonAutoDetect;
    import com.fasterxml.jackson.annotation.PropertyAccessor;
    import com.fasterxml.jackson.databind.ObjectMapper;
    
    /**
     * 通过注解使用Redis内存服务器
     */
    @Configuration
    @EnableCaching
    public class RedisConfig extends CachingConfigurerSupport{
    
    	/**
    	* 生成Redis的键值，根据类名＋方法名＋参数值的形式
    	* @return
    	*/
        @Bean(name = "keyGenerator")
        public KeyGenerator keyGenerator() {
            return new KeyGenerator(){
                @Override
                public Object generate(Object target, java.lang.reflect.Method method, 
                        Object... params) {
                    StringBuffer sb = new StringBuffer();
                    sb.append(target.getClass().getName());
                    sb.append(method.getName());
                    for(Object obj:params){
                        if(obj != null)
                        {
                        	sb.append("_");
                            sb.append(obj.toString());
                        }
                    }
                    return sb.toString();
                }
            };
        }
    
        
        @SuppressWarnings("rawtypes")
        @Bean
        public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        	// 设置缓存有效期
        	RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofSeconds(10));
        	return RedisCacheManager
        	.builder(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory))
        	.cacheDefaults(redisCacheConfiguration).build();
    
        }
    
        @Bean
        @SuppressWarnings({"rawtypes", "unchecked"})
        public RedisTemplate<Object,Object> redisTemplate(RedisConnectionFactory connectionFactory){
            RedisTemplate<Object,Object> redisTemplate=new RedisTemplate<>();
            redisTemplate.setConnectionFactory(connectionFactory);
            //使用Jackson2JsonRedisSerializer替换默认的序列化规则
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer=new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper objectMapper=new ObjectMapper();
            objectMapper.setVisibility(PropertyAccessor.ALL,JsonAutoDetect.Visibility.ANY);
            objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
    
    
            //设置value的序列化规则
            redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
            //设置key的序列化规则
            redisTemplate.setKeySerializer(new StringRedisSerializer());
            redisTemplate.afterPropertiesSet();
            return redisTemplate;
        }
    
    
    	/**
    	 * 序列化Redis的键和值对象
    	* @param template
    	*/
        private void setSerializer(RedisTemplate template){
            @SuppressWarnings({ "rawtypes", "unchecked" })
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = 
                new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper om = new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(om);
            template.setValueSerializer(jackson2JsonRedisSerializer);
         }
    }