网站的对比,大秀,镇江网站建设一般多少钱,零基础学软件开发需要多久stream 模块的作用 在 Node.js 中#xff0c;stream 模块是一个用于处理流#xff08;stream#xff09;的核心模块。流是一种处理数据的抽象方式#xff0c;允许程序处理大量数据时不会一次性将所有数据加载到内存中#xff0c;从而提高性能和内存效率。通过流#xff0…stream 模块的作用 在 Node.js 中stream 模块是一个用于处理流stream的核心模块。流是一种处理数据的抽象方式允许程序处理大量数据时不会一次性将所有数据加载到内存中从而提高性能和内存效率。通过流Node.js 可以以分块的方式读取和写入数据这对于处理大文件或实时数据流如音视频流、网络请求等非常有效。 流可以分为以下几种类型
Readable Streams可读流允许从某个数据源中读取数据例如文件、HTTP 响应、标准输入等。Writable Streams可写流允许将数据写入某个目标例如文件、HTTP 请求、标准输出等。Duplex Streams双工流既可以读也可以写例如网络通信中的 TCP 套接字。Transform Streams转换流既可以读也可以写但在读取数据时会在读取的数据上执行一些转换操作例如压缩、加密、解密等。
核心功能和概念 数据流的处理方式 流是按块chunk进行传输的避免了将所有数据一次性加载到内存中的问题。这使得在处理大数据时程序能够以非常高效的方式进行工作。流会自动地分配缓冲区这些缓冲区的大小可以根据需求进行调节。 事件驱动 流是基于事件驱动的。当数据可用时会触发事件。常见的事件有 data、end、error 和 finish 等。 管道操作 Node.js 的 stream 模块支持管道pipe操作。你可以将一个流的输出连接到另一个流的输入这样数据就能自动从一个流传输到另一个流而不需要手动处理每个数据块。stream.pipe() 是常用的流连接方法。
stream 模块相关的API
1、Readable Stream可读流
用途用于从数据源中读取数据。常见使用场景读取文件、HTTP 请求响应、标准输入等。
const fs require(fs);
const readableStream fs.createReadStream(example.txt, { encoding: utf8 });readableStream.on(data, (chunk) {console.log(Received chunk:, chunk);
});readableStream.on(end, () {console.log(No more data.);
});readableStream.on(error, (err) {console.error(Error:, err);
});当读取一个文件时打印的格式是以下这样的 2、Writable Stream可写流
用途用于向某个目标写入数据。常见使用场景写入文件、HTTP 请求的响应、标准输出等。
const fs require(fs);
const writableStream fs.createWriteStream(output.txt);writableStream.write(Hello, world!\n);
writableStream.end(); // 完成写入writableStream.on(finish, () {console.log(Writing completed!);
});writableStream.on(error, (err) {console.error(Error:, err);
});3、Duplex Stream双工流
用途可以同时读取和写入的流。常见使用场景例如网络通信中的 TCP 套接字。
const { Duplex } require(stream);const duplexStream new Duplex({read(size) {this.push(data from read\n);this.push(null); // 结束流},write(chunk, encoding, callback) {console.log(Received chunk:, chunk.toString());callback();}
});duplexStream.write(Hello, Duplex stream!\n);
duplexStream.pipe(process.stdout);4、Transform Stream转换流
用途用于在读取数据时对数据进行某种转换例如压缩、解密等。常见使用场景压缩文件、数据加密等。
const { Transform } require(stream);const transformStream new Transform({transform(chunk, encoding, callback) {this.push(chunk.toString().toUpperCase()); // 转换成大写callback();}
});process.stdin.pipe(transformStream).pipe(process.stdout);主要方法和事件
常用方法
stream.read([size])从流中读取数据size 参数控制每次读取的字节数。stream.write(chunk[, encoding][, callback])向流中写入数据。stream.end([chunk][, encoding][, callback])标记流的结束通常在写入完毕后调用。stream.pipe(destination)将当前流的输出传递到目标流即另一个流。
常用事件
data当可读取的数据时触发。end数据读取完毕时触发在可读流中。finish数据写入完毕时触发在可写流中。error流操作中发生错误时触发。
