Spring boot 实现监听 Redis key 失效事件

一. 开启Redis key过期提醒

• 方式一：修改配置文件

  redis.conf

  # 默认 notify-keyspace-events ""
  notify-keyspace-events Ex
  

• 方式二：命令行开启

  CONFIG SET notify-keyspace-events Ex
  CONFIG GET notify-keyspace-events
  

二. notify-keyspace-events

notify-keyspace-events 选项的默认值为空

notify-keyspace-events 的参数可以是以下字符的任意组合， 它指定了服务器该发送哪些类型的通知。

字符	发送的通知
K	键空间通知，所有通知以 keyspace@ 为前缀
E	键事件通知，所有通知以 keyevent@ 为前缀
g	DEL 、 EXPIRE 、 RENAME 等类型无关的通用命令的通知
$	字符串命令的通知
l	列表命令的通知
s	集合命令的通知
h	哈希命令的通知
z	有序集合命令的通知
x	过期事件：每当有过期键被删除时发送
e	驱逐(evict)事件：每当有键因为 maxmemory 政策而被删除时发送
A	参数 g$lshzxe 的别名

三. Coding

1. 初始化一个Spring Boot项目

2. pom.xml

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

3. 定义配置类`RedisListenerConfig

   @Configuration
   public class RedisListenerConfig {@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;}}
   

4. 定义监听器 实现KeyExpirationEventMessageListener接口
   查看源码发现，该接口监听所有db的过期事件keyevent@*:expired"
   定义Status1ExpirationListener监听状态1到期

   @Slf4j
   @Component
   public class Status1ExpirationListener extends KeyExpirationEventMessageListener {public Status1ExpirationListener(RedisMessageListenerContainer listenerContainer) {super(listenerContainer);}@Autowiredprivate StringRedisTemplate stringRedisTemplate;@Overridepublic void onMessage(Message message, byte[] pattern) {// message.toString()可以获取失效的keyString expiredKey = message.toString();// 业务处理}}
   

   定义Status2ExpirationListener监听状态2到期

   @Slf4j
   @Component
   public class Status2ExpirationListener extends KeyExpirationEventMessageListener {public Status2ExpirationListener(RedisMessageListenerContainer listenerContainer) {super(listenerContainer);}@Overridepublic void onMessage(Message message, byte[] pattern) {// message.toString()可以获取失效的keyString expiredKey = message.toString();// 业务处理}}
   

四. 参考

Redis keyspace notifications