• Java Spring Redis实现过期键监听回调


    1、开启redis键过期监听

    redis默认是没有开启键过期监听功能的,需要手动在配置文件中修改。

    • Linux操作系统
      • 修改redis安装目录下的redis.conf配置文件,然后找到notify-keyspace-events Ex这行代码,默认是注释掉的,取消注释即可(即删除掉前面的#)。
      • 也有一种情况是没有这一行的,这种情况下直接把这一行添加上去即可。
      • 然后重启redis。
    • windows操作系统
      • 在安装目录下找到redis.windows.confredis.windows-service.conf两个文件,然后分别修改这两个文件中的notify-keyspace-events Ex字段,取消注释即可。
      • 然后重启redis,Windows重启命令为redis-server.exe --service-start

    2、Java代码实现监听回调

    2.1、添加redis键过期监听配置

     
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.listener.RedisMessageListenerContainer;
    
    @Configuration
    public class RedisListenerConfig {
        @Bean
        RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
            RedisMessageListenerContainer container = new RedisMessageListenerContainer();
            container.setConnectionFactory(connectionFactory);
            return container;
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    2.2、建立监听类

    @Component
    public class KeyExpiredListener extends KeyExpirationEventMessageListener {
    
        @Autowired
        private ClientLogCacheProcessor clientLogCacheProcessor;
        @Autowired
        private RedisUtils redisUtils;
        @Autowired
        private ISettingService settingService;
    
        public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
            super(listenerContainer);
        }
    
        @Override
        public void onMessage(Message message, byte[] pattern) {
            try {
                //过期的key
                String key = new String(message.getBody(), StandardCharsets.UTF_8);
    			// 对key进行判断,当redis中的key过期时会在这里调用
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22

    3、获取过期key的value

    刚开始监听key过期的时候,以为是可以拿到这个可以对应的value的。但是在操作过程中发现获取到的value是null。

    这里提供一种解决思路是:在存入这个key的时候紧接着存入一个备份键,相当于给这个key命一个别名,然后把这个value存入到这两个key中,需要监听的这个key设置过期时间,备份键则不设置过期时间。

    当key过期后触发回调方法,则工具这个过期的key来获取这个key的备份键,这样就可以实现拿到过期键的value了。拿到value后手动删除掉这个备份键。

    以上就是实现获取过期键的value的思路,当然这只是针对数据较小,且不频繁变化的value实现的一种思路,如果更好的解决办法,欢迎在评论区留言赐教。

  • 相关阅读:
    【Java基础面试十四】、 封装的目的是什么,为什么要有封装?
    「Vue系列」欢迎传送到“Teleport”星球
    OpenMMLab之Registry机制
    springboot项目打包部署到阿里云windows服务器全过程记录
    【Audio音频开发】音频基础知识及PCM技术详解
    语文世界杂志语文世界杂志社语文世界编辑部2022年第9期目录
    Linux(一)Linux理论、Shell
    Git学习1
    汽车疲劳测试试验平台技术要求(北重厂家)
    【CMU15-445 Part-9】Multi-Threaded Index Concurrency Control
  • 原文地址:https://blog.csdn.net/qq_42376617/article/details/126498517