Redis过期回调 | 整合Spring-redis实现延迟队列

痛定思痛。 2022-10-29 07:52 304阅读 0赞

#### 前言 ####

使用Redis回调功能，需要在Redis.conf配置文件中将**notify-keyspace-events Ex**开启

![1612865790344][]

将前面的注释’\#'去掉即可

#### 结合Spring-Redis实现 ####

引入spring boot整合redis依赖

<dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-data-redis</artifactId>
     </dependency>

在spring-data-redis中提供了KeyExpirationEventMessageListener监听器。

若想实现监听key过期可以直接继承KeyExpirationEventMessageListener并重写onMessage方法实现

@Component
    public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
        
    
        public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        
            super(listenerContainer);
        }
    
        @Override
        public void onMessage(Message message, byte[] pattern) {
        
            String expiredKey = message.toString();
            System.out.println("监听到key：" + expiredKey + "已过期");
        }
    }

可在onMessage方法中，对传入的过期key进行不同的回调逻辑操作。

考虑到KeyExpirationEventMessageListener 实际只有一个带RedisMessageListenerContainer参数的构造器，所以我们需要注入RedisMessageListenerContainer

@Configuration
    public class RedisListenerConfig {
        
        @Bean
        RedisMessageListenerContainer getContainer(RedisConnectionFactory redisConnectionFactory)
        {
        
            RedisMessageListenerContainer container = new RedisMessageListenerContainer();
            container.setConnectionFactory(redisConnectionFactory);
            return container;
        }
    }

可以直接在Redis客户端设置过期键值对

![1612869298564][]

可以在控制台看到，监听到key过期事件

![1612869423598][]

为便于测试，也可以编写Controller用于Get请求传KV键值对

@GetMapping(value = "/expiredKey")
        @ResponseBody
        public RespBean setExpireKey(@RequestParam("key") String key,@RequestParam("value") String value,@RequestParam("expireTime") Long expireTime)
        {
        
            if(key == null || value == null || expireTime == null)
            {
        
                return RespBean.incorrectParameter();
            }
            stringRedisTemplate.opsForValue().set(key,value,expireTime, TimeUnit.SECONDS);
            return RespBean.ok();
        }

访问即可

http://localhost:8080/redis/expiredKey?key=123&value=123&expireTime=10

![1612869275700][]

[1612865790344]: /images/20221024/fbd9ac2151564de485bfc12cf552fc2b.png
[1612869298564]: /images/20221024/47000198c70c4d83bc12d4d8c0f5780e.png
[1612869423598]: /images/20221024/951d679a1921409b8a2103ff3eb20301.png
[1612869275700]: /images/20221024/c99167df2f7c4b96ab8f90e1f895f1c2.png