您好,登錄后才能下訂單哦!
這篇文章主要介紹“node.js怎么自定義實(shí)現(xiàn)一個EventEmitter”,在日常操作中,相信很多人在node.js怎么自定義實(shí)現(xiàn)一個EventEmitter問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”node.js怎么自定義實(shí)現(xiàn)一個EventEmitter”的疑惑有所幫助!接下來,請跟著小編一起來學(xué)習(xí)吧!
前言
一、是什么
二、nodejs中EventEmitter使用方法
三、實(shí)現(xiàn)過程
最近做了商品批發(fā)的需求,需要針對不同的商戶選擇對應(yīng)的批發(fā)商品回顯到原來的界面。由于該項(xiàng)目的代碼是公司古董級別(這種代碼都是程序猿的痛),解決問題的時候都是小心翼翼的。為了避免這種問題減少外部依賴,手動封裝事件派發(fā)的函數(shù)。
我們了解到,Node采用了事件驅(qū)動機(jī)制,而EventEmitter就是Node實(shí)現(xiàn)事件驅(qū)動的基礎(chǔ)
在EventEmitter的基礎(chǔ)上,Node幾乎所有的模塊都繼承了這個類,這些模塊擁有了自己的事件,可以綁定/觸發(fā)監(jiān)聽器,實(shí)現(xiàn)了異步操作
Node.js 里面的許多對象都會分發(fā)事件,比如 fs.readStream 對象會在文件被打開的時候觸發(fā)一個事件
這些產(chǎn)生事件的對象都是 events.EventEmitter 的實(shí)例,這些對象有一個 eventEmitter.on() 函數(shù),用于將一個或多個函數(shù)綁定到命名事件上
Node的events模塊只提供了一個EventEmitter類,這個類實(shí)現(xiàn)了Node異步事件驅(qū)動架構(gòu)的基本模式——觀察者模式
在這種模式中,被觀察者(主體)維護(hù)著一組其他對象派來(注冊)的觀察者,有新的對象對主體感興趣就注冊觀察者,不感興趣就取消訂閱,主體有更新的話就依次通知觀察者們
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);
基本代碼如下所示:
//事件派發(fā)機(jī)制 (function() { var EventDispatcher = function() { var EventDispatcherClosure = function() { }; EventDispatcherClosure.prototype = { /** * 注冊事件 * @param {Object} key * @param {Object} fn */ on: function(key, fn) { //獲取當(dāng)前的事件對象 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) { //獲取當(dāng)前的事件對象 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怎么自定義實(shí)現(xiàn)一個EventEmitter”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識,請繼續(xù)關(guān)注億速云網(wǎng)站,小編會繼續(xù)努力為大家?guī)砀鄬?shí)用的文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。