Node.js可写流write方法创建文件但无法写入内容求助

你的代码核心问题是过早关闭了可写流：在readableStream的open事件回调里，你立刻调用了writableStream.end()，这会直接关闭可写流。而data事件是在文件打开后才会逐步触发的，此时可写流已经关闭，后续的write操作根本无法向文件写入内容，最终导致file-2.txt为空。

修复后的代码 #

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt', 'utf8');
const writableStream = fs.createWriteStream('file-2.txt');

// 提前监听data事件，确保不会错过数据块
readableStream.on('data', (chunk) => {
  console.log(chunk);
  writableStream.write('hey there', 'utf8', () => {
    console.log('Im done writing!');
  });
});

readableStream.on('open', function () {
  console.log('opening file');
});

// 等可读流所有数据处理完成后，再关闭可写流
readableStream.on('end', () => {
  writableStream.end(() => {
    console.log('可写流已关闭');
  });
});

// 增加错误监听，排查潜在问题
readableStream.on('error', (err) => {
  console.error('可读流错误:', err);
});

writableStream.on('error', (err) => {
  console.error('可写流错误:', err);
});

关键修复点 #

• 移除open事件里的writableStream.end()，改为在可读流的end事件中关闭可写流，确保所有write操作都完成后再关闭流。
• 将data事件监听移到open事件外面，这是更规范的写法，避免因文件打开速度快而错过早期的数据块（小文件可能无影响，但大文件场景下很重要）。
• 增加错误监听，能快速排查比如file.txt不存在、文件权限不足等潜在问题。

简化场景（如果不需要可读流） #

如果你的测试只是想写入“hey there”到文件，完全不需要依赖可读流，可以直接简化为：

const fs = require('fs');
const writableStream = fs.createWriteStream('file-2.txt');

writableStream.write('hey there', 'utf8', () => {
  console.log('Im done writing!');
  writableStream.end();
});

内容的提问来源于stack exchange，提问作者Donald Ticha Teghen