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();
});