批量管道是什么
批量管道把多条命令打包，一次发送、一次收全部回复，把多次网络往返压缩成一次，吞吐能提升数倍。它适合批量写入与批量读取，但它不是事务：命令之间不保证原子性，中间某条失败也不会回滚其他命令。使用时必须控制单批规模，超大的一批会长时间占用服务端处理能力，客户端内存也会被撑大。
基本信息
| 用途 | 把多条命令合并为一次网络往返 |
|---|---|
| 收益 | 往返次数从多次降为一次，吞吐明显提升 |
| 原子性 | 不保证，本质不是事务 |
| 单批规模 | 数百到数千条一批比较稳 |
| 错误定位 | 结果按顺序返回，需要逐条检查失败项 |
| 批量导入 | 命令行提供专门的批量导入模式 |
典型使用场景
- 批量写入缓存：预热时一次写入大量键
- 批量读取：一次性取回多个键的值
- 数据迁移与初始化：把大批数据导入实例
- 提高吞吐：把循环里的逐条操作改为批量
- 降低延迟：减少往返次数带来的固定开销
批量用法示例
批量用法示例
# 客户端伪代码：开启批量模式后连续追加命令，最后一次性执行
批量模式开启
循环追加写命令
一次性执行并收集全部结果 # 一次网络往返完成所有命令
# 命令行批量导入
printf 'SET k1 v1\nSET k2 v2\n' > cmds.txt
redis-cli --pipe < cmds.txt # 高速导入，留意返回的错误条数使用要点
| 项目 | 说明 | 注意 |
|---|---|---|
| 往返次数 | 合并为一次 | 网络延迟高的链路收益最大 |
| 原子性 | 不保证 | 中间命令失败不影响其他命令 |
| 单批规模 | 数百到数千条 | 过大就会长时间占用服务端 |
| 结果顺序 | 与发送顺序一致 | 需要逐条检查失败项 |
| 错误处理 | 执行过程不中断 | 失败结果单独返回 |
| 事务模式 | 可以包在事务里 | 包事务会带来额外开销 |
超大批次会长时间占用服务端处理能力并撑大客户端内存：按数百到数千条一批分批发送，避免服务端卡顿与客户端内存暴涨。
批量管道不等于事务：中间某条命令失败，前后命令照样执行，需要原子语义时应该用事务或专门脚本。
批量使用检查清单
- 控制单批条数，按链路质量调整批次大小
- 逐条检查返回结果，识别失败命令
- 批量前评估目标实例的内存与负载
- 需要原子性的场景改用事务或脚本
- 批量导入时关注返回的错误条数
批量操作的作用是减少往返而不是减少服务端工作量：命令总量不变，服务端仍要逐条执行，因此单批规模必须以服务端能顺畅处理为前提。
批量操作检查清单
- 优先在网络延迟高的链路上使用，收益与往返次数成正比
- 按批次大小与链路质量做压测，找到合适的批量
- 批量读取前评估返回数据总量，避免响应体过大
- 导入完成后抽样校验数据，确认没有丢键
- 把批量逻辑封装成公共方法，避免各处批次大小不一致
批量读取同样要注意响应规模：一次取回大量键值会把网络与客户端内存同时推高，读取类批量操作应比写入类更保守地设置批次大小。