揭秘Stream模块，解锁Node.js异步读写利器

前端

2023-03-09 04:31:37

Stream模块：Node.js文件操作的强大工具

导言

对于任何Node.js程序员来说，Stream模块都是必不可少的。它提供了高效处理大量数据的强大功能，使其成为文件读写操作的理想选择。本文将深入探讨Stream模块，揭示它的概念、功能以及如何利用它进行文件读写操作。

什么是Stream？

Stream是一个数据流，可以将数据从一个地方传输到另一个地方。它可以是文件、网络连接、管道或任何其他数据传输通道。

Stream模块的功能

Stream模块提供了一系列流对象，可用于读取、写入和转换数据，包括：

fs.createReadStream(): 读取文件
fs.createWriteStream(): 写入文件
process.stdin: 读取标准输入
process.stdout: 写入标准输出
process.stderr: 写入标准错误

使用Stream进行文件读写操作

读取文件

const fs = require('fs');

const readStream = fs.createReadStream('file.txt');

readStream.on('data', (chunk) => {
  console.log(chunk.toString());
});

readStream.on('end', () => {
  console.log('Finished reading file');
});

写入文件

const fs = require('fs');

const writeStream = fs.createWriteStream('file.txt');

writeStream.write('Hello, world!');

writeStream.end();

转换数据

Stream模块还支持数据转换。例如，使用以下代码可以将CSV文件转换为JSON文件：

const fs = require('fs');
const csvParser = require('csv-parser');
const JSONStream = require('JSONStream');

const readStream = fs.createReadStream('file.csv');
const writeStream = fs.createWriteStream('file.json');

readStream
  .pipe(csvParser())
  .pipe(JSONStream.stringify())
  .pipe(writeStream);