背压与管道传输
使用 pipeTo 和 pipeThrough 管理流量控制。
背压与管道传输 是 CoddyKit 上的免费 JavaScript Academy 课时。 这是第 4 节课，共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 JavaScript Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 JavaScript Academy 课程共包含 4 节课。
背压问题
如果生产者生成数据的速度快于消费者的处理速度，内存就会逐渐占满。背压是一种机制，慢速消费者可以通过它告诉快速生产者放慢速度。
WritableStream
WritableStream 是您可以向其中写入数据块的目标。它的 write(chunk) sink 方法可能是异步的，用于表示何时可以写入下一个数据块。
const sink = new WritableStream({
write(chunk) {
console.log("writing", chunk);
}
});获取写入器
getWriter() 会锁定可写流，并返回一个带有 write()、close() 和 ready promise 的写入器。
const writer = sink.getWriter();
await writer.write("hello");
await writer.close();ready 信号
写入前请等待 writer.ready。当流可以接受更多数据时，它就会完成解析——这就是背压在实际运行中的表现。
await writer.ready;
await writer.write(chunk);pipeTo
readable.pipeTo(writable) 会将源连接到目标，并自动为您管理背压。它返回一个 promise，在管道传输完成时解析。
await readableStream.pipeTo(writableStream);
console.log("done piping");pipeThrough
pipeThrough(transform) 会在源和 sink 之间插入一个转换流，并返回转换后的可读流。将多个转换流串联起来即可构建流水线。
sourceStream
.pipeThrough(new TextDecoderStream())
.pipeThrough(parser)
.pipeTo(consumer);高水位标记
排队策略的 highWaterMark 设置在触发背压前可以排队的数据块数量。请调整它，以平衡吞吐量和内存占用。
new ReadableStream(source, new CountQueuingStrategy({ highWaterMark: 4 }));desiredSize
控制器的 desiredSize 会告诉生产者队列中还剩多少空间。当它降至零或更低时，请停止入队。
pull(controller) {
while (controller.desiredSize > 0) {
controller.enqueue(nextChunk());
}
}中止管道传输
将 { signal } 传递给 pipeTo，即可使用 AbortController 中止整个流水线。
const ctrl = new AbortController();
readable.pipeTo(writable, { signal: ctrl.signal });
ctrl.abort();管道传输选项
pipeTo 接受 preventClose、preventAbort 和 preventCancel，用于控制错误和完成状态如何在两端之间传播。
readable.pipeTo(writable, { preventClose: true });完整的流水线
把这些组合起来：获取字节、解码、转换，然后写入 sink——整个过程都具备自动流量控制。
const res = await fetch("/data");
await res.body
.pipeThrough(new TextDecoderStream())
.pipeThrough(lineSplitter)
.pipeTo(uiSink);快速检查
测试背压。
回顾：背压与管道传输
您了解了 WritableStream 和写入器，等待 ready 以处理背压，使用 pipeTo/pipeThrough 连接流，调整 highWaterMark 并观察 desiredSize，还学习了如何中止流水线。至此，Streams API 的学习就完成了。
用 AI 导师学习 JavaScript — 免费
在浏览器中编写并运行真实代码，获得全天候 AI 导师的即时帮助，并在网页或应用中继续学习。
- 课程
- 59
- 课程
- 200
常见问题解答
「背压与管道传输」课时是免费的吗？
是的 — 「背压与管道传输」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 JavaScript Academy 课程的其余内容，请升级到 CoddyKit PRO。 JavaScript Academy 课程共包含 4 节课。
「背压与管道传输」这节课中我会学到什么？
使用 pipeTo 和 pipeThrough 管理流量控制。 你通过在浏览器中直接运行的动手代码来练习 JavaScript Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 JavaScript Academy 需要有经验吗？
无需任何先前经验。CoddyKit 上的 JavaScript Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。 这是第 4 节课，共 4 节。
「背压与管道传输」课时需要多长时间？
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。
我能在这节 JavaScript Academy 课中编写并运行代码吗？
能。每节 JavaScript Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。
此课程中的所有课时
- 可读流
- 流式处理 Fetch 响应
- 转换流
- 背压与管道传输