最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

淺談node的事件機(jī)制

 更新時間:2017年10月09日 14:13:14   作者:donnylin  
本篇文章主要介紹了node的事件機(jī)制,本文通過實(shí)現(xiàn)一個簡易的、具有發(fā)布/訂閱模式的事件機(jī)制,以此來理清EventEmitter類的實(shí)現(xiàn)思路,有興趣的可以了解一下

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

在nodejs的官方文檔中,明確寫出了node的一個特性是event-driven(事件驅(qū)動),可見其非常重要。查看源碼,我們可知其事件機(jī)制為用js寫的EventEmitter類,寫得非常優(yōu)雅且應(yīng)用了發(fā)布/訂閱模式。

通過實(shí)現(xiàn)一個簡易的、具有發(fā)布/訂閱模式的事件機(jī)制,以此來理清EventEmitter類的實(shí)現(xiàn)思路

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

類比

要講的是一個模式,模式這個詞,聽起來就很抽象。我們先舉個栗子。假設(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)紙。

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

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

目的

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

實(shí)現(xiàn)思路

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

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

由于每種報(bào)紙都可能有不止一個人訂閱,那么格式可優(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);
 }
}

講到這里,相信大家已經(jīng)明白EventEmitter的實(shí)現(xiàn)思路。

參考資料

node events.js

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • 基于Express+multer實(shí)現(xiàn)文件上傳功能

    基于Express+multer實(shí)現(xiàn)文件上傳功能

    Multer是Node.js中的一個第三方包,或者說是第三方中間件,主要用于是實(shí)現(xiàn)文件上傳的功能,本文小編講給大家詳細(xì)介紹一下基于Express+multer來實(shí)現(xiàn)文件上傳功能,文章通過代碼示例和圖文介紹的非常詳細(xì),需要的朋友可以參考下
    2023-11-11
  • 基于Node.js實(shí)現(xiàn)數(shù)據(jù)轉(zhuǎn)換工具

    基于Node.js實(shí)現(xiàn)數(shù)據(jù)轉(zhuǎn)換工具

    在前端項(xiàng)目中,利用?Excel?表格和?Node.js?實(shí)現(xiàn)數(shù)據(jù)轉(zhuǎn)換工具,可以有效優(yōu)化增刪改查等功能,下面小編就來和大家講講具體的實(shí)現(xiàn)步驟吧
    2025-02-02
  • 淺談Node.js 中間件模式

    淺談Node.js 中間件模式

    中間件在 Node.js 中被廣泛使用,它泛指一種特定的設(shè)計(jì)模式、一系列的處理單元、過濾器和處理程序,以函數(shù)的形式存在,這篇文章主要介紹了淺談Node.js 中間件模式,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-06-06
  • Node.js中Process.nextTick()和Process.setImmediate()的區(qū)別

    Node.js中Process.nextTick()和Process.setImmediate()的區(qū)別

    這篇文章介紹了Node.js中Process.nextTick()和Process.setImmediate()的區(qū)別,文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-07-07
  • 使用puppeteer破解極驗(yàn)的滑動驗(yàn)證碼

    使用puppeteer破解極驗(yàn)的滑動驗(yàn)證碼

    這篇文章主要介紹了利用puppeteer破解極驗(yàn)的滑動驗(yàn)證功能,基本流程代碼實(shí)現(xiàn)給大家介紹的非常詳細(xì),需要的朋友可以參考下
    2018-02-02
  • 基于node.js實(shí)現(xiàn)微信支付退款功能

    基于node.js實(shí)現(xiàn)微信支付退款功能

    在微信開發(fā)中有有付款就會有退款,這樣的功能非常常見,這篇文章主要介紹了node.js實(shí)現(xiàn)微信支付退款功能,需要的朋友可以參考下
    2017-12-12
  • Node.js+ES6+dropload.js實(shí)現(xiàn)移動端下拉加載實(shí)例

    Node.js+ES6+dropload.js實(shí)現(xiàn)移動端下拉加載實(shí)例

    這個demo服務(wù)由Node搭建服務(wù)、下拉加載使用插件dropload,數(shù)據(jù)渲染應(yīng)用了ES6中的模板字符串。有興趣的小伙伴可以自己嘗試下
    2017-06-06
  • nodejs中安裝ghost出錯的原因及解決方法

    nodejs中安裝ghost出錯的原因及解決方法

    本篇文章主要介紹了nodejs中安裝ghost出錯的原因及解決方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-10-10
  • Node配合WebSocket做多文件下載以及進(jìn)度回傳

    Node配合WebSocket做多文件下載以及進(jìn)度回傳

    這篇文章主要介紹了Node配合WebSocket做多文件下載以及進(jìn)度回傳功能,本文通過實(shí)例代碼效果截圖給大家介紹的非常詳細(xì),需要的朋友可以參考下
    2019-11-11
  • NodeJS后端開發(fā)操作文件之讀寫文件

    NodeJS后端開發(fā)操作文件之讀寫文件

    這篇文章主要介紹了NodeJS后端開發(fā)操作文件之讀寫文件,操作文件是服務(wù)端一個基礎(chǔ)的功能,也是做后端開發(fā)的必備能力之一,操作文件主要包括讀和寫。而這些功能NodeJS都已經(jīng)提供了對應(yīng)的方法
    2022-06-06

最新評論

定结县| 福建省| 西乌珠穆沁旗| 措勤县| 大宁县| 沁阳市| 芷江| 东安县| 平凉市| 平度市| 丘北县| 台中县| 海晏县| 武川县| 崇文区| 乐东| 乌恰县| 莎车县| 丽江市| 乐都县| 柳州市| 公安县| 庆元县| 林甸县| 唐山市| 湄潭县| 广东省| 长垣县| 高陵县| 古田县| 辽中县| 曲麻莱县| 桂平市| 昌邑市| 永定县| 平武县| 塔河县| 普定县| 桐庐县| 正安县| 敦化市|