监听 Redis 缓存过期(Key 失效)事件
最近写公司一个项目遇到一个场景,设备上线后会以 0.5HZ 的频率给后台发送状态消息,20 秒内没有重连则认为设备下线,需要执行相应操作。
首先想到的就是在 Redis 存带过期时间的 key,每次设备发来消息就去刷新 key 的过期时间,key 过期后,则执行设备下线的方法,那么问题来了,这怎么去监听 key 是否过期(当时没听说过 redis 还可以发布/订阅),于是头脑风暴了一下,直接看 Redis 监听的可以跳过。
头脑风暴一:
每次设备上线都在在Redis里存储:
1. <id_time,value>过期时间20秒
2. <id_backup,value>不包含过期时间
开启一个定时任务:每隔30秒去Redis获取一下这两组数据
每组数据都包含多个,因为可能有多个设备在线
对比这两组数据,即可找到过期的数据,也就是下线的设备(id_backup有,id_time已经失效的数据)
然后去执行相应的操作。
但是不太想整个 Redis
头脑风暴二
干脆直接在Java中维护一个Map<id,最后状态时间戳>(当然我做的这个项目在线设备不多,百八十个不得了了)
每次设备发送状态信息,刷新一下map里的`最后状态时间戳`
然后开启一个定时任务,每隔30秒去遍历一下map
哪个数据的'最后状态时间戳'比当前时间早了超过30秒则认为设备下线,指向相应操作
这种方法虽然不用整合Redis但是容易导致数据丢失,一旦服务停止,内存中数据不会持久化。
于是网上找了一下相关 Redis 监听相关方法,还真有,下面我把 SpringBoot 整合 Redis,实现 Redis 缓存过期(Key 失效)事件监听相关代码分享
Redis 缓存过期(Key 失效)事件监听
Redis 配置修改
- 事件通过 Redis 的订阅与发布功能(pub/sub)来进行分发, 故需要开启 redis 的事件监听与发布
- 修改 redis.conf 文件(Windows 上是 redis.windows.conf 和 redis.windows-service.conf)
notify-keyspace-events Ex
- 重启 Redis,然后进行下面测试。
- 打开 redis-cli.exe 窗口输入:
PSUBSCRIBE __keyevent@*__:expired
,窗口先别关闭。
- 再打开一个 redis-cli.exe 窗口,存一个带失效时间的数据
setex boy 6 6
查看第一个窗口,监听到数据失效,即配置成功
- 引入 pom.xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
- application.yaml 配置文件
spring:
redis:
host: localhost
port: 6379
password:
jedis:
pool:
max-active: 0
- RedisListenerConfig.java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisListenerConfig {
@Autowired
private RedisTemplate redisTemplate;
@Bean
RedisMessageListenerContainer listenerContainer(RedisConnectionFactory connectionFactory) {
RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
listenerContainer.setConnectionFactory(connectionFactory);
return listenerContainer;
}
@Bean
KeyExpirationEventMessageListener redisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
return new RedisKeyExpirationListener(listenerContainer);
}
@Bean
public RedisTemplate redisTemplateInit() {
//设置序列化Key的实例化对象
redisTemplate.setKeySerializer(new StringRedisSerializer());
//设置序列化Value的实例化对象
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
return redisTemplate;
}
}
- RedisKeyExpirationListener.java
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
@Override
public void onMessage(Message message, byte[] pattern) {
//获取过期的key
String expireKey = message.toString();
//信息打印
log.info("key : {} 失效" ,expireKey);
//设备下线相关操作
}
}
- IRedisService.java
public interface IRedisService {
/**
* 存入k,v键值对,有默认生效时间
*
* @param key
* @param value
*/
void setValue(String key, String value);
}
- RedisServiceImpl.java
import com.tangyh.lamp.utils.Constant;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;
import java.util.Map;
import java.util.concurrent.TimeUnit;
@Service
public class RedisServiceImpl implements IRedisService {
@Autowired
private RedisTemplate redisTemplate;
@Override
public void setValue(String key, String value) {
ValueOperations<String, Object> vo = redisTemplate.opsForValue();
vo.set(key, value);
redisTemplate.expire(key, Constant.OSD_TIME_OUT, TimeUnit.SECONDS); // 这里指的是30秒后失效
}
}
有错误之处,或者更好的办法还请评论区指教。
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于