Golang 如何监听 Redis 的 Key 过期事件

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《Golang 如何监听 Redis 的 Key 过期事件》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

必须先开启Redis的notify-keyspace-events配置，设为"Ex"并重启或重写配置，否则无法收到__keyevent@0__:expired等消息；订阅需匹配实际DB编号，使用独立连接、recover防护及幂等处理。

必须先开启 Redis 的 notify-keyspace-events 配置

Redis 默认完全关闭键空间通知，不配就永远收不到 __keyevent@0__:expired 这类消息。只改代码没用。

要生效，必须在 redis.conf 中设置：

notify-keyspace-events "Ex"

其中 E 表示 keyevent 事件，x 表示 expired 类型；不要写成 AKE 或空值。改完记得 redis-cli config rewrite 或重启 Redis。

验证是否生效：

redis-cli config get notify-keyspace-events

返回值应为 1) "notify-keyspace-events" 2) "Ex"。否则后续所有监听逻辑都静默失败。

订阅频道名必须带 DB 编号，且不能用通配符混用

__keyevent@0__:expired 中的 0 是数据库编号，不是占位符。你连的是哪个 DB，就得订哪个 DB 的频道。

常见错误：

• 用 __keyevent@*__:expired —— Redis 不支持通配符订阅该类频道
• 连 DB 1 却订 __keyevent@0__:expired —— 永远收不到自己设的过期 key
• 用 PSUBSCRIBE 订 __keyevent@0__:expired —— 这是普通 SUBSCRIBE 场景，不是模式匹配

正确写法（以 DB 0 为例）：

pubsub := rdb.Subscribe(ctx, "__keyevent@0__:expired")

监听 goroutine 必须独立连接，且带 recover + 重连

Pub/Sub 连接是阻塞式长连接，一旦断开或出错，ReceiveMessage() 会直接 panic 或返回 error，整个 goroutine 就死了，事件从此丢失。

关键防护点：

• 订阅必须用单独的 redis.Client 实例，绝不能复用业务连接池 —— 否则一个断连拖垮全部读写
• goroutine 内部必须包 defer func(){...}() + recover()
• 收到 redis.Nil 或网络错误时，要主动 pubsub.Close()，然后 sleep 几秒后重建连接和订阅
• 首次订阅前，建议先 rdb.ConfigSet(ctx, "notify-keyspace-events", "Ex").Err() 做运行时兜底（但不能替代配置文件）

收到的 payload 是 key 名，不是 value，且不含 DB 信息

msg.Payload 就是纯字符串 key 名，比如 "user:123_delay"，不是 JSON，也不带数据库索引或类型前缀。

这意味着：

• 无法从 payload 判断它属于哪个 DB —— 全靠你订阅时指定的频道 DB 编号来对齐
• 无法知道它原本的 value 或 TTL —— 如需关联原始数据，得靠 key 命名规范（如 user:123_delay 对应缓存 key user:123）
• 高并发下可能重复收到同一 key 的 expired 事件（Redis 文档明确说明：不保证 exactly-once）—— 处理逻辑必须幂等，比如删缓存前先 Exists 判断

典型处理片段：

if strings.HasPrefix(msg.Payload, "user:") && strings.HasSuffix(msg.Payload, "_delay") {
    realKey := strings.TrimSuffix(msg.Payload, "_delay")
    _ = rdb.Del(ctx, realKey).Err()
}

今天关于《Golang 如何监听 Redis 的 Key 过期事件》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！