159 lines
4.9 KiB
Markdown
159 lines
4.9 KiB
Markdown
|
---
|
|||
|
title: Streams
|
|||
|
localeTitle: 流
|
|||
|
---
|
|||
|
## 流
|
|||
|
|
|||
|
Streams在Node.js核心API中可用作允许数据以连续方式读取或写入的对象。基本上,与缓冲区相比,流以块的形式执行该操作,逐位执行,从而使其成为一个缓慢的过程。
|
|||
|
|
|||
|
有四种类型的流可用:
|
|||
|
|
|||
|
* 可读(从中读取数据的流)
|
|||
|
* 可写(写入数据的流)
|
|||
|
* 双工(可读和可写的流)
|
|||
|
* 转换(可在读取和写入时修改数据的双工流)
|
|||
|
|
|||
|
每种可用类型都有几种相关的方法。一些常见的是:
|
|||
|
|
|||
|
* 数据(这在数据可用时运行)
|
|||
|
* 结束(当没有数据可供读取时触发)
|
|||
|
* 错误(当接收或写入数据时出错)
|
|||
|
|
|||
|
### 管
|
|||
|
|
|||
|
在编程中, `pipe`的概念并不新鲜。自20世纪70年代以来,基于Unix的系统一直在实用。管道做什么? `pipe`通常连接源和目的地。它将一个函数的输出作为另一个函数的输入传递。
|
|||
|
|
|||
|
在Node.js中, `pipe`以相同的方式使用,以配对不同操作的输入和输出。 `pipe()`作为一个函数可用,它接受可读的源流并将输出附加到目标流。一般语法可以表示为:
|
|||
|
|
|||
|
```javascript
|
|||
|
src.pipe(dest);
|
|||
|
```
|
|||
|
|
|||
|
多个`pipe()`函数也可以链接在一起。
|
|||
|
|
|||
|
```javascript
|
|||
|
a.pipe(b).pipe(c);
|
|||
|
|
|||
|
// which is equivalent to
|
|||
|
|
|||
|
a.pipe(b);
|
|||
|
b.pipe(c);
|
|||
|
```
|
|||
|
|
|||
|
### 可读流
|
|||
|
|
|||
|
生成可作为输入附加到可写流的数据的流称为可读流。要创建可读流:
|
|||
|
|
|||
|
```javascript
|
|||
|
const { Readable } = require('stream');
|
|||
|
|
|||
|
const readable = new Readable();
|
|||
|
|
|||
|
readable.on('data', chunk => {
|
|||
|
console.log(`Received ${chunk.length} bytes of data.`);
|
|||
|
});
|
|||
|
readable.on('end', () => {
|
|||
|
console.log('There will be no more data.');
|
|||
|
});
|
|||
|
```
|
|||
|
|
|||
|
### 可写流
|
|||
|
|
|||
|
这是一种流的类型,您可以将数据从可读源`pipe()`传输`pipe()` 。要创建可写流,我们有一个构造函数方法。我们从中创建一个对象并传递许多选项。该方法有三个参数:
|
|||
|
|
|||
|
* 块:一个缓冲区
|
|||
|
* 编码:将数据转换为人类可读的形式
|
|||
|
* callback:从块中完成数据处理时调用的函数
|
|||
|
|
|||
|
```javascript
|
|||
|
const { Writable } = require('stream');
|
|||
|
const writable = new Writable({
|
|||
|
write(chunk, encoding, callback) {
|
|||
|
console.log(chunk.toString());
|
|||
|
callback();
|
|||
|
}
|
|||
|
});
|
|||
|
|
|||
|
process.stdin.pipe(writable);
|
|||
|
```
|
|||
|
|
|||
|
### 双工流
|
|||
|
|
|||
|
双工流帮助我们同时实现可读和可写流。
|
|||
|
|
|||
|
```javascript
|
|||
|
const { Duplex } = require('stream');
|
|||
|
|
|||
|
const inoutStream = new Duplex({
|
|||
|
write(chunk, encoding, callback) {
|
|||
|
console.log(chunk.toString());
|
|||
|
callback();
|
|||
|
},
|
|||
|
|
|||
|
read(size) {
|
|||
|
this.push(String.fromCharCode(this.currentCharCode++));
|
|||
|
if (this.currentCharCode > 90) {
|
|||
|
this.push(null);
|
|||
|
}
|
|||
|
}
|
|||
|
});
|
|||
|
|
|||
|
inoutStream.currentCharCode = 65;
|
|||
|
process.stdin.pipe(inoutStream).pipe(process.stdout);
|
|||
|
```
|
|||
|
|
|||
|
`stdin`流将可读数据管道传输到双工流中。 `stdout`帮助我们查看数据。双工流的可读和可写部分完全独立地操作。
|
|||
|
|
|||
|
### 变换流
|
|||
|
|
|||
|
这种类型的流更多是双工流的高级版本。
|
|||
|
|
|||
|
```javascript
|
|||
|
const { Transform } = require('stream');
|
|||
|
|
|||
|
const upperCaseTr = new Transform({
|
|||
|
transform(chunk, encoding, callback) {
|
|||
|
this.push(chunk.toString().toUpperCase());
|
|||
|
callback();
|
|||
|
}
|
|||
|
});
|
|||
|
|
|||
|
process.stdin.pipe(upperCaseTr).pipe(process.stdout);
|
|||
|
```
|
|||
|
|
|||
|
我们消耗的数据与前面的双工流示例相同。这里需要注意的是`transform()`不需要实现`read`或`write`方法。它结合了两种方法本身。
|
|||
|
|
|||
|
### 为什么要使用Streams?
|
|||
|
|
|||
|
由于Node.js是异步的,因此通过将回调传递给具有磁盘和网络的函数来进行交互。下面给出的示例从磁盘上的文件读取数据,并通过来自客户端的网络请求对其进行响应。
|
|||
|
|
|||
|
```javascript
|
|||
|
const http = require('http');
|
|||
|
const fs = require('fs');
|
|||
|
|
|||
|
const server = http.createServer((req, res) => {
|
|||
|
fs.readFile('data.txt', (err, data) => {
|
|||
|
res.end(data);
|
|||
|
});
|
|||
|
});
|
|||
|
server.listen(8000);
|
|||
|
```
|
|||
|
|
|||
|
上面的代码片段将起作用,但在将结果写回客户端请求之前,文件中的所有数据将首先进入每个请求的内存。如果我们正在读取的文件太大,这可能会成为一个非常繁重且昂贵的服务器调用,因为它将消耗大量内存以使进程前进。客户端的用户体验也会受到延迟的影响。
|
|||
|
|
|||
|
在这种情况下,如果我们使用流,则数据一旦从磁盘接收就会一次作为一个块发送到客户端请求。
|
|||
|
|
|||
|
```javascript
|
|||
|
const http = require('http');
|
|||
|
const fs = require('fs');
|
|||
|
|
|||
|
const server = http.createServer((req, res) => {
|
|||
|
const stream = fs.createReadStream('data.txt');
|
|||
|
stream.pipe(res);
|
|||
|
});
|
|||
|
server.listen(8000);
|
|||
|
```
|
|||
|
|
|||
|
`pipe()`在这里负责写入或在我们的情况下,使用响应对象发送数据,并且一旦从文件读取所有数据,就关闭连接。
|
|||
|
|
|||
|
注意: `process.stdin`和`process.stdout`是在Node.js API提供的全局`process`对象的流中构建的。
|