码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • Java Spring Redis实现过期键监听回调


    1、开启redis键过期监听

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

    • Linux操作系统
      • 修改redis安装目录下的redis.conf配置文件,然后找到notify-keyspace-events Ex这行代码,默认是注释掉的,取消注释即可(即删除掉前面的#)。
      • 也有一种情况是没有这一行的,这种情况下直接把这一行添加上去即可。
      • 然后重启redis。
    • windows操作系统
      • 在安装目录下找到redis.windows.conf和redis.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实现的一种思路,如果更好的解决办法,欢迎在评论区留言赐教。

  • 相关阅读:
    FPGA+ARM异核架构,基于米尔MYC-JX8MMA7核心板的全自动血细胞分析仪
    连接虚拟机报错 Could not connect to ‘192.168.xxx.xxx‘ (port 22): Connection failed.
    程序化交易是科学和艺术的结合
    MYSQL之压测
    基于SpringBoot的单应用项目模板(考虑到后期做微服务,内部已经做了拆分)
    从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(六)(优化篇)开发篇-如何解决微服务开发环境请求实例转发到别人机器问题
    Socks5代理IP:网络安全的重要组成部分
    《向量数据库指南》——LlamaIndex 和 Milvus Cloud对于 Chat Towards Data Science 的作用
    剑指offer56 数组中只出现一次的两个数字
    antv-G6知识图谱安装--使用(实例)--连接线修改成动态,并添加跟随线移动的光圈,设置分支跟踪定位功能
  • 原文地址:https://blog.csdn.net/qq_42376617/article/details/126498517
  • 最新文章
  • 沪漂五周年了:我越来越迷茫了
    Agentic Skill Routing 实战:别再把所有 Skill 塞进 AI Agent 上下文
    MySQL-Seconds_behind_master的精度误差
    [MAF预定义ChatClient中间件-03]CachingChatClient——利用缓存省钱省时间
    AI的至暗历史:从万众期待到被政府撤资,AI的两次死亡徘徊
    Agent OS :五种驯服不确定性的范式
    PortSwigger SQL注入LAB11
    数据库即时编译JIT
    [Begin]AI Learn Data Day 0
    深度学习进阶(二十七)现代 LLM 的核心架构设计其二:SwiGLU
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
小工具 小游戏
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

京公网安备 11010502049817号