springbootrediskey失效监听机制
reids2.8之后⽀持的失效监听
因为 Redis ⽬前的订阅与发布功能采取的是发送即忘(fire and forget)策略,所以如果你的程序需要可靠事件通知(reliable notification of events),那么⽬前的键空间通知可能并不适合你:当订阅事件的客户端断线时,它会丢失所有在断线期间分发给它的事件。并不能确保消息送达。未来有计划允许更可靠的事件传递,但可能这将在更⼀般的层⾯上解决,或者为Pub / Sub本⾝带来可靠性,或者允许Lua脚本拦截Pub / Sub消息来执⾏诸如推送将事件列⼊清单。
事件类型
对于每个修改数据库的操作,键空间通知都会发送两种不同类型的事件消息:keyspace 和 keyevent。以 keyspace 为前缀的频道被称为键空间通知(key-space notification),⽽以 keyevent 为前缀的频道则被称为键事件通知(key-event notification)。
事件是⽤ __keyspace@DB__:KeyPattern 或者 __keyevent@DB__:OpsType 的格式来发布消息的。
DB表⽰在第⼏个库;KeyPattern则是表⽰需要监控的键模式(可以⽤通配符,如:__key*__:*);OpsType则表⽰操作类型。因此,如果想要订阅特殊的Key上的事件,应该是订阅keyspace。
⽐如说,对 0 号数据库的键 mykey 执⾏ DEL 命令时,系统将分发两条消息,相当于执⾏以下两个 PUBLISH 命令:
PUBLISH __keyspace@0__:sampleKey del
PUBLISH __keyevent@0__:del sampleKey
订阅第⼀个频道 __keyspace@0__:mykey 可以接收 0 号数据库中所有修改键 mykey 的事件,⽽订阅第⼆个频道 __keyevent@0__:del 则可以接收 0 号数据库中所有执⾏ del 命令的键。
开启配置
键空间通知通常是不启⽤的,因为这个过程会产⽣额外消耗。所以在使⽤该特性之前,请确认⼀定是要⽤这个特性的,然后修改配置⽂件,或使⽤config配置。相关配置项如下:
字符发送通知
K 键空间通知,所有通知以 keyspace@ 为前缀,针对Key
E 键事件通知,所有通知以 keyevent@ 为前缀,针对event
g DEL 、 EXPIRE 、 RENAME 等类型⽆关的通⽤命令的通知
$ 字符串命令的通知
牛津小学英语说课稿
l 列表命令的通知
s 集合命令的通知
h 哈希命令的通知
z 有序集合命令的通知
x 过期事件:每当有过期键被删除时发送
e 驱逐(evict)事件:每当有键因为 maxmemory 政策⽽被删除时发送
A 参数 g$lshzxe 的别名,相当于是All
大野智吧
输⼊的参数中⾄少要有⼀个 K 或者 E ,否则的话,不管其余的参数是什么,都不会有任何通知被分发。上表中斜体的部分为通⽤的操作或者事件,⽽⿊体则表⽰特定数据类型的操作。配置⽂件中修改 notify-keyspace-events “Kx”,注意:这个双引号是⼀定要的,否则配置不成功,启动也不报错。例如,
“Kx”表⽰想监控某个Key的失效事件。
也可以通过config配置:CONFIG t notify-keyspace-events Ex (但⾮持久化)
国庆节升旗仪式Redis 使⽤以下两种⽅式删除过期的键:
crossgene1.当⼀个键被访问时,程序会对这个键进⾏检查,如果键已经过期,那么该键将被删除。
2017六级答案2.底层系统会在后台查找并删除那些过期的键,从⽽处理那些已经过期、但是不会被访问到的键。
当过期键被以上两个程序的任意⼀个发现、并且将键从数据库中删除时, Redis 会产⽣⼀个 expired 通知。
Redis 并不保证⽣存时间(TTL)变为 0 的键会⽴即被删除:如果程序没有访问这个过期键,或者带有⽣存时间的键⾮常多的话,那么在键的⽣存时间变为0 ,直到键真正被删除这中间,可能会有⼀段⽐较显著的时间间隔。
因此, Redis 产⽣ expired 通知的时间为过期键被删除的时候,⽽不是键的⽣存时间变为 0 的时候。
由于通知收到的是redis key,value已经过期,⽆法收到,所以需要在key上标记业务数据。
notify-keyspace-events "Ex"
import fig.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.dition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import java.util.List;
queenie eyepublic class RedisKeyExpiredConfig implements CommandLineRunner {
@Autowired
RedisUtil redisUtil;
@Override四大名著英文>afford的过去式
public void strings) throws Exception {
Jedis jedis =Jedis();
keyListentConfigMethod(jedis);
jedis.psubscribe(new KeyExpiredListener(), "__keyevent@*__:expired");//过期队列
}
public void keyListentConfigMethod(Jedis jedis){
System.out.println(">>>>>>>>>>>>>>>>>>启动监听实现的redisKey<<<<<<<<<<<<<<<<<<"); String parameter = "notify-keyspace-events";
List<String> notify = figGet(parameter);
fornasari翻译网址(1).equals("")){
}
}
}
import org.springframework.stereotype.Component;
import redis.clients.jedis.JedisPubSub;
@Component
public class KeyExpiredListener extends JedisPubSub {
@Override
public void onPSubscribe(String pattern, int subscribedChannels) {
System.out.println("onPSubscribe " + pattern + " " + subscribedChannels);
}
@Override
public void onPMessage(String pattern, String channel, String message) {
System.out.println(
"pattern = [" + pattern + "], channel = [" + channel + "], message = [" + message + "]"); //收到消息 key的键值,处理过期提醒
}
}