前言

本文介绍nodejs关于流的一些简单内容，对于文件的读写等操作，掌握流的使用是必须的。

流的分类

流分为四类：可读流、可写流、双工流、转换流。

可读流、可写流很好理解，就分别是对文件进行读和写操作的流。

而双工流则是可读流和可写流组合成的对象，是既可以读又可以写的流。

最后转换流顾名思义，可以将写入的数据在同一个流中变成可读的，且通常是某种转换后的形式。（也是可读可写的）

可读流

fs.createReadStream('文件路径')就是一种可读流。
例子中我们可以看到可读流可以监听几个事件，data事件是有数据在读取过程中的的事件，end是读取完毕时的事件，还有error事件可以进行错误监听，比如如果test.txt文件不存在则会报未找到对应文件的错误，还有一些其他事件我就不一一列出了。

import fs from 'fs'
const readStream = fs.createReadStream('test.txt')
let res = ''readStream.on('data', (buffer) => {res += buffer 
})readStream.on('end', () => {console.log(res) // test.txt文件中的内容
})readStream.on('error', (err) => {console.log(err)
})

流的事件是可以链式调用的，下面这样绑定事件运行结果和上面的代码是没有区别的。

import fs from 'fs'
const readStream = fs.createReadStream('test.txt')
let res = ''readStream.on('data', (buffer) => {res += buffer
}).on('end', () => {console.log(res)  // test.txt文件中的内容
}).on('error', (err) => {console.log(err)
})

可写流

fs.createWriteStream('文件路径')就是一种可写流。
配置flags可以修改写入模式。w表示写入数据，会覆盖原内容；a表示追加数据，会在原内容后面添加写入内容。另外还可以有w+与a+，添加+会进行读取操作，也就是先读取再写入与先读取再追加。
可写流调用write方法即可对文件进行写入。
可写流也有自己的一些可监听事件，常用的finish表示写入操作完成。

import fs from 'fs'const writeStream = fs.createWriteStream('out.txt', {flags: 'w', 
})writeStream.write('666')writeStream.on('finish', () => {console.log('写入完成')
}).on('error', (err) => {console.log(err)
})

管道

前面介绍了可读流和可写流，假如我们想要复制一个文件该怎么做呢？

也就是要先读取文件，再写入到新文件。通过前面的知识，我们可以创建可读流获取数据，可写流开始写入：

import fs from 'fs'const readStream = fs.createReadStream('test.txt')
const writeStream = fs.createWriteStream('copy.txt', {flags: 'w'
})let res = ''
readStream.on('data', (buffer) => {res += buffer
}).on('end', () => {writeStream.write(res)  // 在读取结束，将数据用可写流
})

我们想象一下，两个流之间，假如有一个管道能够将它们连接在一起，可读流到可写，就不需要我们手动进行一些操作了。

流之间就有一个pipe方法可以将流与流之间建立管道。

import fs from 'fs'const readStream = fs.createReadStream('test.txt')
const writeStream = fs.createWriteStream('copy.txt', {flags: 'w'
})readStream.pipe(writeStream) // 将可读流直接流入可写流，实现读取再写入的操作

同时也可以添加事件。

在管道前的链式调用事件对象是前面的流（即可读流），在管道之后，链式调用事件的对象就成了管道连接的后面的流了（即可读流）。

readStream.on('end', () => {console.log('读取完毕')
}).pipe(writeStream).on('finish', () => {console.log('写入完毕')
})

双工流

net.connect()和其他Node网络API返回的Socket对象就是双工流。
比如某种流，其中有可写流用于向服务器发送消息，可读流用于接受服务器消息，这就是一种通过可读流可写流组合在一起形成的双工流。

转换流

zlib.createGzip()可以压缩文件数据，其就是一种转换流。
可读流可以与它建立管道让它写入，可以证明它可写；它可以读取数据与可写流建立管道，可以证明它可读。由此可以得出，它就是可读可写的转换流。

import fs from 'fs'
import zlib from 'zlib'const readStream = fs.createReadStream('test.txt')
const duplexStream = zlib.createGzip()
const writeStream = fs.createWriteStream('test.txt.gz', {flags: 'w'
})
readStream // 读.pipe(duplexStream) // 转换流压缩.pipe(writeStream)  // 写