正确做法是用 client.Pipeline() 或 client.TxPipeline() 获取管道对象再批量调用命令，最后必须调用 Exec() 并逐个检查各 Cmd.Err()；普通 Pipeline 仅提升吞吐，TxPipeline 提供原子性但不支持集群跨 slot 操作。
Redis Pipeline 在 Go 里怎么写才不丢数据
Go 官方 redis 客户端（github.com/go-redis/redis/v9）默认不自动启用 Pipeline，必须显式调用 pipeliner 接口，否则看似“批量”实则仍是串行请求。常见错误是直接在 client 上连续调用 Set、Get，结果每个命令都走一次 TCP 往返。
正确做法是用 client.Pipeline() 或 client.TxPipeline() 获取管道对象，再把命令发给它：
pipe := client.Pipeline() pipe.Set(ctx, "k1", "v1", 0) pipe.Set(ctx, "k2", "v2", 0) pipe.Get(ctx, "k1") _, err := pipe.Exec(ctx)
注意：Exec() 才真正发包；之前所有操作只是排队。如果中间某步出错（比如 key 过期策略冲突），Exec() 返回的 err 是 nil，但对应命令的 Cmd 结果里会有具体错误，得逐个检查 Cmd.Err()。
Pipeline 和 TxPipeline 到底该选哪个
两者都减少网络往返，但语义不同：Pipeline 是纯客户端缓冲 + 合并发送，服务端按序执行，无原子性保证；TxPipeline 底层用 MULTI/EXEC 包裹，服务端保证原子性，但一旦有命令失败（如类型错误），整个事务回滚，且 EXEC 返回的错误是 redis.Nil 而非具体命令错误，排查更难。
立即学习“go语言免费学习笔记（深入）”；
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
- 需要强一致性（比如扣库存+写日志必须全成功）→ 用
TxPipeline - 只是提升吞吐（比如批量写日志、缓存预热）→ 用普通
Pipeline，性能略高，错误定位更直接 -
TxPipeline在 Redis 集群模式下可能报CROSSSLOT错误，因为 MULTI/EXEC 不支持跨 slot 操作
为什么 Exec() 后还要遍历 Cmd 结果
Exec() 只表示网络请求发出去并收到响应，不代表每个子命令都成功。Redis 对 Pipeline 的响应是数组，Go 客户端把每个响应映射到对应 Cmd 实例上，但不会自动抛异常。
典型坑：写了个 Set 命令传了空字符串，Exec() 返回 nil，但那个 SetCmd.Err() 是 redis.Nil（即“OK”，其实不是）——不对，这里要纠正：空字符串是合法值，真正容易被忽略的是类型错误，比如对一个 string key 执行 HGet，此时 HGetCmd.Err() 会是 redis.Error("WRONGTYPE Operation against a key holding the wrong kind of value")，而 Exec() 本身仍返回 nil。
所以必须这样检查：
cmds := pipe.Set(ctx, "a", "1", 0), pipe.HGet(ctx, "a", "f")
_, err := pipe.Exec(ctx)
if err != nil {
// 网络或协议层错误
}
for _, cmd := range cmds {
if cmd.Err() != nil {
// 处理这个命令的具体错误
}
}
大数量 Pipeline 会卡住或超时？
单次 Pipeline 命令数没有硬限制，但实际受两个因素制约：redis-server 的 client-output-buffer-limit（默认 256MB）和 Go 客户端的 ctx 超时。一次塞几万条命令，服务端可能主动断连，客户端则因 ctx 超时提前放弃。
- 建议单次 Pipeline 控制在 1000 条以内，更稳妥是 100–500 条
- 用带超时的
context.WithTimeout，别用context.Background() - 如果需处理上万键，拆成多个 Pipeline 并发执行，比单个大 Pipeline 更稳
- 注意：并发 Pipeline 共享同一个连接池，高并发下可能触发连接池耗尽，可调大
client.Options.PoolSize
最常被跳过的细节是：没检查每个 Cmd 的 Err()，就默认“Exec 成功=全部成功”。Redis Pipeline 的错误是静默的，得自己捞。
