1、引用redis的包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2、配置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 {
//from fhadmin.cn
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
return container;
}
}
3、创建redis过期监听
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
//from fhadmin.cn
@Override
public void onMessage(Message message, byte[] pattern) {
// 过期key
String expiredKey = message.toString();
System.out.println(expiredKey + "过期了");
// 下面可以通过redis工具获取值或者执行业务逻辑
}
public RedisKeyExpirationListener(RedisMessageListenerContainer redisMessageListenerContainer ){
super(redisMessageListenerContainer);
}
}
4、测试是否可行
这个时候你可以搞个api测试下,设置过期事件为30秒,看下当key过期时,是否会正常被监听到。
5、注意事项
注意:监听器能监听到redis中过期的key是有个要求的,必须在redis配置文件里面设置能够监听到key过期事件,配置文件去目录下找,配置如下:
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。