《Node.js高级编程》之Node 核心API基础

时间:2021-09-27 12:13:02

Node 核心API基础

  • 第三章 加载模块
  • 第四章 应用缓冲区
  • 第五章 事件发射器模式简化事件绑定
  • 第六章 使用定时器制定函数执行计划

第三章 加载模块

本章提要

  • 加载模块
  • 创建模块
  • 使用node_modules文件夹

问题:

  • 全局名称空间,共享
  • 安全性问题、冲突、难以跟踪与解决。

Node解决

  • 使用了CommonJS模块标准。
  • 划分模块,根本没有全局作用域

3.1 理解Node如何加载模块

文件路径 + 名称

核心模块会预先加载

NPM安装模块

var module = require('module_name');

该对象表示模块对外暴露的 JavaScript API

它可以是一个函数,也可以是一个具有若干属性的对象,

属性可能是函数、数组,或者是其他类型。

3.2 导出模块

CommonJS模块系统

文件共享对象,函数.

模块和文件一一对应。

function Circle(x,y,r){
function r_squared(){
return Math.pow(r,2);
} function area(){
return Math.PI * r_squared();
} return {
area : area
}
} module.exports = Circle;

module.exports

  • 模块向需要它的脚本所导出的对象,可以是任意对象。

模块代码

function printA(){
console.log('A');
} function printB(){
console.log('B');
} function printC(){
console.log('C');
} module.exports.printA = printA;
module.exports.printB = printB;
module.exports.pi = Math.PI;

引用模块

var myModule2 = require('./myModule2');
myModule2.printA();
myModule2.printB();
console.log(myModule2.pi);

3.3 加载模块

require函数不会改变全局名称空间的状态,Node种根本没有全局名称空间的概念。

3.3.1 加载核心模块

核心模块,二进制形式发布的模块。

只能通过模块名,而不能通过文件路径。

require(fs)

3.3.2 加载文件模块

提供绝对路径 或相对路径

从文件系统加载非核心模块

var myModule = require ('/home/carvendy/my_modules/my');

可以省略.js的扩展名

3.3.3 加载文件夹模块

var myModule = require('./myModuleDir');

查找包定义,package.json

包不存在就会找 index.js

3.3.4 从node_modules 文件夹加载

如果一个模块既不是相对路径,也不是核心模块,

那么就会尝试在当前目录下的 node_modules文件中查找。

var myModule = require('myModule.js');

当前目录没有myModule.js,就会往上一级父目录查找,持续到达根目录。

推荐还是让NPM来管理

3.3.4 缓存模块

模块在首次加载时,会被缓存起来,这意味着能被解析为相同的文件名。

console.log('module my_module initializing...');
module.exports = function (){
console.log('Hi!');
}
console.log('my_module initialized.');

然后加载

var myModule = require('./my_module');

输出

module my_module initializing...

module my_module initialized.

加载两次效果一样

模块在初始化,可能会有副作用

总结

  • CommonJS模块系统取代,js默认全局名称空间
  • 避免是安全性问题和错误。
  • 使用require()加载模块
  • 还可以编写 JavaSript导出的模块API

第四章 应用缓冲区处理、编码和解码二进制数据


#### 本章提要
- 理解Node 中为何需要缓冲区
- 用字符串创建缓冲区
- 将缓冲区转换成字符串
- 在缓冲区中处理数据
- 切分和复制缓冲区

问题

  • js 善于处理字符串,但是它是被设计处理HTML,不擅长处理二进制数据。
  • js没有字节类型,没有结构化类型,甚至没有字节数组
  • 只有数值类型和字符串

Node 解决

  • 处理HTTP文本协议
  • 数据库通信、图像操作。
  • 前期,使用字符串处理二进制,性能底下。
  • 于是,引入了二进制缓冲区。(字节为计量单位)

补充

Buffer类的另一特别之处是数据占用的内存并不是分配JavaScript VM内存堆,这些对象不会被垃圾收集算法处理。

它会占据一个不会被修改的永久内存地址,这避免了因缓冲区内容的内存复制所造成的CPU浪费。

4.1 创建缓冲区

var buf = new Buffer('Hello World');//使用utf-8
var buf = new Buffer('8b76fdes713ce','base64');

编码

  • ascii, ASCII字符集
  • utf8, UTF-8
  • base64,Base64个可打印的ASCII字符

如果缓冲区没有具体内容初始化,那么可以指定容量大小创建,备用

var buf = new Buffer(1024);

4.2 在缓冲区中获取和设置数据

查看某个字节

var buf = new Buffer('my buffer content');
console.log(buf[10]);//-->99 (随机值)

注意

  • 设置一个大于255的数,将会用256对该数取模,赋值。
  • 设置256,实际上被赋值为0
  • 设置为100.7的小数,只会存储100
  • 如果尝试给超出缓冲区边界的位置赋值,那么将会失败告终。
var buf = new Buffer(100);
console.log(buf.length);

4.3 切分缓冲区

对于已经创建的缓冲区,也许需要提取一部分。

var buffer = new Buffer('this is the content of my buffer');
var smallerBuffer = buffer.slice(8,9);
console.log(smallerBuffer.toString());

注意

切缓冲区,并没有分配新的内存。只不过引用父缓冲区的起始和结束位置。

修改父,删除父,可能会有错误,或内存泄漏。

4.4 赋值缓冲区

