Go用redis.Client.Subscribe做跨节点广播必须防护：频道名需严格对齐，订阅后须用带超时ReceiveMessage验证；ReceiveMessage须在for循环中持续调用，忽略redis.Nil和subscribe消息；Publish返回0不表示失败，应检查ret.Err()；务必用独立带超时ctx并确保pubsub.Close()执行，防止goroutine与连接泄漏。
Go 用 redis.Client.Subscribe 做跨节点广播，能用，但不加防护就上线等于埋雷——消息丢、goroutine 泄漏、连接堆积、静默失败，四者必中其一。
Subscribe 后 ReceiveMessage 卡住，90% 是频道名没对齐
调用 rdb.Subscribe(ctx, "user.login") 成功，不代表真的连上了该频道。Redis 不校验频道是否存在，拼错大小写、多空格、少前缀（比如发布端用 "user:login"，订阅端写 "user.login"），Subscribe 仍返回 *redis.PubSub 实例，但后续 ReceiveMessage() 永远不会吐出业务消息。
必须做两件事：
- 订阅后立刻用带超时的
ReceiveMessage()验证：若几秒内只返回redis.Nil，大概率是频道名不一致； - 用
redis-cli -p 6379 SUBSCRIBE user.login手动确认，看是否能收到 “subscribe” 状态消息和后续测试PUBLISH。
别依赖 err != nil 就退出循环——redis.Nil 是心跳空响应，可忽略；真正要处理的是 context.Canceled（主动关闭）和网络类错误（如 read: connection reset by peer）。
立即学习“go语言免费学习笔记（深入）”；
ReceiveMessage 必须在 for 循环里调用，且不能 sleep 等待
ReceiveMessage() 是阻塞式单条读取，一次调用只拿一条。写成这样会丢消息：
msg, err := pubsub.ReceiveMessage(ctx)
if err != nil {
return
}
// 处理 msg...
正确姿势是：
- 用
for循环持续调用ReceiveMessage()； - 所有超时控制走
ctx，比如ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)； - 绝对不要在循环里加
time.Sleep(100 * time.Millisecond)—— 这会让延迟翻倍，且掩盖真实问题。
还要注意：ReceiveMessage() 返回的第一两条很可能是 redis.Subscription 类型消息（msg.Kind == "subscribe"），msg.Channel 为空，这是订阅生效的信号，不是业务数据，需跳过再进业务逻辑。
Publish 返回 0 不代表失败，真正要看 ret.Err()
rdb.Publish(ctx, "topic", data) 的返回值 ret.Val() 是当前在线并已成功订阅该频道的客户端数量，不是“发送是否成功”。返回 0 只说明此刻没人监听，不等于消息没发出去。
真正反映异常的是 ret.Err()：
-
redis: connection closed：Redis 连接断了； -
redis: ACLs don't allow 'publish' command：权限不足； -
redis: invalid password：密码错误。
如果业务要求“至少一人收到”，得自己实现 ACK：发布后起 goroutine 监听另一个确认频道，或改用 Redis Stream + XREADGROUP。
goroutine 和连接泄漏比消息丢失更致命
每个 rdb.Subscribe() 都启一个后台 goroutine 拉 Redis 流，不关就永远挂着。常见泄漏点：
- 忘记
defer pubsub.Close()； -
Subscribe传的ctx没设超时，导致连接卡死； - 错误地用
pubsub.Channel()直接 range（它返回 unbuffered channel，没人消费就会让后续Publish卡住）。
生产环境务必做到：
- 每个
Subscribe都配独立ctx，带超时和取消； - 在
defer或closeOnce里确保pubsub.Close()被执行； - 用
redis-cli client list定期检查是否有大量idle连接堆积。
原生 Pub/Sub 没有重试、没有持久化、没有 ACK，它只保证“发的时候有人在线就送，没人就丢”。想保消息，别硬扛，换 Redis Stream。
