异步迭代器通过AsyncIterator协议实现，提供返回Promise的next()方法，支持for await...of语法处理流数据。它适用于网络请求、文件读取等分块到达场景，可封装ReadableStream、WebSocket或分页API，结合异步生成器函数实现懒加载与内存优化，并能通过try-catch捕获错误，自动触发清理逻辑，提升流式数据处理的可控性与可读性。
异步迭代器在JavaScript中为处理流数据提供了强大而灵活的方式，尤其适合数据不是一次性获取，而是随时间逐步到达的场景，比如网络请求、文件读取或实时消息流。
什么是异步迭代器？
异步迭代器是一种遵循 AsyncIterator 协议的对象，它提供一个返回 Promise 的 next() 方法，每次调用会解析为包含 value 和 done 属性的结果对象。与普通迭代器不同，异步迭代器允许你在每次迭代中执行异步操作。
支持 for await...of 语法，使得消费异步数据流像处理数组一样直观。
如何用于流数据处理？
流数据通常分块到达，例如从服务器读取大型文件或接收 WebSocket 消息。异步迭代器能逐块处理这些数据，而不必等待全部加载完成。
立即学习“Java免费学习笔记（深入）”；
常见应用场景包括：- 读取可读流（如 Node.js 中的 ReadableStream）
- 消费事件源（EventSource）或 WebSocket 数据
- 分页获取 API 数据（如翻页拉取日志记录）
以浏览器中的 Response.body 为例，它是一个可读流，可以通过异步迭代器逐个读取数据块：
async function processStream(url) {
const response = await fetch(url);
const reader = response.body.getReader();
const decoder = new TextDecoder();
<p>while (true) {
const { done, value } = await reader.read();
if (done) break;
const text = decoder.decode(value);
console.log(text); // 处理每一小段数据
}
}
这段代码使用了底层流 API，但你可以将其封装成一个异步生成器函数，使其更易复用和组合：
async function* streamAsyncIterator(stream) {
const reader = stream.getReader();
const decoder = new TextDecoder();
while (true) {
const { done, value } = await reader.read();
if (done) return;
yield decoder.decode(value);
}
}
<p>// 使用 for await...of
async function handleStream(url) {
const response = await fetch(url);
for await (const chunk of streamAsyncIterator(response.body)) {
console.log(chunk);
}
}
异步生成器简化流封装
异步生成器函数（async function*）结合 yield 可以轻松创建异步迭代器，非常适合将流式来源抽象为可迭代的数据源。
例如，模拟一个分批拉取日志的API：
async function* fetchLogsFromPage(start = 0, limit = 100) {
let page = start;
while (true) {
const response = await fetch(`/logs?page=${page}&limit=${limit}`);
const logs = await response.json();
if (logs.length === 0) return;
yield* logs; // 逐条产出日志
page++;
}
}
<p>// 消费无限日志流，按需获取
async function printAllLogs() {
for await (const log of fetchLogsFromPage()) {
console.log(log);
}
}
这种方式实现了懒加载，只有在需要时才发起请求，内存友好且响应及时。
错误处理与终止控制
处理流数据时，网络中断或解析失败是常见问题。在 for await...of 中可以使用 try-catch 捕获异步迭代过程中的异常：
async function safeStreamConsumption(asyncIterator) {
try {
for await (const chunk of asyncIterator) {
console.log(chunk);
}
} catch (err) {
console.error('读取流时出错:', err);
}
}
如果需要提前终止迭代（例如用户取消），异步迭代器也会在退出 for await...of 时自动触发清理逻辑（如关闭流或取消请求），前提是底层实现支持取消机制。
基本上就这些。异步迭代器让流式数据处理变得更自然、更可控，结合现代Web API广泛使用的流机制，成为高效处理大数据量或实时信息的重要工具。不复杂但容易忽略。
