网站发布到互联网上的步骤,app引流推广怎么做,零陵区住房和城乡建设局网站,百度广告代理商查询#x1f308; Node.js 的流
#x1f680;什么是流
流不是 Node.js 特有的概念。它们是几十年前在 Unix 操作系统中引入的。
我们可以把流看作这些数据的集合#xff0c;就像液体一样#xff0c;我们先把这些液体保存在一个容器里#xff08;流的内部缓冲区 BufferList Node.js 的流
什么是流
流不是 Node.js 特有的概念。它们是几十年前在 Unix 操作系统中引入的。
我们可以把流看作这些数据的集合就像液体一样我们先把这些液体保存在一个容器里流的内部缓冲区 BufferList等到相应的事件触发的时候我们再把里面的液体倒进管道里并通知其他人在管道的另一侧拿自己的容器来接里面的液体进行处理。 Node.js中的流是一种处理数据的抽象接口它提供了一种有效的方式按需处理数据来读取或写入大量数据而无需一次性将整个数据加载到内存中。流可以被视为数据在某段时间内从一个点移动到另一个点的序列类似于水从一根管子的一端流到另一端。 Node.js流的好处
Node.js流解决了处理大量数据时可能遇到的内存消耗和性能问题。以下是使用Node.js流的好处 内存效率使用流可以按需处理数据而不需要一次性将整个数据加载到内存中。这意味着即使处理大量数据也可以节省大量的内存空间。流以块的形式处理数据每次只加载和处理一小部分数据然后将其释放从而减少了内存的使用量。 性能优化由于流以块的形式处理数据可以实现并行处理提高处理速度。流还可以通过流水线pipeline的方式将多个操作连接起来实现数据的连续处理从而提高整体性能。 响应性使用流可以实现实时处理数据即在数据到达时立即进行处理而不需要等待整个数据加载完成。这对于需要实时处理数据的应用程序非常重要例如实时日志分析、实时聊天等。 可扩展性流是可组合的可以将多个流连接起来形成更复杂的数据处理流程。这种可组合性使得代码更加模块化和可重用便于扩展和维护。 适用于各种场景Node.js流可以用于处理各种类型的数据包括文件、网络请求、数据库查询结果等。无论是处理大文件、处理网络请求还是处理数据库查询结果使用流都可以提供高效的数据处理方式。
Node.js流的重点知识
以下是关于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 响应、服务器的 HTTP请求、fs 的读取流、zlib 流、crypto 流、TCP Socket、子进程 stdout与stderr、process.stdin 等。所有可读流都实现了 stream.Readable 类定义的接口。
fs读取文件案例
文件fs读取文件.js
const fs require(fs);
// 创建可读流
const rs fs.createReadStream(./movie.txt);let content ;
// 当有数据可读时触发data事件
rs.on(data, chunk {// 将读取的数据块拼接到content变量中content chunk;
});// 当可读流结束时触发end事件
rs.on(end, () {// 所有数据已读取完毕输出content内容console.log(content);
});文件movie.txt
The best time to plant a tree is 20 years ago.
The second-best time is now.
种一棵树最好的时间是20年前
其次是现在输出结果
PS D:\WuWorkSpace\code\NodejsProject\nodejs实战学习\【第2章 Node.js基础】\2.7 Node的流 node .\fs可读流.js
The best time to plant a tree is 20 years ago.
The second-best time is now.
种一棵树最好的时间是20年前
其次是现在process.stdin案例 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案例
客户端的 HTTP 响应、服务器的 HTTP请求是可读流。
服务端文件http-server.js
const http require(http);
const server http.createServer((req,res){if(req.method POST req.url.includes(/upload)){process.stdout.write(服务端收到了请求);// req 服务器的 HTTP 请求可读流req.pipe(process.stdout);// res 服务器的 HTTP 响应可写流res.write(我是服务端响应);res.end();}else{res.writeHead(404);res.end(Not Found);}
})
server.listen(9800);
console.log(服务已经运行在http://localhost:9800);客户端代码文件http-client.js
const http require(http);
const options {hostname : 127.0.0.1,port : 9800,path : /upload,method : POST
};
const req http.request(options,res{process.stdout.write(客户端获取响应);// res 客户端的 HTTP 响应可读流res.pipe(process.stdout);
})// req 客户端的 HTTP 请求可写流
req.write(我是客户端。);
req.end();以下是运行演示先运行服务端代码 http-server.js 再运行客户端代码http-client.js。
$ node .\http-client.js
客户端获取响应我是服务端响应$ node .\http-server.js
服务已经运行在http://localhost:9800
服务端收到了请求我是客户端。··
可读流de两种模式
可读流有两种模式:流动(Flowing)和暂停(Paused )。在流动模式中数据被自动从底层系统读取并通过 EventEmitter 接口的事件尽可能快地提供给应用程序。在暂停模式中必须显式调用stream.read()方法读取数据块。 所有可读流一开始都处于暂停模式,之后可以通过以下方式切换到流动模式。
添加data 事件处理函数。调用stream.resume()方法。调用 stream.pipe()方法。
可读流也可以通过以下方式切换回暂停模式。
如果没有管道目标则调用 stream.pause()方法如果有管道目标则移除所有管道目标。调用 stream.unpipe()方法可以移除多个管道目标。
注意 : 只有提供了数据消费或忽略数据的机制后可读流才会产生数据。如果消费的机制被禁用或移除则可读流会停止产生数据。
stream.Readable类定义的主要事件:
data当有数据可读时被触发。end没有更多的数据可读时被触发。close当流或其底层资源被关闭时被触发。
stream.Readable 类定义的主要方法
readable.read([size])从内部缓冲区拉取并返回数据。readable.pause()使流动模式的流停止触发data事件并切换出流动模式。readable.setEncoding(encoding)为从可读流读取的数据设置字符编码。