首頁 > web前端 > js教程 > 主體

node事件機制解說

小云云
發布: 2018-01-26 13:31:34
原創
1503 人瀏覽過

本文主要介紹了node的事件機制,本文透過實作一個簡易的、具有發布/訂閱模式的事件機制,以此來理清EventEmitter類的實現思路,有興趣的可以了解一下,希望能幫助到大家。

Node.js uses an event-driven, non-blocking I/O model that makes it lightweight and efficient.

在nodejs的官方文件中,明確寫出了node的一個特性是event-driven(事件驅動),可見其非常重要。查看原始碼,我們可知其事件機制為用js寫的EventEmitter類,寫得非常優雅且套用了發布/訂閱模式。

透過實作一個簡易的、具有發佈/訂閱模式的事件機制,以此來理清EventEmitter類別的實作思維

Publish/Subscribe(發佈/訂閱模式)

類比

要講的是一個模式,模式這個詞,聽起來就很抽象。我們先舉個栗子。假設有一家報紙機構,提供晨報、午報、晚報。如果你想看某種報紙,你需要向報紙機構訂閱,等對應的報紙發佈出來後,報紙機構就會通知你來拿報紙。

在這個過程中,報紙機構實現了兩個功能,一是接受客戶的訂閱;二是發布不同類型的報紙。發布報紙的時候,訂閱該類型報紙的客戶就能接收到通知。

這個報紙機構也就是我們要實現的事件機制。

目的

從上面的例子可以看出:1.發布報紙;2.將報紙給到客戶;這個連續的過程由於報紙機構的存在,變成了可以先訂閱,再發布,等到發布就自動送到客戶手中,實現了動作時間上的分離。這也是發布/訂閱系統的優勢。

實作想法

我們有3種報紙,對應3個事件,每個事件發生時要通知客戶。對應的資料格式可以如下:


var Event = {
 morning: event1,
 noon: event2,
 night: event3
}
登入後複製

由於每種報紙都可能有不只一個人訂閱,那麼格式可優化成這樣:


var Event = {
 morning: [e11, e12,...],
 noon: [e21, e22],
 night: event3
}
登入後複製

當使用者訂閱的時候,我們就將其事件加入對應的陣列中;當事件發布的時候,就執行對應事件。說穿了就是先儲存後再使用。

具體程式碼如下:

1.on表示訂閱,將事件加入對應數組中
2.emit表示發布,將對應數組中的數據取出來執行
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 
  //取得每次订阅不同的参数
  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(&#39;console1&#39;, function(num) {
 console.log(num); // 1
});

Event.emit(&#39;console1&#39;, 1)
登入後複製

node的EventEmitter

node的EventEmitter基本邏輯和上面提供的例子基本上一樣,只是更複雜。

1.訂閱事件on


function _addListener(target, type, listener, prepend) {
 var m;
 var events;
 var existing;

 if (typeof listener !== &#39;function&#39;)
  throw new TypeError(&#39;"listener" argument must be a function&#39;);

 events = target._events;
 ...
 if (typeof existing === &#39;function&#39;) {
   // Adding the second element, need to change to array.
   existing = events[type] =
    prepend ? [listener, existing] : [existing, listener];
  } else {
   // If we&#39;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.發布事件


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);
 }
}
登入後複製

說到這裡,相信大家已經明白EventEmitter的實現想法。

相關推薦:

PHP事件機制的實作

jq與js中的事件機制與阻止

JavaScript的事件機制

#

以上是node事件機制解說的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板