ReadableStream.getReader()详解与使用教程

`ReadableStream.getReader()` 是操作流数据的核心入口，它通过独占锁机制（[[locked]] 内部状态）严格保障单消费者、顺序读取的安全性——一旦调用即锁定流，禁止重复获取 reader 或使用 pipe、BYOB 等其他消费方式；真正的数据拉取需主动调用 `reader.read()` 启动，其返回 Promise 并智能处理缓存与底层 pull；而锁不会自动释放，必须通过读完关闭、显式 `cancel()` 或 `finally` 中清理来避免流永久阻塞，稍有疏忽就会导致整个流不可再用——掌握这一“获取—读取—释放”三步闭环，是高效、健壮处理流式数据（如 fetch 响应）的关键。

调用 ReadableStream.getReader() 会立即获取一个 ReadableStreamDefaultReader 实例，并**独占性地锁住该流**——这意味着同一时间只能有一个活跃的 reader，后续再调用 getReader() 会直接抛出 TypeError（提示“stream is locked”）。

锁住流的本质与影响

锁是流对象内部的一个状态标记（[[locked]] 内部槽），一旦设为 true，以下操作将被禁止：

• 再次调用 getReader()
• 调用 pipeTo()、pipeThrough()
• 调用 getReader({ mode: 'byob' })（即使模式不同也不行）

锁的存在是为了避免多个消费者竞争读取，保证数据消费的确定性和顺序性。它不阻塞底层源（如 fetch() 响应体），数据仍会持续流入队列，只是读取控制权交给了当前 reader。

开启底层读取器的实际步骤

所谓“开启底层读取器”，本质是通过 reader 的 read() 方法触发流的内部读取机制。每次调用 read() 会：

• 若内部队列有数据，立即返回已缓存的 chunk（{ value, done: false }）
• 若队列为空且流未关闭/取消，向底层源请求新数据（例如触发 pull() 回调）
• 若流已关闭，返回 { value: undefined, done: true }

注意：read() 返回的是 Promise，需用 await 或 .then() 处理；不主动调用 read()，reader 虽存在但底层不会启动拉取逻辑。

释放锁与正确清理

锁不会自动释放，必须显式终止 reader：

• 读完并关闭：持续 read() 直到 done: true，然后 reader 自动解锁
• 主动取消：调用 reader.cancel(reason)，流进入 closed 状态并解锁
• 异常中断：reader 被垃圾回收前未完成或取消，流可能卡在 readable 状态，但锁仍存在——此时应确保 finally 中调用 cancel() 或 releaseLock()（仅限已读完）

⚠️ 错误做法：创建 reader 后不读也不 cancel，会导致流永久锁定，后续任何消费方式都失效。

常见场景示例

比如处理 fetch 响应流：

const response = await fetch('/data');
const reader = response.body.getReader(); // 此刻流已被锁
let result = new Uint8Array(0);

while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  // 拼接 chunk
  const newResult = new Uint8Array(result.length + value.length);
  newResult.set(result);
  newResult.set(value, result.length);
  result = newResult;
}
// reader 自动解锁，result 即完整响应体

如果中途想中止，改用 reader.cancel('abort') 即可提前解锁并终止底层传输。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~