node中事件機制的原理是什么

今天就跟大家聊聊有關(guān)node中事件機制的原理是什么，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

Publish/Subscribe(發(fā)布/訂閱模式)

類比

要講的是一個模式，模式這個詞，聽起來就很抽象。我們先舉個栗子。假設(shè)有一家報紙機構(gòu)，提供晨報、午報、晚報。如果你想要看某種報紙，你需要向報紙機構(gòu)訂閱，等對應(yīng)的報紙發(fā)布出來后，報紙機構(gòu)就會通知你來拿報紙。

在這個過程中，報紙機構(gòu)實現(xiàn)了兩個功能，一是接受客戶的訂閱；二是發(fā)布不同類型的報紙。發(fā)布報紙的時候，訂閱該類型報紙的客戶就能接收到通知。

這個報紙機構(gòu)也就是我們要實現(xiàn)的事件機制。

目的

從上面的例子可以看出：1.發(fā)布報紙；2.將報紙給到客戶；這個連續(xù)的過程由于報紙機構(gòu)的存在，變成了可以先訂閱，再發(fā)布，等到發(fā)布就自動送到客戶手中，實現(xiàn)了動作時間上的分離。這也是發(fā)布/訂閱系統(tǒng)的優(yōu)勢。

實現(xiàn)思路

我們有3種報紙，對應(yīng)3個事件，每個事件發(fā)生時要通知客戶。對應(yīng)的數(shù)據(jù)格式可以如下：

var Event = {
 morning: event1,
 noon: event2,
 night: event3
}

由于每種報紙都可能有不止一個人訂閱，那么格式可優(yōu)化成這樣：

var Event = {
 morning: [e11, e12,...],
 noon: [e21, e22],
 night: event3
}

當(dāng)用戶訂閱的時候，我們就將其事件添加對應(yīng)的數(shù)組中；當(dāng)事件發(fā)布的時候，就執(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);
 }
}

看完上述內(nèi)容，你們對node中事件機制的原理是什么有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。