异步迭代器适用于处理分页数据、流式数据、消息队列和轮询等场景。1. 可封装分页逻辑，如逐页获取GitHub提交记录；2. 能简化Node.js中文件或网络流的逐块处理；3. 可包装WebSocket等实时消息流，实现同步风格的消息消费；4. 适合周期性异步任务，如定时轮询服务器状态。其核心优势是将复杂异步控制流隐藏在生成器内部，通过for await...of提供清晰、可组合的接口，使异步代码更易读和维护。
JavaScript中的异步迭代器（Async Iterators）适用于需要按需、逐步处理异步数据流的场景。它结合了异步操作和迭代协议，让开发者可以用简洁的方式处理一系列可能在未来完成的操作。以下是几个典型的使用场景：
1. 读取分页的远程数据
很多API采用分页机制返回大量数据。使用异步迭代器可以封装“获取下一页”的逻辑，让调用方通过for await...of自然地遍历所有结果。
例如从GitHub API逐页拉取提交记录：
async function* fetchCommits(repo) {let page = 1;
while (true) {
const res = await fetch(
`https://api.github.com/repos/${repo}/commits?page=${page}`
);
const commits = await res.json();
if (commits.length === 0) break;
for (const commit of commits) {
yield commit;
}
page++;
}
}
这样消费代码就变得非常清晰：
立即学习“Java免费学习笔记（深入）”；
for await (const commit of fetchCommits('vuejs/vue')) {console.log(commit.message);
}
2. 处理流式数据（Streams）
Node.js 中的可读流（Readable Streams）支持异步迭代。你可以直接用for await...of来处理文件流或网络流的数据块。
比如读取一个大文件并逐行处理：
const fs = require('fs');const readline = require('readline');
const rl = readline.createInterface({
input: fs.createReadStream('large.log'),
crlfDelay: Infinity
});
for await (const line of rl) {
console.log('处理一行:', line);
}
这种方式比传统的事件监听更直观，也更容易结合过滤、映射等逻辑。
3. 消费消息队列或事件流
在实时系统中，客户端可能需要持续接收服务端推送的消息，如WebSocket消息、Kafka消息等。异步迭代器可以封装“等待下一条消息”的过程。
示例：包装WebSocket为异步迭代器：
async function* websocketMessages(socket) {for await (const event of once(socket, 'message')) {
yield JSON.parse(event.data);
}
}
然后就可以用同步风格的循环来处理异步消息：
for await (const msg of websocketMessages(ws)) {if (msg.type === 'ping') continue;
handleMessage(msg);
}
4. 封装定时任务或轮询操作
当你需要周期性执行某个异步检查（比如轮询服务器状态），异步生成器可以封装延迟和重试逻辑。
async function* poll(url, interval = 5000) {while (true) {
const res = await fetch(url);
const data = await res.json();
yield data;
await new Promise(r => setTimeout(r, interval));
}
}
调用时可以限制次数或根据条件中断：
for await (const status of poll('/health')) {if (status.ready) break;
console.log('仍在等待...');
}
基本上就这些。异步迭代器的优势在于它把复杂的异步控制流隐藏在生成器内部，对外提供统一、可组合的接口。配合for await...of，代码读起来就像同步操作一样清晰，特别适合处理“一系列不确定时间到达的值”。
