redis之监听redis key过期事件

超、凢脫俗 2023-10-01 20:05 3阅读 0赞

**目录**

1.创建springboot工程

2.导入redis依赖

3.创建RedisListenerConfig配置类

4.创建RedisKeyExpirationListener事件监听类

5.开启redis过期事件

6.redis设置一个key为user:id,value为1,过期时间为30秒

7.启动项目，测试

#### 1.创建springboot工程 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_19_color_FFFFFF_t_70_g_se_x_16][]

#### 2.导入redis依赖 ####

implementation 'org.springframework.boot:spring-boot-starter-data-redis'

#### 3.创建RedisListenerConfig配置类 ####

/**
     * @author zsx
     */
    @Configuration
    public class RedisListenerConfig {
    
        @Bean
        RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
    
            RedisMessageListenerContainer container = new RedisMessageListenerContainer();
            container.setConnectionFactory(connectionFactory);
            return container;
        }
    }

#### 4.创建RedisKeyExpirationListener事件监听类 ####

/**
     * @author zsx
     */
    @Component
    public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
    
        public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
            super(listenerContainer);
        }
    
        /**
         * 针对redis数据失效事件，进行数据处理
         * @param message
         * @param pattern
         */
        @Override
        public void onMessage(Message message, byte[] pattern) {
            // 这地方可以做自己的业务处理,message.toString()可以获取失效的key
            String expiredKey = message.toString();
            System.out.println("过期redis_key" + expiredKey);
        }
    }

整个工程结构如下图：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16][]

#### 5.开启redis过期事件 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

#### 6.redis设置一个key为user:id,value为1,过期时间为30秒 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

#### 7.启动项目，测试 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

结果：发现已经可以监听到过期的redis key了

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_19_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/e575b6a0967045d4a48f5286075befa1.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5pCs56CW6ICB5Yac5bel,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/0213a2f285b44a5486f883386c528990.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5pCs56CW6ICB5Yac5bel,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/15a3bb594e3541e482c6f06de5f41b04.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5pCs56CW6ICB5Yac5bel,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/3b79cf18970542bbac888d65fc372fbd.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5pCs56CW6ICB5Yac5bel,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5pCs56CW6ICB5Yac5bel_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/40654a061f3f4452968989719e63d775.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5pCs56CW6ICB5Yac5bel,size_20,color_FFFFFF,t_70,g_se,x_16