异步迭代器适用于处理分页数据、流式数据、消息队列和轮询等场景。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’);

这种方式比传统的事件监听更直观，也更容易结合过滤、映射等逻辑。

Smodin AI Content Detector

多语种AI内容检测工具

51

查看详情

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，代码读起来就像同步操作一样清晰，特别适合处理“一系列不确定时间到达的值”。