Hyperf中使用Redis Pipeline需手动创建Hyperf\Redis\Pipeline实例并显式调用execute()，适用于批量无依赖操作，不支持事务和复合命令别名，且须避免与Hyperf\Pipeline组件混淆。
Hyperf 里用 Redis Pipeline 提升批量操作性能，核心就一条：别让每条命令单独走一次网络往返。只要批量读写超过 3 条，就该切到 Pipeline；否则 RTT 累积起来，100 次 GET 就是 100 次毫秒级等待。
Hyperf 中怎么拿到 Redis Pipeline 实例
Hyperf 的 Hyperf\Redis\Redis 客户端不直接暴露 pipeline() 方法，必须通过 Hyperf\Redis\Pipeline 类手动构造。它不是“调个方法就行”，而是要显式创建、执行、释放。
-
Hyperf\Redis\Pipeline是一个独立类，需手动 new（或从容器获取），不能从$redis->pipeline()这样链式调用 - 构造时需传入
Hyperf\Redis\Redis实例，即你配置好的 Redis 连接对象（如$this->redis） - 不支持自动 commit，必须显式调用
execute()或sync()—— 忘了这步，命令就卡在内存里，永不发出 - 注意：它不等价于 phpredis 的原生
pipeline()，底层封装了连接复用逻辑，但不支持 WATCH/MULTI 事务语义
示例：
$pipeline = make(Hyperf\Redis\Pipeline::class, ['redis' => $this->redis]);
$pipeline->set('a', '1');
$pipeline->set('b', '2');
$pipeline->get('a');
$result = $pipeline->execute(); // 返回 [true, true, "1"]什么时候该用 Pipeline，什么时候不该用
不是所有批量场景都适合 Pipeline。关键看「命令是否可并行、结果是否需强序依赖」。
- 适合：
MGET/MSET类替代场景（如批量查用户头像、批量设购物车项）、无状态的写入（日志打点、计数器自增） - 不适合：带条件判断的链式操作（如先
GET再INCRBY再SET），Pipeline 里无法读取中间结果做分支 - 警惕内存：Pipeline 缓冲区会暂存所有命令和响应，10 万条命令可能吃掉几十 MB 内存；建议单次控制在 500–2000 条以内，按业务分片处理
- 错误处理弱：某条命令失败（如 key 过期、类型错误），
execute()仍返回混合结果（false或异常对象），需遍历检查每个返回值，不能靠 try/catch 整体捕获
常见报错与绕过方式
实际跑 Pipeline 时最常撞上的不是逻辑错，而是连接和上下文问题。
-
Connection refused或Redis server went away：多见于协程内复用非协程安全的 Redis 实例；确保$this->redis是从容器 get 的，而非 new 出来的单例 -
Call to undefined method Hyperf\Redis\Pipeline::mget()：Pipeline 不支持复合命令别名，只能调用原子方法（get,set,hGet等），mget得拆成多个get - 返回结果顺序错乱：没按调用顺序接收 —— 必须严格用
execute()返回的数组索引对应原始调用位置，别用foreach ($pipeline as $r)这种不可靠遍历 - 协程泄漏：Pipeline 实例未被及时 GC，尤其在循环中反复 new；建议用
make()+ 显式销毁，或改用go匿名函数包裹生命周期
和 Hyperf 原生 Pipeline 组件别混用
Hyperf 有两个 “Pipeline”：一个是中间件/数据处理用的 Hyperf\Pipeline\Pipeline（基于 DI 容器 + callable 链），另一个是 Redis 通信层的 Hyperf\Redis\Pipeline（基于 TCP 批量写入）。名字一样，用途、接口、生命周期完全不同。
- 前者处理的是 PHP 数据流（如报表清洗管道），后者处理的是 Redis 协议命令流
- 不能把
RedisPipeline当作Pipeline的一个 stage 注入进业务处理管道 —— 类型不兼容，容器也无法解析 - 若需“查 Redis → 清洗 → 聚合”，应在外层组合：先用
RedisPipeline拿数据，再把结果喂给Hyperf\Pipeline\Pipeline处理
真正容易被忽略的点是：Redis Pipeline 的性能收益几乎全来自减少 RTT，但它本身不降低单条命令执行时间。如果命令本身慢（比如大 key 的 HGETALL），Pipeline 只是把慢打包发出去，不会变快 —— 这时候得先优化命令，再考虑批量。
