淺談node的事件機(jī)制
Node.js uses an event-driven, non-blocking I/O model that makes it lightweight and efficient.
在nodejs的官方文檔中,明確寫出了node的一個(gè)特性是event-driven(事件驅(qū)動),可見其非常重要。查看源碼,我們可知其事件機(jī)制為用js寫的EventEmitter類,寫得非常優(yōu)雅且應(yīng)用了發(fā)布/訂閱模式。
通過實(shí)現(xiàn)一個(gè)簡易的、具有發(fā)布/訂閱模式的事件機(jī)制,以此來理清EventEmitter類的實(shí)現(xiàn)思路
Publish/Subscribe(發(fā)布/訂閱模式)
類比
要講的是一個(gè)模式,模式這個(gè)詞,聽起來就很抽象。我們先舉個(gè)栗子。假設(shè)有一家報(bào)紙機(jī)構(gòu),提供晨報(bào)、午報(bào)、晚報(bào)。如果你想要看某種報(bào)紙,你需要向報(bào)紙機(jī)構(gòu)訂閱,等對應(yīng)的報(bào)紙發(fā)布出來后,報(bào)紙機(jī)構(gòu)就會通知你來拿報(bào)紙。
在這個(gè)過程中,報(bào)紙機(jī)構(gòu)實(shí)現(xiàn)了兩個(gè)功能,一是接受客戶的訂閱;二是發(fā)布不同類型的報(bào)紙。發(fā)布報(bào)紙的時(shí)候,訂閱該類型報(bào)紙的客戶就能接收到通知。
這個(gè)報(bào)紙機(jī)構(gòu)也就是我們要實(shí)現(xiàn)的事件機(jī)制。
目的
從上面的例子可以看出:1.發(fā)布報(bào)紙;2.將報(bào)紙給到客戶;這個(gè)連續(xù)的過程由于報(bào)紙機(jī)構(gòu)的存在,變成了可以先訂閱,再發(fā)布,等到發(fā)布就自動送到客戶手中,實(shí)現(xiàn)了動作時(shí)間上的分離。這也是發(fā)布/訂閱系統(tǒng)的優(yōu)勢。
實(shí)現(xiàn)思路
我們有3種報(bào)紙,對應(yīng)3個(gè)事件,每個(gè)事件發(fā)生時(shí)要通知客戶。對應(yīng)的數(shù)據(jù)格式可以如下:
var Event = { morning: event1, noon: event2, night: event3 }
由于每種報(bào)紙都可能有不止一個(gè)人訂閱,那么格式可優(yōu)化成這樣:
var Event = { morning: [e11, e12,...], noon: [e21, e22], night: event3 }
當(dāng)用戶訂閱的時(shí)候,我們就將其事件添加對應(yīng)的數(shù)組中;當(dāng)事件發(fā)布的時(shí)候,就執(zhí)行相應(yīng)事件。說白了就是先存儲后使用。
具體代碼如下:
1.on表示訂閱,將事件添加到對應(yīng)數(shù)組中
2.emit表示發(fā)布,將對應(yīng)數(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 } //調(diào)用 Event.on('console1', function(num) { console.log(num); // 1 }); Event.emit('console1', 1)
node的EventEmitter
node的EventEmitter基本邏輯和上面提供的例子基本一樣,只是更加復(fù)雜些。
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的實(shí)現(xiàn)思路。
參考資料
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Nest.js中使用HTTP五種數(shù)據(jù)傳輸方式小結(jié)
本文主要介紹了Nest.js中使用HTTP五種數(shù)據(jù)傳輸方式小結(jié),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-05-05Node.js配合node-http-proxy解決本地開發(fā)ajax跨域問題
這篇文章主要介紹了Node.js配合node-http-proxy解決本地開發(fā)ajax跨域問題,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友可以參考下2016-08-08輕松創(chuàng)建nodejs服務(wù)器(4):路由
這篇文章主要介紹了輕松創(chuàng)建nodejs服務(wù)器(4):路由,服務(wù)器需要根據(jù)不同的URL或請求來執(zhí)行不一樣的操作,我們可以通過路由來實(shí)現(xiàn)這個(gè)步驟,需要的朋友可以參考下2014-12-12Node.js數(shù)據(jù)流Stream之Duplex流和Transform流用法
這篇文章介紹了Node.js數(shù)據(jù)流Stream之Duplex流和Transform流的用法,文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-07-07express結(jié)合nodejs開啟服務(wù)示例模版
這篇文章主要為大家展現(xiàn)了express結(jié)合nodejs開啟服務(wù)的代碼示例模版,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步早日升職加薪2022-04-04nodejs中art-template模板語法的引入及沖突解決方案
本篇文章主要介紹了nodejs中art-template模板語法的引入及沖突解決方案,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-11-11