SpringBoot如何配置Redis自定义过期时间操作

这篇文章主要介绍SpringBoot如何配置Redis自定义过期时间操作，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！

SpringBoot配置Redis自定义过期时间

Redis配置依赖

<dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-redis</artifactId>        <version>1.4.4.RELEASE</version>      </dependency>      <dependency>        <groupId>org.springframework.data</groupId>        <artifactId>spring-data-redis</artifactId>        <version>1.8.1.RELEASE</version>      </dependency>      <dependency>        <groupId>redis.clients</groupId>        <artifactId>jedis</artifactId>        <version>2.9.0</version></dependency>

SpringBoot-Reids配置文件

package com.regs.tms.common.redis;

@Configuration@EnableCaching// 启用缓存，这个注解很重要@ConfigurationProperties(prefix = "spring.redis")@Datapublic class RedisCacheConfig extends CachingConfigurerSupport {private String host;private Integer port;private Integer database;private String password;@Bean("redisTemplate")public RedisTemplate redisTemplate(RedisConnectionFactory factory) {    StringRedisTemplate template = new StringRedisTemplate();    template.setConnectionFactory(factory);    //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值    Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);    ObjectMapper mapper = new ObjectMapper();    mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);    mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);    serializer.setObjectMapper(mapper);    template.setValueSerializer(serializer);    template.setHashValueSerializer(serializer);    // 设置键（key）的序列化采用StringRedisSerializer。    template.setKeySerializer(new StringRedisSerializer());    template.setHashKeySerializer(new StringRedisSerializer());    //打开事务支持    template.setEnableTransactionSupport(true);    template.afterPropertiesSet();    return template;}@Beanpublic PlatformTransactionManager transactionManager(DataSource dataSource) throws SQLException {    //配置事务管理器    return new DataSourceTransactionManager(dataSource);}@Bean("stringRedisTemplate")public StringRedisTemplate stringRedisTemplate() {    Integer port = this.port == null ? 6379 : this.port;    JedisConnectionFactory jedis = new JedisConnectionFactory();    jedis.setHostName(host);    jedis.setPort(port);    if (StringUtils.isNotEmpty(password)) {        jedis.setPassword(password);    }    if (database != null) {        jedis.setDatabase(database);    } else {        jedis.setDatabase(0);    }    // 初始化连接pool    jedis.afterPropertiesSet();    // 获取连接template    StringRedisTemplate temple = new StringRedisTemplate();    temple.setConnectionFactory(jedis);    return temple;}}

自定义失效注解

package com.regs.tms.common.redis.annotation;

@Retention(RetentionPolicy.RUNTIME)@Target({ElementType.METHOD, ElementType.TYPE})public @interface CacheDuration {    //Sets the expire time (in seconds).    public long duration() default 60;}

自定义失效配置

package com.regs.tms.common.redis.annotation;

 public class RedisExpireCacheManager extends RedisCacheManager implements ApplicationContextAware, InitializingBean {    private ApplicationContext applicationContext;    public RedisExpireCacheManager(RedisTemplate redisTemplate) {        super(redisTemplate);    }    @Override    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {        this.applicationContext = applicationContext;    }    @Override    public void afterPropertiesSet() {        parseCacheExpire(applicationContext);    }    private void parseCacheExpire(ApplicationContext applicationContext) {        final Map<String, Long> cacheExpires = new HashMap<>(16);        //扫描有注解        String[] beanNames = applicationContext.getBeanNamesForAnnotation(Cacheable.class);        for (String beanName : beanNames) {            final Class clazz = applicationContext.getType(beanName);            addCacheExpires(clazz, cacheExpires);        }        //设置有效期        super.setExpires(cacheExpires);    }    private void addCacheExpires(final Class clazz, final Map<String, Long> cacheExpires) {        ReflectionUtils.doWithMethods(clazz, new ReflectionUtils.MethodCallback() {            @Override            public void doWith(Method method) throws IllegalArgumentException, IllegalAccessException {                ReflectionUtils.makeAccessible(method);                //根据CacheExpire注解获取时间                CacheExpire cacheExpire = findCacheExpire(clazz, method);                if (cacheExpire != null) {                    Cacheable cacheable = findAnnotation(method, Cacheable.class);                    String[] cacheNames = isEmpty(cacheable.value()) ? new String[]{} : cacheable.value();                    for (String cacheName : cacheNames) {                        cacheExpires.put(cacheName, cacheExpire.expire());                    }                }            }        }, new ReflectionUtils.MethodFilter() {            @Override            public boolean matches(Method method) {                return null != findAnnotation(method, Cacheable.class);            }        });    }        private CacheExpire findCacheExpire(Class clazz, Method method) {        CacheExpire methodCache = findAnnotation(method, CacheExpire.class);        if (null != methodCache) {            return methodCache;        }        CacheExpire classCache = findAnnotation(clazz, CacheExpire.class);        if (null != classCache) {            return classCache;        }        return null;    }}

spring boot 使用redis 超时时间重新设置

如果要计算每24小时的下单量，

通常的做法是，取出旧值，进行加一在设置回去，

但是这样就出现了一个问题

第二次设置值的时候，把超时时间重新设置成个24小时

这样无疑的记录24小时的数量是不准确的

并且spring boot 中，默认使用了spring 来操作redis ，使存在每个redis中的值，都会加前面加入一些东西

1) "\xac\xed\x00\x05t\x00\x0bREDISUALIST"

我们在查找每个值的时候，并不知道在key前面需要加点什么.

所以我们必须要用keys 这个命令 ，来匹配 我们需要查找的key，来取第一个

然后我们用 ttl 命令 返回指定key的剩余时间 ，重新设置回去，而不是设置24小时，这样就实现了24小时累加一次

在redisService 中，增加一个方法

    public Long ttlByKey(@NotNull String key){        Set<byte[]> keys = redisTemplate.getConnectionFactory().getConnection().keys(key.getBytes());        byte[] bytes = keys.stream().findFirst().get();        Long ttl = redisTemplate.getConnectionFactory().getConnection().ttl(bytes);        return ttl;    }

以上是“SpringBoot如何配置Redis自定义过期时间操作”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注编程网行业资讯频道！