目录
4.创建RedisKeyExpirationListener事件监听类
6.redis设置一个key为user:id,value为1,过期时间为30秒
1.创建springboot工程
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);
}
}整个工程结构如下图：
5.开启redis过期事件
6.redis设置一个key为user:id,value为1,过期时间为30秒
7.启动项目，测试
结果：发现已经可以监听到过期的redis key了
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/121019.html
