var fs = require('fs');var readStream = fs.createReadStream('/path/to/source');var writeStream = fs.createWriteStream('/path/to/dest');

readStream.on('data', function(chunk) { // 当有数据流出时，写入数据
   writeStream.write(chunk);
});

readStream.on('end', function() { // 当没有数据时，关闭数据流
   writeStream.end();
});

上面的代码就有一个问题，要是写入速度跟不上读取速度，就可能造成你说的writeStream还没写完就被关闭了。所以可以改成下面这种，我写完一段，你再读取下一段。这里如果是最后一次读取数据，那么读了之后，writeStream开始写，写完再通知readStream去读数据，可是这时readStream发现没有数据可读了，于是就触发end事件的监听器，它们才被关闭了

var fs = require('fs');var readStream = fs.createReadStream('/path/to/source');var writeStream = fs.createWriteStream('/path/to/dest');

readStream.on('data', function(chunk) { // 当有数据流出时，写入数据
   if (writeStream.write(chunk) === false) { // 如果没有写完，暂停读取流
       readStream.pause();
   }
});

writeStream.on('drain', function() { // 写完后，继续读取
   readStream.resume();
});

readStream.on('end', function() { // 当没有数据时，关闭数据流
   writeStream.end();
});