淺談node的事件機制
Node.js uses an event-driven, non-blocking I/O model that makes it lightweight and efficient.
在nodejs的官方文檔中,明確寫出了node的一個特性是event-driven(事件驅動),可見其非常重要。查看源碼,我們可知其事件機制為用js寫的EventEmitter類,寫得非常優(yōu)雅且應用了發(fā)布/訂閱模式。
通過實現(xiàn)一個簡易的、具有發(fā)布/訂閱模式的事件機制,以此來理清EventEmitter類的實現(xiàn)思路
Publish/Subscribe(發(fā)布/訂閱模式)
類比
要講的是一個模式,模式這個詞,聽起來就很抽象。我們先舉個栗子。假設有一家報紙機構,提供晨報、午報、晚報。如果你想要看某種報紙,你需要向報紙機構訂閱,等對應的報紙發(fā)布出來后,報紙機構就會通知你來拿報紙。
在這個過程中,報紙機構實現(xiàn)了兩個功能,一是接受客戶的訂閱;二是發(fā)布不同類型的報紙。發(fā)布報紙的時候,訂閱該類型報紙的客戶就能接收到通知。
這個報紙機構也就是我們要實現(xiàn)的事件機制。

目的
從上面的例子可以看出:1.發(fā)布報紙;2.將報紙給到客戶;這個連續(xù)的過程由于報紙機構的存在,變成了可以先訂閱,再發(fā)布,等到發(fā)布就自動送到客戶手中,實現(xiàn)了動作時間上的分離。這也是發(fā)布/訂閱系統(tǒng)的優(yōu)勢。
實現(xiàn)思路
我們有3種報紙,對應3個事件,每個事件發(fā)生時要通知客戶。對應的數(shù)據(jù)格式可以如下:
var Event = {
morning: event1,
noon: event2,
night: event3
}
由于每種報紙都可能有不止一個人訂閱,那么格式可優(yōu)化成這樣:
var Event = {
morning: [e11, e12,...],
noon: [e21, e22],
night: event3
}
當用戶訂閱的時候,我們就將其事件添加對應的數(shù)組中;當事件發(fā)布的時候,就執(zhí)行相應事件。說白了就是先存儲后使用。
具體代碼如下:
1.on表示訂閱,將事件添加到對應數(shù)組中
2.emit表示發(fā)布,將對應數(shù)組中的數(shù)據(jù)取出來執(zhí)行
3.off表示刪除無用的事件
var Event = {
on: function(key, listener) {
if (!this.__events) {
this.__events = {}
}
if (!this.__events[key]) {
this.__events[key] = [];
}
if (_indexOf(this.__events[key], listener) == -1 && typeof listener === 'function') {
this.__events[key].push(listener)
}
},
emit: function(key) {
if (!this.__events || !this.__events[key]) return
//取得每次訂閱不同的參數(shù)
var arg = Array.prototype.slice.call(arguments, 1) || [];
var listeners = this.__events[key];
var len = listeners.length;
for (var i=0; i<len; i++) {
listeners[i].apply(this, arg)
}
return this
},
off: function(key, listener) {
if (!key && !listener) {
this.__events = {}
}
if (key && !listener) {
delete this.__events[key]
}
if (key && listener) {
var listeners = this.__events[key];
var index = _indexOf(listeners, listener);
(index > -1) && listeners.splice(index, 1);
}
return this
}
}
var _indexOf = function(array,key){
if (array === null) return -1
var i = 0, length = array.length
for (; i < length; i++) if (array[i] === key) return i
return -1
}
//調用
Event.on('console1', function(num) {
console.log(num); // 1
});
Event.emit('console1', 1)
node的EventEmitter
node的EventEmitter基本邏輯和上面提供的例子基本一樣,只是更加復雜些。
1.訂閱事件on
function _addListener(target, type, listener, prepend) {
var m;
var events;
var existing;
if (typeof listener !== 'function')
throw new TypeError('"listener" argument must be a function');
events = target._events;
...
if (typeof existing === 'function') {
// Adding the second element, need to change to array.
existing = events[type] =
prepend ? [listener, existing] : [existing, listener];
} else {
// If we've already got an array, just append.
if (prepend) {
existing.unshift(listener);
} else {
existing.push(listener);
}
}
return target;
}
EventEmitter.prototype.addListener = function addListener(type, listener) {
return _addListener(this, type, listener, false);
};
EventEmitter.prototype.on = EventEmitter.prototype.addListener;
2.發(fā)布事件
EventEmitter.prototype.emit = function emit(type) {
...
handler = events[type];
switch (len) {
// fast cases
case 1:
emitNone(handler, isFn, this);
break;
case 2:
emitOne(handler, isFn, this, arguments[1]);
break;
case 3:
emitTwo(handler, isFn, this, arguments[1], arguments[2]);
break;
case 4:
emitThree(handler, isFn, this, arguments[1], arguments[2], arguments[3]);
break;
// slower
default:
args = new Array(len - 1);
for (i = 1; i < len; i++)
args[i - 1] = arguments[i];
emitMany(handler, isFn, this, args);
}
}
講到這里,相信大家已經(jīng)明白EventEmitter的實現(xiàn)思路。
參考資料
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
基于Express+multer實現(xiàn)文件上傳功能
Multer是Node.js中的一個第三方包,或者說是第三方中間件,主要用于是實現(xiàn)文件上傳的功能,本文小編講給大家詳細介紹一下基于Express+multer來實現(xiàn)文件上傳功能,文章通過代碼示例和圖文介紹的非常詳細,需要的朋友可以參考下2023-11-11
基于Node.js實現(xiàn)數(shù)據(jù)轉換工具
在前端項目中,利用?Excel?表格和?Node.js?實現(xiàn)數(shù)據(jù)轉換工具,可以有效優(yōu)化增刪改查等功能,下面小編就來和大家講講具體的實現(xiàn)步驟吧2025-02-02
Node.js中Process.nextTick()和Process.setImmediate()的區(qū)別
這篇文章介紹了Node.js中Process.nextTick()和Process.setImmediate()的區(qū)別,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-07-07
Node.js+ES6+dropload.js實現(xiàn)移動端下拉加載實例
這個demo服務由Node搭建服務、下拉加載使用插件dropload,數(shù)據(jù)渲染應用了ES6中的模板字符串。有興趣的小伙伴可以自己嘗試下2017-06-06

