Redis 事件通知(keyspace & keyevent notification)


 

IMPORTANT  2.8.0之后版本才可用
 
    鍵空間通知使得客戶端可以通過訂閱頻道或模式, 來接收那些以某種方式改動了 Redis 數據集的事件。
    因為 Redis 目前的訂閱與發布功能采取的是發送即忘(fire and forget)策略, 所以如果你的程序需要可靠事件通知(reliable notification of events), 那么目前的鍵空間通知可能並不適合你:當訂閱事件的客戶端斷線時, 它會丟失所有在斷線期間分發給它的事件。並不能確保消息送達。
    
 
事件的類型
    對於每個修改數據庫的操作,鍵空間通知都會發送兩種不同類型的事件消息:keyspace 和 keyevent。以 keyspace 為前綴的頻道被稱為鍵空間通知(key-space notification), 而以 keyevent 為前綴的頻道則被稱為鍵事件通知(key-event notification)。
 
    事件是用  __keyspace@DB__:KeyPattern 或者  __keyevent@DB__:OpsType 的格式來發布消息的。
    DB表示在第幾個庫;KeyPattern則是表示需要監控的鍵模式(可以用通配符);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 命令的鍵。
 
    
配置
    鍵空間通知通常是不啟用的,因為這個過程會產生額外消耗。所以在使用該特性之前,請確認一定是要用這個特性的,然后修改配置文件。相關配置項如下:
字符 發送的通知
K 鍵空間通知,所有通知以 __keyspace@<db>__ 為前綴,針對Key
E 鍵事件通知,所有通知以 __keyevent@<db>__ 為前綴,針對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的失效事件。
 
過期通知的發送時間
Redis 使用以下兩種方式刪除過期的鍵:
  • 當一個鍵被訪問時,程序會對這個鍵進行檢查,如果鍵已經過期,那么該鍵將被刪除。
  • 底層系統會在后台漸進地查找並刪除那些過期的鍵,從而處理那些已經過期、但是不會被訪問到的鍵。
當過期鍵被以上兩個程序的任意一個發現、 並且將鍵從數據庫中刪除時, Redis 會產生一個 expired 通知。
Redis 並不保證生存時間(TTL)變為 0 的鍵會立即被刪除: 如果程序沒有訪問這個過期鍵, 或者帶有生存時間的鍵非常多的話, 那么在鍵的生存時間變為 0 , 直到鍵真正被刪除這中間, 可能會有一段比較顯著的時間間隔。
因此, Redis 產生 expired 通知的時間為過期鍵被刪除的時候, 而不是鍵的生存時間變為 0 的時候。
 
subscribe & psubscribe
    subscribe & psubscribe命令來對特定主題進行訂閱,完成事件通知的過程。
        SUBSCRIBE channel [channel ...]                       
        PSUBSCRIBE channelPattern [channelPattern ...]        
    PSUBSCRIBE 跟 SUBSCRIBE 唯一不同,就是支持通配符。每個模式以 * 作為匹配符,比如 huangz* 匹配所有以 huangz。顯然支持通配符的性能消耗會大一點。
    時間復雜度:
O(N), N是訂閱的模式的數量。
    返回值:
# 第 1 - 6 行是執行 psubscribe 之后的反饋信息, 包括:顯示成功、訂閱的內容、已訂閱數量
# 第 7 - 10 才是接收到的第一條信息,包括:返回類型、來源(訂閱的Channel)、內容
# 第 11 - 14 是第二條
# 以此類推。。。
    注意:這里可以一次性訂閱多個Channel 或者 模式,每個中間用空格分割。
 
 
命令行實驗
    1:修改配置,然后用配置啟動Redis。可以通過 info命令來查看是否使用了特定配置文件。
    2:訂閱
        > subscribe __keyspace@0__:cool
        Reading messages... (press Ctrl-C to quit)
        1) "subscribe"                             # 返回值的類型:顯示訂閱成功
        2) "__keyspace@0__:cool"         # 訂閱的Channel名
        3) (integer) 1                                # 目前已訂閱的頻道數量
    3:設置失效
        > setex cool 1 val                         # cool=val 1秒失效
    4:失效消息
        1) "message"                               # 返回值的類型:信息
        2) "__keyspace@0__:cool”          # 來源(從哪個Channel發送過來)
        3) “expired"                                 # 信息內容
 
注:對於psubscribe,消息會多一行
        1) “pmessage”                            #返回值的類型:信息
        2) "__keyspace@0__:cool*”         # 來源(從哪個ChannelPattern發送過來)
        3) "__keyspace@0__:cool"          # 實際的Channel
        4) “expired"                                 # 信息內容

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM