Nodejs中的stream模块

如今简单说一下，nodejs中的stream模块。

fs   》fileSystem 文件系统，提供了不少的方法，方法有同步与异步。只不过异步中多了一个callback，里面的第一参数是错误对象。

流（stream）在 Node.js 中是处理流数据的抽象接口（abstract interface）。 stream 模块提供了基础的 API 。使用这些 API 能够很容易地来构建实现流接口的对象。

Node.js 提供了多种流对象。 例如， HTTP 请求 和 process.stdout 就都是流的实例。

流能够是可读的、可写的，或是可读写的。全部的流都是 EventEmitter 的实例。

首先了解一下stream模块的分类

在nodejs中，有四种stream类型：
Readable：用来读取数据，好比 fs.createReadStream()。
Writable：用来写数据，好比 fs.createWriteStream()。
Duplex：可读+可写，好比 net.Socket()。
Transform：在读写的过程当中，能够对数据进行修改，好比 zlib.createDeflate()（数据压缩/解压）。复制代码

简单读取的一个txt文件。

let fs = require("fs");let path = require("path");
let result = fs.readFileSync(path.join(__dirname,"./1.txt"),'utf8');复制代码

一、Buffer 的乱码问题。

let buffer = Buffer.from("前端好好");let buff1= buffer.slice(0,5);let buff2= buffer.slice(5);console.log(buff1.toString());console.log(buff2.toString());

这样会输出乱码以下。
前��好好=》解决上面的方法是用了一个模块

复制代码

let buffer = Buffer.from("前端好好");let buff1 = buffer.slice(0, 5);let buff2 = buffer.slice(5);
let { StringDecoder } = require('string_decoder');
let sd = new StringDecoder();console.log(sd.write(buff1).toString());console.log(sd.write(buff2).toString());

如今输出就正常了。
前端好好
复制代码

ps： 输出路径问题

#！/usr/bin/env node

复制代码

可读流：例子以下.把“hello world”写到1.txt里面去。

var fs = require('fs');
var content = 'hello world';
var filepath = './1.txt';

fs.writeFile(filepath, content);复制代码