面试题：Node.js 流错误处理与背压问题

错误处理：

监听error事件：

为每个流（可读流、可写流和转换流）添加error事件监听器。例如，对于一个转换流transformStream：

transformStream.on('error', (err) => {
  // 记录错误信息，便于调试
  console.error('转换流出现错误:', err);
  // 可以选择向外部系统发送错误通知
  // 停止管道中的其他流，防止更多错误
  const readableStreams = []; // 假设已经收集了所有可读流
  const writableStreams = []; // 假设已经收集了所有可写流
  readableStreams.forEach((rs) => rs.pause());
  writableStreams.forEach((ws) => {
    if (ws.write) {
      ws.end();
    }
  });
});

错误传递：
- 当一个流出现错误时，要确保错误能够传递到整个管道流的合适位置进行处理。如果是转换流抛出错误，可以通过process.nextTick将错误传递给管道中的后续流或主程序。例如：
```
transformStream.on('error', (err) => {
  process.nextTick(() => {
    const downstreamStream = // 获取下游流
    if (downstreamStream.emit) {
      downstreamStream.emit('error', err);
    }
  });
});
```

背压处理：

可读流控制：

使用readable.pause()和readable.resume()方法。在可写流出现背压时（可写流的write方法返回false），暂停可读流。例如：

const readable = new Readable();
const writable = new Writable();
readable.pipe(writable);
writable.on('drain', () => {
  readable.resume();
});
writable.write = function (chunk) {
  const writeResult = Writable.prototype.write.call(this, chunk);
  if (!writeResult) {
    readable.pause();
  }
  return writeResult;
};

转换流处理背压：

转换流在处理数据时要考虑背压。如果转换流的输出速度过快，导致下游流出现背压，转换流需要暂停接收上游数据。可以通过this.push(null)来通知上游流暂停发送数据，直到下游流准备好接收更多数据（drain事件触发）。例如：

const Transform = require('stream').Transform;
const transform = new Transform({
  transform: function (chunk, encoding, callback) {
    const writeResult = this.push(chunk);
    if (!writeResult) {
      this.push(null);
    }
    callback();
  }
});
transform.on('drain', () => {
  // 恢复从上游流接收数据
});

综合处理：
- 确保错误处理和背压处理不冲突：
  - 在错误处理中暂停流时，要考虑已经存在的背压情况。如果在处理错误时已经暂停了可读流，就不需要因为背压再次暂停。同样，在背压处理中暂停流后，出现错误时要确保流的状态能够正确处理，不会导致重复操作或数据丢失。
- 恢复操作：
  - 在错误处理完成后，根据情况决定是否恢复管道流的操作。如果错误是可恢复的（例如临时的资源不足），可以尝试重新启动可读流，并逐步恢复数据处理，但要注意处理可能再次出现的背压问题。例如，在错误处理中记录错误原因，判断是否可恢复，如果可恢复：
```
let isRecoverableError = true; // 根据错误类型判断
if (isRecoverableError) {
  setTimeout(() => {
    const readableStream = // 获取可读流
    readableStream.resume();
  }, 5000); // 等待一段时间后尝试恢复
}
```

星途面试题库

面试题：Node.js 流错误处理与背压问题

知识考点

面试题答案