redis cluster 下 clusterclient.pipeline() 会 panic，因官方禁止跨 slot pipeline；正确做法是用 keyslot+nodeforkey 手动路由到单节点再调用 pipeline()，且需逐条检查 cmd.err()。
直接用 client.Pipeline() 批量写弹幕，在 Redis Cluster 环境下会 panic —— 不是慢，是根本跑不起来。
go-redis/v9 中 clusterClient.Pipeline() 为什么 panic
因为 github.com/redis/go-redis/v9 明确禁止对 *redis.ClusterClient 调用 Pipeline()。这不是配置遗漏或版本错，是 API 层硬性限制：集群客户端不提供跨 slot 的 pipeline 封装，强行调用直接触发 panic。
- 底层逻辑是：pipeline 必须保证所有命令发往同一节点，而 ClusterClient 默认按 key 自动路由，无法保证“一批命令全落在一个 slot”
- 你传一个
chat:room:1001和一个user:233进同一个 pipeline，客户端要么拆成两批（失去 pipeline 意义），要么拒绝执行 - 正确做法是绕过
clusterClient.Pipeline()，自己算 slot、找节点、在单机 client 上调Pipeline()
Redis Cluster 下必须手动 slot 路由才能用 Pipeline
弹幕场景天然要求同房间消息进同一 slot，否则 LPUSH chat:{room:1001}:messages 可能被分到不同节点，后续 LLEN 或 LRANGE 就会报 CROSSSLOT 错误。
Alibabacloud Sdk Client Initialization For Golang
下载
初始化并管理阿里云SDK Go 客户端，涵盖 sync.Once 单例、goroutine 安全、endpoint 与 region 配置、VPC 端点及调试。
- key 必须带 hash tag：
chat:{room:1001}:messages，确保{room:1001}部分参与 slot 计算 - 用
clusterClient.KeySlot(key)获取 slot 编号 - 再用
clusterClient.NodeForKey(slot)拿到对应节点的*redis.Client - 在这个节点 client 上调
node.Pipeline()，此时它就是标准单机 pipeline，完全可用
每条命令的 .Err() 必须显式检查，不能只看 Exec() 返回值
pipe.Exec(ctx) 的 error 只反映连接中断、超时、序列化失败等底层问题；而某条 LPUSH 因 key 被设为 READONLY、或 value 超长被截断，其余 499 条仍会成功 —— 这类错误只藏在每个 cmd.Err() 里。
- 漏掉遍历
pipe.Cmds()检查，等于默认接受静默丢数据 - 批大小建议控制在 100–500 条之间：太少网络收益低；超过 500 容易触达 Redis 的
proto-max-bulk-len限制（默认 512MB，但实际单批 payload 建议 -
context.Context超时设为 500ms：太短整批被砍，太长拖慢故障恢复 - 严禁混入
INCR、GET等读命令——弹幕写入无依赖，混读不仅无意义，还可能因中间状态不可见或跨 slot 触发错误
真正卡住线上服务的，从来不是“会不会写 pipeline”，而是 slot 路由没做、cmd.Err() 没查、批大小拍脑袋定。这三处一错，流量上来就丢弹幕，日志里却只看到 “exec ok”。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
