redis pub/sub生产使用需警惕静默丢消息：频道名拼错、连错实例均无报错，须校验首次subscribe响应；缓冲区仅10条易覆盖丢失，需recover防panic；close()必须显式调用防连接泄漏；多频道应独立goroutine订阅，避免阻塞。
别用框架封装的 Pub/Sub 抽象层做生产级订阅发布——go-redis/v9 的 redis.PubSub 本身已足够轻量，而多数“Pub/Sub 框架”反而掩盖了连接生命周期、错误分类、缓冲区溢出等关键问题，导致静默丢消息或 goroutine 泄漏。
为什么 Subscribe() 成功后 ReceiveMessage() 却收不到消息
Redis 的 SUBSCRIBE 命令不校验频道是否存在，拼错名（如 "user.updated" 写成 "user.update"）、连错 DB、甚至连错 Redis 实例，都不会返回 error，只会安静等待。结果就是 ReceiveMessage() 永远阻塞，CPU 低、日志空、服务像卡住。
- 必须在首次
ReceiveMessage()后检查msg.Kind == "subscribe"且msg.Count >= 1，才算真正生效；前 1–2 条消息大概率是redis.Subscription类型，不是业务消息 - 别只靠
err != nil就 break —— 要分别处理：errors.Is(err, context.Canceled)是主动退出，errors.Is(err, redis.Nil)是心跳超时可忽略，其他 err 才该重建连接 - 用
redis-cli手动验证：PUBSUB NUMSUB order.created看返回值是否 ≥1，PUBSUB CHANNELS看频道是否在列表里
多频道订阅必须手动分流，不能依赖框架自动路由
调一次 client.Subscribe(ctx, "user.updated", "order.created")，所有消息都走同一个 ReceiveMessage() 流，不会按频道拆 goroutine 或 channel。框架若声称“自动分发”，往往只是帮你做了 if msg.Channel == "xxx" 这种判断，本质没变。
- 业务逻辑差异大（比如一个要查 DB，一个只发通知），建议拆成多个独立
Subscribe+ goroutine，避免慢操作阻塞快通道 - Redis 不保证跨频道消息顺序，只保证单频道内 FIFO；别在多个频道间做强时序依赖
- 频道命名必须和发布端严格对齐：大小写、空格、前缀（如
"ws:user:123"）都要一致，否则订阅即失效
Close() 不是可选项，重连必须自己实现
pubsub.Close() 是释放 TCP 连接的唯一方式。不调它，Redis 的 CLIENT LIST 里 idle 连接越积越多，最终触发 maxclients 拒绝新连接。框架若没暴露 Close() 或没提供重连钩子，等于埋雷。
- 务必显式调
pubsub.Close()，尤其在 goroutine 中启动的订阅——defer在 for 循环里无效，因为 defer 绑定的是当前迭代变量 - 网络抖动或 Redis 重启后，
ReceiveMessage()返回 error，此时要 close 当前实例并重建整个Subscribe流程，不能只重试ReceiveMessage() - 生产环境别裸写 for-loop 重连，应封装带指数退避的 helper：失败后 sleep 1s → 2s → 4s，避免雪崩式冲击 Redis
缓冲区默认仅 10 条，慢处理或 panic 会导致消息静默丢失
redis.PubSub 内部缓冲区极小（默认 10 条），且完全不报丢消息的错误。一旦你的回调函数解析 JSON 失败、调 HTTP 超时或 panic，新消息就会直接覆盖旧消息，毫无提示。
- 每个消息处理必须包一层
defer func() { recover() }()，防止 panic 传播 - 用
context.WithTimeout给回调加硬性超时，比如ctx, _ := context.WithTimeout(parentCtx, 5*time.Second) - 别复用同一个
PubSub实例去监听多个语义差异大的频道——一个频道异常（如消息格式突变）可能拖垮全部
最易被忽略的点：发布端 rdb.Publish(ctx, "topic", data) 返回的 ret.Val() 是当前在线订阅数，不是发送成功标志；为 0 只说明此刻没人在线，不等于消息失败。真正的可靠性，得靠业务层补全（比如结合 Redis Stream 或 ACK 机制），而不是指望框架自动兜底。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
