键空间通知
键空间通知(keyspace notification)
Note:
本文档翻译自: http://redis.io/topics/notifications 。
Warning 键空间通知功能目前仍在开发中,这个文档所描述的内容,以及功能的具体实现,可能会在未来数周内改变,敬请知悉。
功能概览
键空间通知使得客户端可以通过订阅频道或模式, 来接收那些以某种方式改动了 Redis 数据集的事件。
以下是一些键空间通知发送的事件的例子:
- 所有修改键的命令。 
- 所有接收到 LPUSH key value [value …] 命令的键。 
- 0号数据库中所有已过期的键。
事件通过 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 | 键空间通知,所有通知以 __keyspace@<db>__为前缀 | 
| E | 键事件通知,所有通知以 __keyevent@<db>__为前缀 | 
| g | DEL、EXPIRE、RENAME等类型无关的通用命令的通知 | 
| $ | 字符串命令的通知 | 
| l | 列表命令的通知 | 
| s | 集合命令的通知 | 
| h | 哈希命令的通知 | 
| z | 有序集合命令的通知 | 
| x | 过期事件:每当有过期键被删除时发送 | 
| e | 驱逐(evict)事件:每当有键因为 maxmemory政策而被删除时发送 | 
| A | 参数 g$lshzxe的别名 | 
输入的参数中至少要有一个 K 或者 E , 否则的话, 不管其余的参数是什么, 都不会有任何通知被分发。
举个例子, 如果只想订阅键空间中和列表相关的通知, 那么参数就应该设为 Kl , 诸如此类。
将参数设为字符串 "AKE" 表示发送所有类型的通知。
命令产生的通知
以下列表记录了不同命令所产生的不同通知:
- DEL key [key …] 命令为每个被删除的键产生一个 - del通知。
- RENAME key newkey 产生两个通知:为来源键(source key)产生一个 - rename_from通知,并为目标键(destination key)产生一个- rename_to通知。
- EXPIRE key seconds 和 EXPIREAT key timestamp 在键被正确设置过期时间时产生一个 - expire通知。当 EXPIREAT key timestamp 设置的时间已经过期,或者 EXPIRE key seconds 传入的时间为负数值时,键被删除,并产生一个- del通知。
- SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern …]] [ASC | DESC] [ALPHA] [STORE destination] 在命令带有 - STORE参数时产生一个- sortstore事件。如果- STORE指示的用于保存排序结果的键已经存在,那么程序还会发送一个- del事件。
- SET key value [EX seconds] [PX milliseconds] [NX|XX] 以及它的所有变种(SETEX key seconds value 、 SETNX key value 和 GETSET key value)都产生 - set通知。其中 SETEX key seconds value 还会产生- expire通知。
- MSET key value [key value …] 为每个键产生一个 - set通知。
- SETRANGE key offset value 产生一个 - setrange通知。
- INCR key 、 DECR key 、 INCRBY key increment 和 DECRBY key decrement 都产生 - incrby通知。
- INCRBYFLOAT key increment 产生 - incrbyfloat通知。
- APPEND key value 产生 - append通知。
- LPUSH key value [value …] 和 LPUSHX key value 都产生单个 - lpush通知,即使有多个输入元素时,也是如此。
- RPUSH key value [value …] 和 RPUSHX key value 都产生单个 - rpush通知,即使有多个输入元素时,也是如此。
- RPOP key 产生 - rpop通知。如果被弹出的元素是列表的最后一个元素,那么还会产生一个- del通知。
- LPOP key 产生 - lpop通知。如果被弹出的元素是列表的最后一个元素,那么还会产生一个- del通知。
- LINSERT key BEFORE|AFTER pivot value 产生一个 - linsert通知。
- LSET key index value 产生一个 - lset通知。
- LTRIM key start stop 产生一个 - ltrim通知。如果 LTRIM key start stop 执行之后,列表键被清空,那么还会产生一个- del通知。
- RPOPLPUSH source destination 和 BRPOPLPUSH source destination timeout 产生一个 - rpop通知,以及一个- lpush通知。两个命令都会保证- rpop的通知在- lpush的通知之前分发。如果从键弹出元素之后,被弹出的列表键被清空,那么还会产生一个- del通知。
- HSET hash field value 、 HSETNX hash field value 和 HMSET 都只产生一个 - hset通知。
- HINCRBY 产生一个 - hincrby通知。
- HINCRBYFLOAT 产生一个 - hincrbyfloat通知。
- SADD key member [member …] 产生一个 - sadd通知,即使有多个输入元素时,也是如此。
- SREM key member [member …] 产生一个 - srem通知,如果执行 SREM key member [member …] 之后,集合键被清空,那么还会产生一个- del通知。
- SMOVE source destination member 为来源键(source key)产生一个 - srem通知,并为目标键(destination key)产生一个- sadd事件。
- SPOP key 产生一个 - spop事件。如果执行 SPOP key 之后,集合键被清空,那么还会产生一个- del通知。
- SINTERSTORE destination key [key …] 、 SUNIONSTORE destination key [key …] 和 SDIFFSTORE destination key [key …] 分别产生 - sinterstore、- sunionostore和- sdiffstore三种通知。如果用于保存结果的键已经存在,那么还会产生一个- del通知。
- ZINCRBY key increment member 产生一个 - zincr通知。(译注:非对称,请注意。)
- ZADD key score member [[score member] [score member] …] 产生一个 - zadd通知,即使有多个输入元素时,也是如此。
- ZREM key member [member …] 产生一个 - zrem通知,即使有多个输入元素时,也是如此。如果执行 ZREM key member [member …] 之后,有序集合键被清空,那么还会产生一个- del通知。
- ZREMRANGEBYSCORE key min max 产生一个 - zrembyscore通知。(译注:非对称,请注意。)如果用于保存结果的键已经存在,那么还会产生一个- del通知。
- ZREMRANGEBYRANK key start stop 产生一个 - zrembyrank通知。(译注:非对称,请注意。)如果用于保存结果的键已经存在,那么还会产生一个- del通知。
- ZINTERSTORE destination numkeys key [key …] [WEIGHTS weight [weight …]] [AGGREGATE SUM|MIN|MAX] 和 ZUNIONSTORE destination numkeys key [key …] [WEIGHTS weight [weight …]] [AGGREGATE SUM|MIN|MAX] 分别产生 - zinterstore和- zunionstore两种通知。如果用于保存结果的键已经存在,那么还会产生一个- del通知。
- 每当一个键因为过期而被删除时,产生一个 - expired通知。
- 每当一个键因为 - maxmemory政策而被删除以回收内存时,产生一个- evicted通知。
Note:
所有命令都只在键真的被改动了之后,才会产生通知。
比如说,当 SREM key member [member …] 试图删除不存在于集合的元素时,删除操作会执行失败,因为没有真正的改动键,所以这一操作不会发送通知。
如果对命令所产生的通知有疑问, 最好还是使用以下命令, 自己来验证一下:
$ redis-cli config set notify-keyspace-events KEA
$ redis-cli --csv psubscribe '__key*__:*'
Reading messages... (press Ctrl-C to quit)
"psubscribe","__key*__:*",1然后, 只要在其他终端里用 Redis 客户端发送命令, 就可以看到产生的通知了:
"pmessage","__key*__:*","__keyspace@0__:foo","set"
"pmessage","__key*__:*","__keyevent@0__:set","foo"
...过期通知的发送时间
Redis 使用以下两种方式删除过期的键:
- 当一个键被访问时,程序会对这个键进行检查,如果键已经过期,那么该键将被删除。 
- 底层系统会在后台渐进地查找并删除那些过期的键,从而处理那些已经过期、但是不会被访问到的键。 
当过期键被以上两个程序的任意一个发现、 并且将键从数据库中删除时, Redis 会产生一个 expired 通知。
Redis 并不保证生存时间(TTL)变为 0 的键会立即被删除: 如果程序没有访问这个过期键, 或者带有生存时间的键非常多的话, 那么在键的生存时间变为 0 , 直到键真正被删除这中间, 可能会有一段比较显著的时间间隔。
因此, Redis 产生 expired 通知的时间为过期键被删除的时候, 而不是键的生存时间变为 0 的时候。