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