在看我司后端代码时(在此之前基本未接触过后端),发现类似这样的代码:
socket.emit('xxx', xxx);
socket.on('xxx', xxx);
emitter.emit(event, data);
emitter.on(event, callback);
整个人就凌乱了,虽然知道1和2,3和4肯定是一一对应的,但socket和emitter是什么,什么关系,有什么作用,一脸懵逼。
带着这样简单明了的疑惑,开启了后端学习之路。
ps:本来这篇打算写events模块和websocket的,结果发现node.js的水太深,目前就只写node的events模块了,下次再websoket了。(逃)
在说event模块之前,有个问题是绕不过去的,即node.js的事件循环(Event Loop),事件循环允许node.js执行非阻塞IO操作。
1、node.js中Event Loop的6个阶段
当node.js启动的时候,初始化Event Loop,处理输入脚本,这个脚本可以异步调用API、设置时间任务,或者调用process.nextTick(),然后处理事件循环。
image.png图中每一个方框表示事件循环的一个阶段,每个阶段都有自己的回调队列,每当进入某个阶段,都会从所属的队列中取出callback来执行, 当队列为空或者被执行callback的数量达到系统的最大数量时,进入下一阶段
1.1 timers
执行setTimeout() 和 setInterval()中到期的callback。
1.2 I/O callbacks
执行大部分的回调,执行除了 close、timers和setImmediate()设定的回调,主要是指有系统操作引起的回调,比如TCP错误类型的
1.3 idle, prepare
仅内部使用
1.4 poll
获取新的I/O事件, 适当的条件下node将阻塞在这里
poll阶段有两个功能:
- 当timers到达指定的时间后,执行指定的timer的回调
- 处理poll队列的事件
当进入到poll阶段,并且没有定时器任务,会有如下情况:
-
如果poll队列不为空,Event Loop将同步执行poll里的callback,直到队列为空或者执行的callback达到上限
-
如果poll队列为空,
1、如果脚本调用了setImmediate(),Event Loop将会结束poll阶段进入到check阶段执行setImmediate()的回调
2、如果脚本没有调用setImmediate(),Event Loop将会将阻塞在该阶段等待回调被添加到队列中,然后立即执行。 -
一旦poll队列为空,Event Loop会检查是否有timers到达时间,有就回到timer阶段执行callback
1.5 check
执行setImmediate的callback
1.6 close callbacks
执行close事件的callback,例如socket.on("close",func)
2. events模块
events是node.js的核心模块之一,只提供了一个对象:events.EventEmitter。EventEmitter的核心就是事件发射与事件监听器功能的封装。EventEmitter的每个事件由一个事件名和若干个参数组成,事件名是一个字符串。
通过创建EventEmitter可简化与事件循环的交互。
对于每个事件,EventEmitter支持若干个事件监听器。当事件发射时,注册到这个事件的事件监听器被一次调用,事件参数作为回调函数参数传递。
EventEmitter.on(event, listener)
为指定事件注册一个监听器,接受一个字符串event和一个回调函数listener
EventEmitter.emit(event, [arg1], [arg2],[...]),发射event事件,传递若干参数大事件监听器的参数表
。。。还有其他用法就不赘述了。
var EventEmitter = require('events').EventEmitter;
var event = new EventEmitter();
event.on('some_event', function() {
console.log('some_event 事件触发');
});
setTimeout(function() {
event.emit('some_event');
}, 1000);
网友评论