node.js如何自定義實現(xiàn)一個EventEmitter
前言
最近做了商品批發(fā)的需求,需要針對不同的商戶選擇對應(yīng)的批發(fā)商品回顯到原來的界面。由于該項目的代碼是公司古董級別(這種代碼都是程序猿的痛),解決問題的時候都是小心翼翼的。為了避免這種問題減少外部依賴,手動封裝事件派發(fā)的函數(shù)。
一、是什么
我們了解到,Node采用了事件驅(qū)動機制,而EventEmitter就是Node實現(xiàn)事件驅(qū)動的基礎(chǔ)
在EventEmitter的基礎(chǔ)上,Node幾乎所有的模塊都繼承了這個類,這些模塊擁有了自己的事件,可以綁定/觸發(fā)監(jiān)聽器,實現(xiàn)了異步操作
Node.js 里面的許多對象都會分發(fā)事件,比如 fs.readStream 對象會在文件被打開的時候觸發(fā)一個事件
這些產(chǎn)生事件的對象都是 events.EventEmitter 的實例,這些對象有一個 eventEmitter.on() 函數(shù),用于將一個或多個函數(shù)綁定到命名事件上
二、nodejs中EventEmitter使用方法
Node的events模塊只提供了一個EventEmitter類,這個類實現(xiàn)了Node異步事件驅(qū)動架構(gòu)的基本模式——觀察者模式
在這種模式中,被觀察者(主體)維護著一組其他對象派來(注冊)的觀察者,有新的對象對主體感興趣就注冊觀察者,不感興趣就取消訂閱,主體有更新的話就依次通知觀察者們
const EventEmitter = require('events')
class MyEmitter extends EventEmitter {}
const myEmitter = new MyEmitter()
function callback() {
console.log('觸發(fā)了event事件!')
}
myEmitter.on('event', callback)
myEmitter.emit('event')
myEmitter.removeListener('event', callback);
三、實現(xiàn)過程
基本代碼如下所示:
//事件派發(fā)機制
(function() {
var EventDispatcher = function() {
var EventDispatcherClosure = function() {
};
EventDispatcherClosure.prototype = {
/**
* 注冊事件
* @param {Object} key
* @param {Object} fn
*/
on: function(key, fn) {
//獲取當前的事件對象
var curEvents = this._getCurEvents(key);
//先檢查該事件是否已經(jīng)注冊過了
var flag = false;
for (var i = 0, len = curEvents.length; i < len; i++) {
if (curEvents[i].name == fn.name) {
//已經(jīng)出現(xiàn)過了,以最新注冊的函數(shù)為主
flag = true;
curEvents[i] = fn;
break;
}
}
if (!flag) {
curEvents[curEvents.length] = fn;
}
this._register(key, curEvents);
},
/**
* 派發(fā)事件
* @param {Object} key
* @param {Object} data
*/
dispatch: function(key) {
//獲取當前的事件對象
var curEvents = this._getCurEvents(key);
var shouldDispatch = true;
for (var i = 0, len = curEvents.length; shouldDispatch && i < len; i++) {
try {
//獲取參數(shù)
var args = [];
for (var j = 1, len1 = arguments.length; j < len1; j++) {
args.push(arguments[j]);
}
shouldDispatch = curEvents[i].apply({}, args);
} catch (e) {
shouldDispatch = false;
}
}
return shouldDispatch;
},
remove: function(key) {
if (this._getCurEvents(key)) {
delete EventDispatcherClosure.events[key];
}
},
/**
* 根據(jù)key獲取事件列表
* @param {Object} key
*/
_getCurEvents: function(key) {
return EventDispatcherClosure.events[key] || [];
},
/**
* 注冊時間
* @param {Object} key
* @param {Object} events
*/
_register: function(key, events) {
EventDispatcherClosure.events[key] = events;
},
};
EventDispatcherClosure.events = {};
return {
create: function() {
return new EventDispatcherClosure();
}
};
};
window.EventDispatcher = new EventDispatcher().create();
})();
首先定義一個全局變量的匿名函數(shù),然后將全局變量掛在window上面,這樣可以讓我們在開發(fā)過程中的調(diào)用。在匿名函數(shù)的原型鏈上面添加事件分發(fā)、事件監(jiān)聽、事件刪除等方法。
事件分發(fā)的調(diào)用
EventDispatcher.dispatch("test", obj)
事件監(jiān)聽
EventDispatcher.on("test", function callback(obj) {
})
事件刪除
EventDispatcher.on("test")
代碼封裝的比較簡單
到此這篇關(guān)于node.js如何自定義實現(xiàn)一個EventEmitter的文章就介紹到這了,更多相關(guān)node實現(xiàn)EventEmitter內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Node.js設(shè)置CORS跨域請求中多域名白名單的方法
這篇文章主要介紹了Node.js設(shè)置CORS跨域請求中多域名白名單的方法,文中通過示例代碼介紹的非常詳細,相信對大家具有一定的參考價值,需要的朋友們下面來一起看看吧。2017-03-03
Node.js web 應(yīng)用如何封裝到Docker容器中
這篇文章主要介紹了Node.js web 應(yīng)用如何封裝到Docker容器中,幫助大家更好的學習node.js和使用docker容器,感興趣的朋友可以了解下2020-09-09

