Unix

我们可以把流看作这些数据的集合#xff0c;就像液体一样#xff0c;我们先把这些液体保存在一个容器里#xff08;流的内部缓冲区

BufferList

我们可以把流看作这些数据的集合就像液体一样我们先把这些液体保存在一个容器里流的内部缓冲区

BufferList等到相应的事件触发的时候我们再把里面的液体倒进管道里并通知其他人在管道的另一侧拿自己的容器来接里面的液体进行处理。

Node.js中的流是一种处理数据的抽象接口它提供了一种有效的方式按需处理数据来读取或写入大量数据而无需一次性将整个数据加载到内存中。

流可以被视为数据在某段时间内从一个点移动到另一个点的序列类似于水从一根管子的一端流到另一端。

Node.js流解决了处理大量数据时可能遇到的内存消耗和性能问题。

以下是使用Node.js流的好处

内存效率使用流可以按需处理数据而不需要一次性将整个数据加载到内存中。

这意味着即使处理大量数据也可以节省大量的内存空间。

流以块的形式处理数据每次只加载和处理一小部分数据然后将其释放从而减少了内存的使用量。

性能优化由于流以块的形式处理数据可以实现并行处理提高处理速度。

流还可以通过流水线pipeline的方式将多个操作连接起来实现数据的连续处理从而提高整体性能。

响应性使用流可以实现实时处理数据即在数据到达时立即进行处理而不需要等待整个数据加载完成。

这对于需要实时处理数据的应用程序非常重要例如实时日志分析、实时聊天等。

可扩展性流是可组合的可以将多个流连接起来形成更复杂的数据处理流程。

这种可组合性使得代码更加模块化和可重用便于扩展和维护。

适用于各种场景Node.js流可以用于处理各种类型的数据包括文件、网络请求、数据库查询结果等。

无论是处理大文件、处理网络请求还是处理数据库查询结果使用流都可以提供高效的数据处理方式。

流的类型流可以是可读的、可写的或者可读可写的。

在Node.js中有四种内置的流类型

可读流Readable、可写流Writable、双工流Duplex转换流Transform。

常见的流事件所有的流都是EventEmitter类的实例可以通过事件和方法来处理流的数据。

data当有数据可读时触发、end当没有更多数据可读时触发error当发生错误时触发等。

write向流中写入数据read从流中读取数据pipe将一个可读流的数据传输到一个可写流等。

流的工作原理流将要传输的数据处理成连续的块chunk通过一小块一小块地传输数据从而降低内存消耗并提高性能。

这种逐段处理的方式使得流非常适合处理大量数据或需要逐段处理的场景。

内置的流对象Node.js中有许多内置的流对象如HTTP请求、文件读写、标准输入输出stdin/stdout等。

这些内置的流对象可以直接使用无需直接实现流的接口。

stream模块stream模块是用于构建实现流接口的对象的模块可以通过require(stream)导入。

开发人员可以使用stream模块创建自定义的流实例实现更复杂的流操作。

HTTP

fs.createReadStream(./movie.txt);let

content

所有数据已读取完毕输出content内容console.log(content);

});文件movie.txt

D:\WuWorkSpace\code\NodejsProject\nodejs实战学习\【第2章

Node.js基础】\2.7

process.stdin.pipe(process.stdout);这段代码使用了Node.js的process.stdin和process.stdout流对象并通过pipe方法将输入流(process.stdin)的数据直接传输到输出流(process.stdout)中。

具体解析如下

process.stdin是一个可读流它表示标准输入流stdin可以用于接收用户的输入。

process.stdout是一个可写流它表示标准输出流stdout可以用于向控制台输出数据。

通过调用pipe方法我们将输入流(process.stdin)连接到输出流(process.stdout)这样输入流中的数据会被自动传输到输出流中。

这段代码的作用是将用户在控制台输入的内容直接输出到控制台实现了一个简单的输入输出的管道复读机。

动图演示如下

http.createServer((req,res){if(req.method

POST

req.url.includes(/upload)){process.stdout.write(服务端收到了请求);//

req

请求可读流req.pipe(process.stdout);//

res

响应可写流res.write(我是服务端响应);res.end();}else{res.writeHead(404);res.end(Not

Found);}

console.log(服务已经运行在http://localhost:9800);客户端代码文件http-client.js

const

http.request(options,res{process.stdout.write(客户端获取响应);//

res

接口的事件尽可能快地提供给应用程序。

在暂停模式中必须显式调用stream.read()方法读取数据块。

所有可读流一开始都处于暂停模式,之后可以通过以下方式切换到流动模式。

添加data

stream.pause()方法如果有管道目标则移除所有管道目标。

调用

注意​

只有提供了数据消费或忽略数据的机制后可读流才会产生数据。

如果消费的机制被禁用或移除则可读流会停止产生数据。

data当有数据可读时被触发。

end没有更多的数据可读时被触发。

close当流或其底层资源被关闭时被触发。

stream.Readable

readable.read([size])从内部缓冲区拉取并返回数据。

readable.pause()使流动模式的流停止触发data事件并切换出流动模式。

readable.setEncoding(encoding)为从可读流读取的数据设置字符编码。