当前位置：首页 > news >正文

Node.js：Stream、模块系统

news 2025/7/21 19:47:23

Stream流

Stream是一个抽象接口，Node中有很多的对象实现了这个接口。例如，对这个http服务器发起请求的一个request对象就是一个Stream，还有stdout(标准输出)

Readable 可读操作
Writable 可写操作
Durplex 可读可写操作
Transform 操作被写入数据，然后读出结果
所有的Stream对象都是EventEmitter的实例
data 当有数据可读时触发
end 没有更多的数据可读时触发
error 在接收和写入过程中发生错误时触发
finish 所有数据已被写入到底层系统时触发

从流中读取数据

创建input.txt文件，内容如下：

var fs = require('fs');
var data = '';
//创建可读流
var readerStream = fs.createReadStream('input.txt');
//设置编码为utf-8
readerStream.setEncoding('UTF8');
//处理流事件-->data,end,and error
readerStream.on('data',function(chunk){data += chunk;
});
readerStream.on('end', function(){console.log(data);
});
readerStream.on('error', function(err){console.log(err.stack);
});
console.log("程序执行完毕!");

写入流

var fs = require('fs');
var data = 'DooooooooG';
//创建可读流
var writeStream = fs.createWriteStream('input.txt');
//设置编码为utf-8
writeStream.write(data,'UTF8');
//标记文件末尾
writeStream.end();
//处理时间-->finish、error
writeStream.on('finish', function(){console.log("写入完成");
});
writeStream.on('error', function(err){console.log(err.stack);
})
console.log("程序执行完毕！");

管道流

管道提供了一个输出流到输入流的机制，通常我们用于从一个流中获取数据并且将数据传递到另一个流当中
下面的实例中，将一个文件的内容通过管道写入到另一个文件

var fs = require("fs");
var inputStream = fs.createReadStream("input.txt");
var outputStream = fs.createWriteStream("output.txt");
inputStream.pipe(outputStream);
console.log("程序执行完毕！");

链式流

链式流是通过链接输出流到另外一个流并创建多个流操作链的机制。链式流一般用于管道操作
接下来我们用管道和链式流来压缩和解压文件

压缩文件

var fs = require("fs");
var zlib = require("zlib");
fs.createReadStream("input.txt").pipe(zlib.createGzip()).pipe(fs.createWriteStream('input.txt.gz'));
console.log("文件压缩完成！");

解压文件

var fs = require("fs");
var zlib = require('zlib');
// 解压 input.txt.gz 文件为 input.txt
fs.createReadStream('input.txt.gz').pipe(zlib.createGunzip()).pipe(fs.createWriteStream('input.txt'));console.log("文件解压完成。");

Node.js模块系统

为了让Node.js的文件可以相互调用，Node.js提供了简单的模块系统
模块Node.js应用程序的基本组成部分，文件和模块是一一对应的，一个node.js文件就是一个和模块，这个文件可能是js代码，可能是JSON或者编译过的C/C++拓展

引入模块

在Node.js中引入一个模块非常简单，直接创建文件然后引入代码即可

var hello = require('./hello');
hello.world();

默认node.js引入文件的后缀是.js文件，我们在hello.js中这样定义一个外部函数

//hello.js
export.world = function(){console.log("Hello world!");
}

引入对象模块

可以把一个类的定义写在外部的模块中，就像这样

//dog.js
function Dog(){var uname = "Default";var age = 0;this.show=function(){console.log(this.uname + " " + this.age);};this.Sayhello = function(){console.log("Hello World!");};
};
module.exports = Dog;//demo.js
var Dog = require('./dog');
var coco = new Dog("Coco", 2);
coco.uname = "Coco";
coco.age = 2;
coco.show();
coco.Sayhello();

Coco 2
Hello World!

服务端的模放在哪里

Node.js 中自带了一个叫做 http 的模块，在我们的代码中请求它并把返回值赋给一个本地变量。
这把我们的本地变量变成了一个拥有所有 http 模块所提供的公共方法的对象。
Node.js 的 require 方法中的文件查找策略如下：
由于 Node.js 中存在 4 类模块（原生模块和3种文件模块），尽管 require 方法极其简单，但是内部的加载却是十分复杂的，其加载优先级也各自不同。
请添加图片描述