JAVA实现redis超时失效key 的监听触发

左手的ㄟ右手 2022-03-02 04:56 884阅读 0赞

过期事件通过Redis的订阅与发布功能（pub/sub）来进行分发。

而对超时的监听呢，并不需要自己发布，只有修改配置文件redis.conf中的：notify-keyspace-events Ex，默认为notify-keyspace-events ""

\# K    键空间通知，以\_\_keyspace@<db>\_\_为前缀  
\# E    键事件通知，以\_\_keysevent@<db>\_\_为前缀  
\# g    del , expipre , rename 等类型无关的通用命令的通知, ...  
\# $    String命令  
\# l    List命令  
\# s    Set命令  
\# h    Hash命令  
\# z    有序集合命令  
\# x    过期事件（每次key过期时生成）  
\# e    驱逐事件（当key在内存满了被清除时生成）  
\# A    g$lshzxe的别名，因此”AKE”意味着所有的事件

修改好配置文件后，redis会对设置了expire的数据进行监听，当数据过期时便会将其从redis中删除：

1.先写一个监听器：

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("onPMessage pattern "  
                        + pattern + " " + channel + " " + message);  
    \}  
   
   
   
\}

2.订阅者：

public class Subscriber \{  
   
    public static void main(String\[\] args) \{  
        JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");  
   
        Jedis jedis = pool.getResource();  
        jedis.psubscribe(new KeyExpiredListener(), "\_\_key\*\_\_:\*");  
   
    \}  
   
\}

3.测试类：

public class TestJedis \{  
   
    public static void main(String\[\] args) \{  
        JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");  
   
        Jedis jedis = pool.getResource();  
        jedis.set("notify", "新浪微博：小叶子一点也不逗");  
        jedis.expire("notify", 10);  
   
    \}  
\}

4.结果：  
先启动订阅者，然后执行测试类，然后等待10秒之后再监听类的方法中就可以获得回调。非常需要主要的时，过期监听的管道默认是\_\_keyevent@0\_\_:expired，艾特后面的0表示第几个是数据库，redis默认的数据库是0~15一共16个数据库。所以如果你存入的数据库是2,那么数据接收的管道就是\_\_keyevent@2\_\_:expired