JAVA實現redis超時失效key 的監聽觸發

過期事件通過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