Redis key过期事件的监听_redis过期监听是否可以根据某种规则监听,或者只监听一个key

使用redis key 过期通知，需开启key过期通知功能：

登录进入redis-cli客户端，执行：

config set notify-keyspace-events Ex
1

或者在redis.conf 添加配置:

notify-keyspace-events "Ex" //过期时间监听生效
1

或者通过代码设置：

    # 连接redis库1
    redisCli1 = StrictRedis(db=1, decode_responses=True)
    # 开启key过期通知功能
    redisCli1.config_set("notify-keyspace-events", "Ex")
    # 清空库
    redisCli1.flushdb()
1
2
3
4
5
6

配置详解:

启动监听key过期

登录进入redis-cli 客户端，执行：( 订阅一个或者多个符合pattern格式的频道)

# 进入1库
redis-cli -n 1--raw
# 订阅过期事件，*代表所有库
PSUBSCRIBE __keyevent@*__:expired    
1
2
3
4

然后该客户端处于监听状态，如果有key过期，则列出：

Python代码示例

from redis import StrictRedis
import requests
import sys
import logging
import logging.handlers

logger = logging.getLogger('mylogger')
logger.setLevel(logging.WARNING)

# handler 输出到控制台
ch = logging.StreamHandler()
ch.setLevel(logging.WARNING)
logger.addHandler(ch)

# redis
try:
    # 开启key过期通知功能
    redisCli1 = StrictRedis(db=1, decode_responses=True)
    redisCli1.config_set("notify-keyspace-events", "Ex")
    redisCli1.flushdb()
except:
    logging.error("redis服务未启动!")
    sys.exit(0)

# 对库1 进行监听
pubsub = redisCli1.pubsub()
# 发布监听key失效的订阅
pubsub.psubscribe("__keyevent@1__:expired")
# 通过无限循环等待事件
logger.info('Starting message loop')
for data in pubsub.listen():
    key = data.get("data")
    if key != 1:
        logger.warning("过期key是: %s", key)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35