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"                                 # 信息內容