"ReadableStream tee 多消费者一致性治理实践"

ReadableStream tee 多消费者一致性治理实践概述使用 `ReadableStream.prototype.tee()` 将一个源流拆分为两个分支流，分别供不同处理任务并行消费，同时保持块序与一致性治理。技术背景`tee()` 返回两个独立的 `ReadableStream`，基础数据仅拉取一次并复制到两个分支。背压由较慢分支决定总体拉取速率，避免快分支拖垮源。核心内容tee 的基本用法const [s1, s2] = sourceReadable.tee(); const p1 = s1.pipeTo(writableA); const p2 = s2.pipeTo(writableB); await Promise.all([p1, p2]); 一致性治理策略明确每个分支的职责（如校验与落盘），减少重复计算。若分支需要共享状态，使用 `Web Locks` 或消息通道协调，避免竞态。与 TransformStream 协作const transformA = new TransformStream({ transform(c, ctl){ ctl.enqueue(c); }}); const transformB = new TransformStream({ transform(c, ctl){ ctl.enqueue(c); }}); const [s1x, s2x] = sourceReadable.tee(); await Promise.all([ s1x.pipeThrough(transformA).pipeTo(writableA), s2x.pipeThrough(transformB).pipeTo(writableB), ]); 技术参数与验证测试环境浏览器: Chrome 120+ / Firefox 120+ / Safari 17+验证要点模拟一个分支慢写，确认整体拉取速率降档且不丢块。统计两个分支接收块数量与顺序一致性。应用场景同步计算与持久化（校验+落盘）。一路用于 UI 预览，另一路用于文件存储。注意事项分支中的异常会中止对应管道，应做好错误捕获与回滚策略。大量复制可能增加内存压力，需结合块大小与队列策略调优。参考资料MDN ReadableStream.tee：https://developer.mozilla.org/docs/Web/API/ReadableStream/tee