fetch 的 response.body 是只读、单次消费的 readablestream，需显式读取且不可重复使用；推荐用 for await...of 或 pipethrough 进行流式处理，并配合 try/catch 与 cancel 实现错误处理和中断控制。
Fetch 返回的 Response 对象中，body 是一个 ReadableStream，它支持按需读取、分块处理、取消流等能力。直接操作流比一次性用 json() 或 text() 更灵活，也更适合大文件、实时数据或自定义解析场景。
理解 body 流的基本状态和限制
Response.body 是只读、单次消费的流：一旦调用 json()、text()、arrayBuffer() 等方法，内部会自动读取并锁定流，后续再访问 body 会得到 null；手动读取流后，也无法再调用这些高阶方法。所以必须在“读取流”和“用便捷方法”之间二选一。
流默认处于“等待读取”状态，不会自动开始传输。你需要显式调用 getReader() 或使用 for await...of 启动消费。
用 for await…of 读取流（推荐，简洁安全）
这是最常用、最直观的方式，适合大多数流式处理需求，比如边接收边解析 JSON 行（NDJSON）、拼接文本、计算哈希、转发到另一个流等：
- 确保响应头允许流式读取（如
Content-Type: application/json或无特定类型） - 使用
response.body+for await...of获取Uint8Array块 - 注意：块顺序固定，但大小不固定（由网络与浏览器调度决定）
示例：拼接全部内容为字符串（模拟 text()）：
const response = await fetch('/data');
const reader = response.body.getReader();
let chunks = [];
<p>while (true) {
const { done, value } = await reader.read();
if (done) break;
chunks.push(value);
}</p><p>const bytes = new Uint8Array(chunks.reduce((acc, chunk) => [...acc, ...chunk], []));
const text = new TextDecoder().decode(bytes);
console.log(text);
</p>用 ReadableStream 接口做高级操作
你可以把 response.body 当作标准 ReadableStream，接入 TransformStream、WritableStream 或管道（pipeTo / pipeThrough），实现流式转换：
-
response.body.pipeThrough(new TextDecoderStream())→ 直接得到可迭代的字符串流 -
response.body.pipeThrough(new DecompressionStream('gzip'))→ 解压后再处理（需浏览器支持） -
response.body.pipeTo(new WritableStream({ write(chunk) { /* 自定义写入逻辑 */ } }))→ 写入 IndexedDB、File System Access API 或 WebSocket
示例：逐块打印解码后的文本行（适用于日志流）：
const response = await fetch('/logs');
const stream = response.body
.pipeThrough(new TextDecoderStream())
.pipeThrough(new TextEncoderStream()); // 可选：转回字节流做进一步处理
<p>const reader = stream.getReader();
while (true) {
const { done, value } = await reader.read();
if (done) break;
console.log(new TextDecoder().decode(value)); // value 是 Uint8Array，已解码为文本块
}
</p>中断流与错误处理
流可以随时取消，这对取消上传、超时控制或用户主动停止非常关键：
- 调用
reader.cancel('reason')会终止读取并关闭底层连接（类似 abort controller） - 监听
reader.closed（Promise）可知道流是否正常结束 - 所有流操作都可能抛出异常（如网络中断、解码失败），务必用
try/catch包裹read()或for await
示例：带超时的流读取：
const controller = new AbortController();
setTimeout(() => controller.abort(), 5000);
<p>const response = await fetch('/big-file', { signal: controller.signal });
const reader = response.body.getReader();</p><p>try {
while (true) {
const { done, value } = await reader.read();
if (done) break;
processChunk(value);
}
} catch (err) {
console.error('流读取失败：', err.name === 'AbortError' ? '超时或取消' : err.message);
}
</p>Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
