分布式系统中Redis的Key过期监听事件如何防止重复处理
我在Java的分布式系统中,使用了Redis的Key过期时间
Redis中设置如下:
notify-keyspace-events Ex
在Java中代码使用了JedisPubSub进行订阅:
/*
* 添加Redisd的key过期事件监听(因为会阻塞线程,所以放到最后执行)
*/
try {
logger.info("正在添加Redisd的key过期事件监听...");
Jedis jedis = Redis.use("data").getJedis();
JedisPubSub jedisPubSub = new RedisKeyExpiredListener();
String channel = "__keyevent@0__:expired";// key过期事件
if (jedis != null) {
new Thread(() -> {
jedis.subscribe(jedisPubSub, channel);// 这里启动了订阅监听,线程将在这里被阻塞
}).start();
logger.info("添加Redisd的key过期事件监听完成!");
} else {
logger.warn("添加Redisd的key过期事件监听失败,未获取到 jedis 对象!");
}
} catch (Exception ex) {
logger.error("添加Redisd的key过期事件监听异常!", ex);
}
监听事件如下:
/**
* 监听到订阅频道接受到消息时的回调
*/
@Override
public void onMessage(String channel, String message) {
logger.info("【onMessage】");
logger.info("channel = " + channel);
logger.info("message = " + message);
}
现在出现的问题是每当Redis中有Key过期时,都会调用各个程序中的onMessage事件,而且是同时调用,请问如果防止处理重复?处理完成后存缓存或者库来保证同步吗?