var buffer = new Buffer('this is the content of my buffer');
var smallerBuffer = buffer.slice(8,19);
console.log(smallerBuffer.toString()); var buf1 = new Buffer('this is the content of my buffer');
var buf2 = new Buffer(11); var targetStart = 0;
var sourceStart = 8;
var sourceEnd = 19; buf1.copy(buf2, targetStart , sourceStart , sourceEnd);
console.log(buf2.toString());

** 4.5 缓冲区解码**

var buf = new Buffer('this is the content of my buffer');
var str = buf.toString('base64');

打印

bXkgc3RyaW5n

第五章 使用事件发射器模式简化事件绑定


#### 本章提要:
- 事件发射器模式简介
- 绑定和解绑事件监听器
- 创建自定义的事件发射器

发射事件

类似于发布/订阅模式。

5.1 理解标准回调模式

异步编程不使用函数返回值代表结束,而使用后继传递。

每个函数执行完毕后都会调用一个回调函数。

var fs =  require('fs');
fs.readFile('/etc/passwd',function(err,fileContent){
if(err){
throw err;
}
console.info('file content',fileContent.toString());
});

5.2 理解事件发射器模式

缺点

如果在函数执行过程中发生了很多事件,或者事件反复多次出现。

这样工作就不太好了。

事件发射器

看月发射事件的兑现,而事件监听器则是绑定到事件发射器上的代码,

负责监听特定类型的事件

var req = http.request(options,function(response){
response.on("data",function(data){
console.log("some data",data);
});
response.on("end",function(){
console.log("response ended");
});
});

PS

  • 当需要在请求操作完成智慧重新获取控制权看月使用CPS模式
  • 当事件可以发生多次时,就使用事件发射器模式

5.3 理解事件类型

事件类型

按照一般约定,事件类型都是由不包含开个的小写单词组成的。

无法通过编程判断发射了哪些类型的事件,API没有提供内省机制。

error事件

如果程序员选择不监听"error"事件,当事件发生是,事件发射器注意到它,并抛出未捕获异常。

var em = new (require('events').EventEmitter)();
em.emit('event1');//没有的事件
em.emit('error', new Error('My mistake'));// error马上打印堆栈

5.4 应用事件发生器API

方法

  • .addListener 和.on —— 添加事件监听
  • .once ——指定,并只邦定一个近被调用一次
  • .removeEventListener ——删除
  • .removeAllEventListener ——删除所有绑定的事件

5.4.1 使用.addListener或.on 绑回调函数

function receiveData(data){
console.info("got data from server");
}
readStream.addListener("data",receiveData);

分析

当有可用数据块时,文件可读流就会发射“data”事件

可以使用on代替:

readStream.on("data",receiveData);

PS:

data事件可能会传递数据缓冲区,error事件可能会传递一个错误对象,而流“end”事件则不向事件监听器传递任何参数。

5.4.2 绑定多个事件监听器

readStream.on("data",function(data){
console.log('I have data');
});
readStream.on("data",function(data){
console.log('I have data 2');
});

PS:

  • 有注册顺序
  • 监听器没有执行,可能是前面还有一个监听器
  • 异常,可能会永远不会被执行。
  • 第一个事件抛错误了,第二个监听器就不会执行。

5.4.3 .removeListener 删除

5.4.4. .once() 最多执行一次

var event = require('events').EventEmitter;
EventEmitter.prototype.once = function (type,callbak){
var that = this;
this.on(type,function listener(){
that.removeListener(type,listener);
callback.apply(that,arguments);//参数原封不动传递,再调回调函数
});
}

.removeAllListeners

5.5 创建事件发射器

5.5.1 从Node事件发射器继承

var util = require('util');
var events = require('events').EventEmitter;
var MyClass = function(){
//原型链
util.inherits(MyClass, EventEmitter);
}

发射事件

MyClass.prototype.someMethod = function (){
this.emit("custom event","argument 1","argument 2");
} // 触发
var myClazz = new MyClass();
myClazz.on('custom event',function(str1,str2){
console.log("one:%s,two:%s",str1,str2);
}); myClazz.someMethod();

第六章 定时器指定函数执行计划


#### 本章提要
- 推迟函数的执行
- 取消执行计划
- 指定函数的周期行执行计划
- 将函数执行推迟到下一轮事件循环

Node全面实现一组函数,它们被用来再服务端辅助不通进程进行后期限或者推迟执行。

6.1 使用 setTimeout推迟

var timeout_ms = 2000;
var timeout = setTimeout(functino({
console.log('do sime');
}),timeout_ms);
clearTimeout(timeout);//取消函数计划

6.2 指定和取消函数的重复执行计划

var period = 1000;
setInterval(function(){
console.log("tick");
},period);

6.4 使用process.nextTick将函数执行推迟到下一个事件循环

有时候不需要立刻执行。

事件循环在一个处理事件队列的循环运行,事件循环每执行一次就被称为一个"tick"

process.nextTick 比激活超时队列块。

process.nextTick(function(){
my_expensive_conmputation_function();
});

6.5 阻塞队列事件循环

单线程事件循环。

运行时调用相关回调函数来处理队列的下个事件。

特殊情况,如果某个回调占用事件长,整个服务就会非常缓慢。

[阻塞]

process.nextTick(function nextTick1(){
var a = 0;
while(true){
a++;
}
}); process.nextTick(function nextTick2(){
console.log("2.....");
}); setTimeout(function timeout(){
console.log(1);
},1000);

6.6 推出事件循环

释放事件

6.7 使用 setTimeout 代替setInteval 前置函数串行

var inteval = 1000;
setInterval(function(){
my_async_function(function(){
console.log('finished...!');
});
});