Node.js流实验遇stream.push() after EOF错误，求问题根源

嘿，我来帮你拆解下你遇到的这两个问题，搞懂手动处理流时容易踩的坑～

为什么会出现 Error: stream.push() after EOF？ #

这个错误的核心原因是：你试图往已经标记为“结束”的可读流里继续推送数据。

如果是你自己继承 Readable 类自定义了可读流，那大概率是在 _read 方法里，已经调用过 this.push(null)（这是告诉流“我没有更多数据要推送了，标记结束”）之后，又再次调用了 this.push(chunk)。一旦流进入EOF状态，就不能再推送任何数据，否则就会抛出这个错误。

如果是用原生的 fs.createReadStream，那可能是你在 data 事件的回调里做了一些错误的操作，比如重复触发了数据推送的逻辑，或者不小心修改了流的内部状态。

为什么在 data 事件里调用 this.push(null) 会导致目标文件创建失败？ #

这完全搞反了调用时机和对象！

push(null) 是自定义可读流在 _read 方法里用来标记流结束的API，不是给你在 data 事件回调里调用的：

1. data 事件是可读流向外发射数据的事件，此时回调里的 this 不一定是你自定义的流对象（如果用箭头函数的话this 还会指向外层上下文）；
2. 提前在 data 事件里调用 push(null) 会强行终止可读流，导致可读流还没把所有数据发出来就停了，可写流根本没接收到足够的数据，甚至可能还没完成初始化，自然创建不了目标文件，还会因为流的状态异常报错。

正确的手动实现文件复制（不用 pipe()） #

如果要手动模拟 pipe() 的逻辑，需要自己处理背压、流的结束和错误处理，示例代码如下：

const fs = require('fs');

// 创建可读流和可写流
const readStream = fs.createReadStream('./index.js');
const writeStream = fs.createWriteStream('./indexCopy.js');

// 处理数据读取
readStream.on('data', (chunk) => {
  // 写入数据，如果返回false说明可写流缓冲区已满，暂停可读流
  const canContinueWriting = writeStream.write(chunk);
  if (!canContinueWriting) {
    readStream.pause();
  }
});

// 当可写流缓冲区有空位时，恢复可读流（处理背压）
writeStream.on('drain', () => {
  readStream.resume();
});

// 可读流结束时，告诉可写流写入完成
readStream.on('end', () => {
  writeStream.end();
});

// 处理错误，避免程序崩溃
readStream.on('error', (err) => {
  console.error('读取文件出错:', err);
  writeStream.destroy(err); // 出错时销毁可写流
});

writeStream.on('error', (err) => {
  console.error('写入文件出错:', err);
  readStream.destroy(err); // 出错时销毁可读流
});

总结下手动实现的关键要点 #

1. 不要随便调用 push(null)，只有自定义可读流的 _read 方法在确实没有数据时才用它标记结束；
2. 必须处理背压：当可写流的 write() 返回 false 时，暂停可读流，等 drain 事件再恢复；
3. 可读流结束时，一定要调用可写流的 end()，确保所有缓冲区的数据都被写入文件；
4. 别忘了处理两边的错误事件，防止因为某个流出错导致程序卡住或崩溃。

pipe() 之所以省心，就是它把这些细节都帮你封装好了，不过手动实现一遍确实能更深刻理解流的工作原理～

内容的提问来源于stack exchange，提问作者Vitaliy Markitanov