Node.js使用Streams来处理文件读写操作的示例代码

const fs = require('fs');
const readline = require('readline');

// 创建一个可读流
const readStream = fs.createReadStream('example.txt', 'utf8');

const rl = readline.createInterface({
  input: readStream,
  crlfDelay: Infinity
});

rl.on('line', (line) => {
  console.log(`Line from file: ${line}`);
});

rl.on('close', () => {
  console.log('Finished reading the file.');
});

const fs = require('fs');

// 创建一个可写流
const writeStream = fs.createWriteStream('output.txt', 'utf8');

// 写入数据
writeStream.write('Hello, Node.js Streams!\n');
writeStream.write('This is another line.\n');

// 关闭流
writeStream.end('This is the final line.\n');

writeStream.on('finish', () => {
  console.log('Finished writing to the file.');
});

writeStream.on('error', (error) => {
  console.error(`Error writing to the file: ${error.message}`);
});

const fs = require('fs');

// 创建读取和写入流
const readStream = fs.createReadStream('input.txt', 'utf8');
const writeStream = fs.createWriteStream('output.txt', 'utf8');

// 管道操作
readStream.pipe(writeStream);

readStream.on('error', (error) => {
  console.error(`Error reading the file: ${error.message}`);
});

writeStream.on('error', (error) => {
  console.error(`Error writing to the file: ${error.message}`);
});

writeStream.on('finish', () => {
  console.log('Finished copying the file.');
});