美文网首页
SpringCache+redis 设置过期时间

SpringCache+redis 设置过期时间

作者: 台风口的猪 | 来源:发表于2019-11-28 16:11 被阅读0次

    Spring自带缓存

    如果没有使用缓存中间件,Spring Boot会使用默认的缓存,只需要启用即可
    

    自带缓存启用注解

     @EnableCaching
    

    缓存配置详解

      //用在类上
      @CacheConfig(cacheNames = "bank")  用在类上,方法中则可以省略cacheNames 配置
     // 用在方法上
      @Cacheable: 先判断有没有缓存,有就取缓存,否则查库后再存入缓存,一般用在get 方法上(不支持设置缓存时间)
      @CachePut: 操作后结果存入缓存    ,一般用在update上
      @CacheEvict: 清除缓存  ,一般用在delete
      @Caching  多个Cache组合使用
    
            @Caching(
                put = {
                        @CachePut(value = "bank",key="#bank.bankId"),
                        @CachePut(value = "bank",key="#bank.bankNo")
                      }
            ) 
            public BankVO save(){}
    
    
      自定义缓存注解(@Caching组合,会让方法上的注解显得整个代码比较乱)
           @Caching(
                put = {
                        @CachePut(value = "bank",key="#bank.bankId"),
                        @CachePut(value = "bank",key="#bank.bankNo")
                      }
            ) 
           @Target({ElementType.METHOD, ElementType.TYPE})
           @Retention(RetentionPolicy.RUNTIME)
           @Inherited
           public @interface UserSaveCache {
    
           }
    
    
           value/cacheNames  缓存的名字,必须指定至少一个, 也可以放在CacheConfig()中
           key   缓存的key,可以为空,如果指定要按照SpEl表达式编写,如果不指定,则按照所有参数进行组合
           condition     缓存的条件,可以为空,使用SpEL编写,返回true、false,只有为true才进行缓存
          
           allEntries   是否清空所有缓存内容,默认为false,如果指定为true,则方法调用后立即清空所有缓存
           beforeInvocation   是否在方法执行前就清空,默认为false(如果抛了异常则不会清空缓存),如果指定为true,则在方法还没有执行的时候就清空缓存
    

    以下是相关代码

    @Configuration
    @EnableCaching //开启缓存,如果没有使用缓存中间件会使用Spring自带的缓存,否则使用中间件缓存,这里就会使用redis缓存中间件
    public class CacheConfig  {
        @Bean
        public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
            RedisTemplate<String, Object> template = new RedisTemplate<>();
            template.setConnectionFactory(connectionFactory);
            RedisSerializer jackson2JsonRedisSerializer = jsonSerializer();
            StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
            // key采用String的序列化方式
            template.setKeySerializer(stringRedisSerializer);
            // hash的key也采用String的序列化方式
            template.setHashKeySerializer(stringRedisSerializer);
            // value序列化方式采用jackson
            template.setValueSerializer(jackson2JsonRedisSerializer);
            // hash的value序列化方式采用jackson
            template.setHashValueSerializer(jackson2JsonRedisSerializer);
            template.afterPropertiesSet();
            return template;
        }
    
        /**
         * RedisTemplate默认使用的序列化机制是JdkSerializationRedisSerializer,这里我们是用Jackson2JsonRedisSerializer
         * @return
         */
        private RedisSerializer jsonSerializer() {
            Jackson2JsonRedisSerializer<Object> 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);
            return jackson2JsonRedisSerializer;
        }
    
        @Bean
        public RedisUtil redisUtils(RedisTemplate<String, Object> template) {
            return new RedisUtil(template);
        }
    
        /**
         * key的生成策略()
         * @return
         */
        @Bean
        public KeyGenerator simpleKeyGenerator() {
            return (o, method, objects) -> {
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.append(o.getClass().getSimpleName());
                stringBuilder.append(".");
                stringBuilder.append(method.getName());
                stringBuilder.append("[");
                for (Object obj : objects) {
                    stringBuilder.append(obj.toString());
                }
                stringBuilder.append("]");
    
                return stringBuilder.toString();
            };
        }
    
    /********************以下代码解决@Cacheable不支持设置缓存过期的问题**************************/
        /**
         * 
         * @param redisConnectionFactory
         * @return
         */
        @Bean
        public CacheManager cacheManager(RedisConnectionFactory  redisConnectionFactory) {
            return new RedisCacheManager(
                    RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory),
                    this.getRedisCacheConfigurationWithTtl(600),//默认策略,为配置的key会使用这个
                    this.getRedisCacheConfigurationMap() //指定key策略
            );
        }
    
        private Map<String, RedisCacheConfiguration> getRedisCacheConfigurationMap() {
            Map<String, RedisCacheConfiguration> redisCacheConfigurationMap = new HashMap<>();
            // 需要作缓存在这里加上就加一个put即可
            redisCacheConfigurationMap.put("bankId", this.getRedisCacheConfigurationWithTtl(120)); // 120秒后失效
            return redisCacheConfigurationMap;
        }
    
        private RedisCacheConfiguration getRedisCacheConfigurationWithTtl(Integer seconds) {
            RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig();
            redisCacheConfiguration = redisCacheConfiguration.serializeValuesWith(
                    RedisSerializationContext.SerializationPair.fromSerializer(jsonSerializer())
            ).entryTtl(Duration.ofSeconds(seconds));
    
            return redisCacheConfiguration;
        }
    }
    
    

    业务代码中使用

    @Service
    // @CacheConfig(cacheNames = "bank") //如果使用该注解,方法中则可以省略cacheNames /value 配置
    @Slf4j
    public class BankServiceImpl implements IBankService {
    @Cacheable(value = "bankId",keyGenerator = "simpleKeyGenerator")
     public BankVO getBank(Long bankId) {
            log.info("获取用户银行卡,{}",bankId);
            BankVO bankVO = new BankVO();
            UserBank bank = bankDomain.getBank(bankId);
            if(null != bank){
                BeanUtils.copyProperties(bank,bankVO);
            }
            return bankVO;
        }
    }
    
    

    相关文章

      网友评论

          本文标题:SpringCache+redis 设置过期时间

          本文链接:https://www.haomeiwen.com/subject/dfmbwctx.html