SpringBoot怎麼監聽redis Key變化事件

一 、功能概覽

鍵空間通知使得客戶端可以透過訂閱頻道或模式， 來接收那些以某種方式改變了 Redis key變化的事件。

所有修改key鍵的指令。

所有接收到 LPUSH key value [value …] 指令的鍵。

db資料庫中所有已過期的鍵。

事件透過Redis 的訂閱與發布功能（pub/sub）來進行分發， 因此所有支援訂閱與發布功能的用戶端都可以在無須做任何修改的情況下， 直接使用鍵空間通知功能。

因為Redis 目前的訂閱與發布功能採取的是發送即忘（fire and forget）策略， 所以如果你的程式需要可靠事件通知（reliable notification of events）， 那麼目前的鍵空間通知可能不適合你： 當訂閱事件的客戶端斷線時， 它會失去所有在斷線期間分發給它的事件。

未來將會支援更可靠的事件分發， 這種支援可能會透過讓訂閱與發布功能本身變得更可靠來實現， 也可能會在Lua 腳本中對訊息（message）的訂閱與發布進行監聽， 從而實現類似將事件推入到列表這樣的操作。

二、事件類型

對於每個修改資料庫的操作，鍵空間通知都會傳送兩種不同類型的事件。

比如說，對 0 號資料庫的鍵 mykey 執行 DEL key [key …] 指令時，系統會分發兩條訊息，相當於執行下列兩個 PUBLISH channel message 指令：

PUBLISH __keyspace@0__:mykey del
PUBLISH __keyevent@0__:del mykey

訂閱第一個頻道__keyspace@0__:mykey 可以接收0 號資料庫中所有修改鍵mykey 的事件，而訂閱第二個頻道__keyevent@0__:del則可以接收0 號資料庫中所有執行del 指令的鍵。

以 keyspace 為前​​綴的頻道稱為鍵空間通知（key-space notification）， 而以 keyevent 為前綴的頻道則稱為按鍵事件通知（key-event notification）。

當 del mykey 指令執行時:

• 鍵空間頻道的訂閱者將接收到被執行的事件的名字，在這個例子中，就是 del 。

• 鍵事件頻道的訂閱者將會接收到被執行事件的鍵的名字，在這個例子中，就是 mykey 。

三、設定

因為開啟鍵空間通知功能需要消耗一些 CPU ， 所以在預設設定下， 此功能處於關閉狀態。

可以透過修改redis.conf 文件， 或直接使用CONFIG SET 指令開啟或關閉鍵空間通知功能：

當notify-keyspace-events 選項的參數為空字串時，功能關閉。

另一方面，當參數不是空字串時，功能開啟。

notify-keyspace-events 的參數可以是以下字元的任意組合， 它指定了伺服器該發送哪些類型的通知：

輸入的參數中至少要有一個 K或 E ， 否則的話， 不管其餘的參數是什麼， 都不會有任何通知被分發。

舉個例子， 如果只想訂閱鍵空間中和列表相關的通知， 那麼參數就應該設為 Kl ，諸如此類。

將參數設為字串"AKE" 表示發送所有類型的通知。

每當一個鍵因為過期而被刪除時，產生一個 expired 通知。

每當一個鍵因為maxmemory政策而被刪除以回收記憶體時，產生一個 evicted 通知。

所有指令都只在鍵真的被改動了之後，才會產生通知。

比如說，當 SREM key member [member …]試圖刪除不存在於集合的元素時，刪除操作會執行失敗，因為沒有真正的改動鍵，所以這一操作不會發送通知。

如果對命令所產生的通知有疑問， 最好還是使用以下命令， 自己來驗證一下：

Redis 使用以下兩種方式刪除過期的鍵：

當一個鍵被存取時，程式會對這個鍵進行檢查，如果鍵已經過期，那麼該鍵將會被刪除。

底層系統會在後台漸進地尋找並刪除那些過期的鍵，從而處理那些已經過期、但是不會被存取到的鍵。
當過期鍵被以上兩個程式的任意一個發現、 並且將鍵從資料庫中刪除時， Redis 會產生一個 expired 通知。

Redis 不保證生存時間（TTL）變成0 的鍵會立即被刪除： 如果程式沒有存取這個過期鍵， 或帶有生存時間的鍵非常多的話， 那麼在鍵的生存時間變為0 ， 直到鍵真正被刪除這中間， 可能會有一段比較顯著的時間間隔。

因此， Redis 产生expired通知的时间为过期键被删除的时候， 而不是键的生存时间变为 0 的时候。

三、案例

按上文内容，我们先将redis的键空间通知开启,我们开启所有的通知，在可以端中测试后没问题再到代码中测试。

连接到redis 输入一下命令

config set notify-keyspace-events KEA

  订阅键空间和键事件的主题

psubscribe '__key*__:*'#对所有库键空间通知
 
psubscribe '__keyspace@2__:*' #是对db2数据库键空间通知
 
psubscribe '__keyspace@2__:order*' #是对db2数据库，key前缀为order所有键的键空间通知

创建一个 key :name valus:zhangsan

set name wsl

观察订阅的窗口 会受到两个消息，第一个是：键空间 第二个是键事件，键空间是内容是操作指令，主题中包含有key，键事件主题中包含了指令，内容是key。

到这里说明已经开启了键空间通知

代码

以下代码采用string类型演示

在配置一下MessageListenerContainer类，将我们写好的监听类添加到该类中即可,删除和过期都是需要添加，我这里就一起添加了后面就不做演示。

@Configuration
public class RedisConfig {
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    @Autowired
    private RedisUpdateAndAddListener redisUpdateAndAddListener;
 
    @Autowired
    private RedisDeleteListener redisDeleteListener;
 
    @Autowired
    private RedisExpiredListener redisExpiredListener;
 
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        //监听所有的key的set事件
        container.addMessageListener(redisUpdateAndAddListener, redisUpdateAndAddListener.getTopic());
        //监听所有key的删除事件
        container.addMessageListener(redisDeleteListener,redisDeleteListener.getTopic());
        //监听所有key的过期事件
        container.addMessageListener(redisExpiredListener,redisExpiredListener.getTopic());
        return container;
    }
 
 
}

新增和修改都是set指令

所以监听的主题都一样,实现MessageListener接口，重写onMessage这里就是收到消息的处理逻辑

@Component
@Data
public class RedisUpdateAndAddListener implements MessageListener {
	//监听的主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:set");
 
    @Override
    public void onMessage(Message message,byte[] pattern){
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key更新或修改，消息主题是："+ topic+",消息内容是："+msg);
    }
 
}

在redis中对name这个key进行set操作

set name wsl

在控制台就可以看到name这个key被操作了

删除

跟上面的更新监听一样，只需要把订阅主题更改一下即可。同样需要添加到这个RedisMessageListenerContainer，上面已经添加，这里不做演示

@Component
@Data
public class RedisDeleteListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:del");
 
    /**
     *
     * @param message 消息
     * @param pattern 主题
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的删除，消息主题是："+ topic+",消息内容是："+msg);
    }
}

 在redis输入命令，del name 在控制台可以看到已经收到消息了。

过期

如上面的操作方式一样

@Data
@Component
public class RedisExpiredListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:expired");
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的过期，消息主题是："+ topic+",消息内容是："+msg);
    }
}

 在redis中写一个定时删除的keySETEX age 18 3三秒后就可以控制台打印了相关信息

以上是SpringBoot怎麼監聽redis Key變化事件的詳細內容。更多資訊請關注PHP中文網其他相關文章！