EventEmitter

sixleaves 發布于2019-08-26 10:46 / 2019人閱讀

摘要：工具函數判斷所屬類型判斷是否是或者添加事件監聽事件的名稱監聽事件對應的方法改變的指向執行的主體是否只執行一次必須是一個函數如果只執行一次將是一次函數如果已經存在監聽一個函數則將是一個數組如果存在監聽多個函數數組則類初始化屬性添加事件可執行

//工具函數,判斷所屬類型,判斷是否是null或者undefined
const toString = Object.prototype.toString;
const isType = obj => toString.call(obj).slice(8, -1).toLowerCase();
const isArray = obj => Array.isArray(obj) || isType(obj) === "array";
const isNullOrUndefined = obj => obj === null || obj === undefined;
/**
 * 添加事件
 * @param {*} type 監聽事件的名稱
 * @param {*} fn   監聽事件對應的方法
 * @param {*} context 改變this的指向/執行的主體
 * @param {*} once 是否只執行一次
 */
const _addListener = function(type, fn, context, once) {
  if (typeof fn != "function") {
    throw new TypeError("fn 必須是一個函數");
  }
  fn.context = context;
  fn.once = !!once;
  const event = this._events[type];
  //如果只執行一次, this._events[type] 將是一次函數
  if (isNullOrUndefined(event)) {
    this._events[type] = fn;
  } else if (typeof event === "function") {
    //如果已經存在(監聽)一個函數,則this._events[type]將是一個數組
    this._events[type] = [event, fn];
  } else if (isArray(event)) {
    //如果存在(監聽)多個函數(數組),則push
    this._events[type].push(fn);
  }
  return this;
}

//EventEmitter類
class EventEmitter {
  constructor() {
    //初始化_events屬性
    if (isNullOrUndefined(this._events)) {    
      this._events = Object.create(null);
    }
  }
  //添加事件
  addListener(type, fn, context) {
    return _addListener.call(this, type, fn, context);
  }
  //可執行多次
  on(type, fn, context) {
    return this.addListener(type, fn, context);
  }
  //執行一次
  once(type, fn, context) {
    return _addListener.call(this, type, fn, context, true);
  }
  //事件觸發
  emit(type, ...rest) {
    if (isNullOrUndefined(type)) {
      throw new Error("emit必須接收至少一個參數");
    }
    const events = this._events[type];
    if (isNullOrUndefined(events)) return false;
    if (typeof events === "function") {
      //用call改變this的指向指向events.context主體,否則指向null
      events.call(events.context || null, rest);
      //執行完畢判斷是否只執行一次,是則移除
      if (events.once) {
        this.removeListener(type, events);
      }
    } else if (isArray(events)) {
      events.map(e => {
        e.call(e.context || null, rest);
        if (e.once) {
          this.removeListener(type, e);
        }
      })
    }
    return true;
  }
  //事件移除
  removeListener(type, fn) {
    if (isNullOrUndefined(this._events)) return this;
    if (isNullOrUndefined(type)) return this;
    if (typeof fn !== "function") {
      throw new Error("fn 必須是一個函數");
    }
    const events = this._events[type];
    if (typeof events === "function") {
      events === fn && delete this._events[type];
    } else {
      const findIndex = events.findIndex(e => e === fn);
      if (findIndex === -1) return this;
      if (findIndex === 0) {
        events.shift();
      } else {
        events.splice(findIndex, 1);
      }
      //如果只剩下一個監聽者,則把數組變為函數
      if (events.length === 1) {
        this._events[type] = events[0];
      }
    }
    return this;
  }
  //刪除所有事件
  removeAllListeners(type) {
    if (isNullOrUndefined(this._events)) return this;
    //如果沒有指定type,則刪除全部
    if (isNullOrUndefined(type)) this._events = Object.create(null);
    const events = this._events[type];
    if (!isNullOrUndefined(events)) {
      //判斷是否只剩下最后一個事件
      if (Object.keys(this._events).length === 1) {
        this._events = Object.create(null);
      } else {
        delete this._events[type];
      }
    }
    return this;
  }
  //監聽隊列
  listeners(type) {
    if (isNullOrUndefined(this._events)) return [];
    const events = this._events[type];
    return isNullOrUndefined(events) ? [] : (typeof events === "function" ? [events] : events.map(o => o));
  }
  //監聽者數量
  listenerCount(type) {
    if (isNullOrUndefined(this._events)) return 0;
    const events = this._events[type];
    return isNullOrUndefined(events) ? 0 : (typeof events === "function" ? 1 : events.length);
  }
  eventNames() {
    if (isNullOrUndefined(this._events)) return [];
    return Object.keys(this._events);
  }
}

參考自https://www.php.cn/js-tutoria... 作者:php中世界最好的語言

GPU云服務器云服務器 EventEmitter

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/106735.html

循序漸進教你實現一個完整的node的EventEmitter模塊

摘要：本文從的的使用出發，循序漸進的實現一個完整的模塊。移除指定事件的某個監聽器，監聽器必須是該事件已經注冊過的監聽器的別名移除所有事件的所有監聽器，如果指定事件，則移除指定事件的所有監聽器。返回指定事件的監聽器數組。 node的事件模塊只包含了一個類：EventEmitter。這個類在node的內置模塊和第三方模塊中大量使用。EventEmitter本質上是一個觀察者模式的實現，這種模式可...

sunsmell 2019-08-26 12:08 評論0 收藏0
【Node事件模塊Events】

環境：Node v8.2.1; Npm v5.3.0;OS Windows10 1、 Node事件介紹 Node大多數核心 API 都采用慣用的異步事件驅動架構，其中某些類型的對象（觸發器）會周期性地觸發命名事件來調用函數對象（監聽器）。所有能觸發事件的對象都是 EventEmitter 類的實例。這些對象開放了一個 eventEmitter.on() 函數，允許將一個或多個函數綁定到會被對象...

junnplus 2019-08-21 16:48 評論0 收藏0
【node不完全指西】EventEmitter （事件發布/訂閱模式）解析

摘要：從異步編程解決方案說起吧事件發布訂閱模式模式流程控制庫事件發布訂閱模式事件監聽器模式是一種廣泛運用于異步編程的模式，是回調函數的事件話，又稱發布訂閱模式。從node異步編程解決方案說起吧：事件發布/訂閱模式 Promise/deferred模式流程控制庫事件發布/訂閱模式事件監聽器模式是一種廣泛運用于異步編程的模式，是回調函數的事件話，又稱發布/訂閱模式。主要實現的幾個...

yagami 2019-08-23 16:48 評論0 收藏0
NodeJS Events 必知必會

摘要：超過會有警告輸出。實例默認的某個事件最大監聽者的數量，默認是。事件監聽數量是檢測內存泄露的一個標準一個維度。例如同一個實例類型事件個監聽者，類型事件個監聽者，這個并不會有告警。 1. 環境 node 8.11.3 2. 基本使用 // 01.js const EventEmitter = require(events); class MyEmitter extends EventE...

bladefury 2019-08-23 11:35 評論0 收藏0
【每日一包0025】events

摘要：打印的參數分別為移除的監聽事件和該事件的句柄函數默認情況下，每個事件可以注冊最多個監聽器。返回已注冊監聽器的事件名數組。值設為或表示不限制監聽器的數量。持續地記錄返回一個數組，只包含綁定的監聽器。 [github地址：https://github.com/ABCDdouyae...] events 事件觸發器大多數 Node.js 核心 API 構建于慣用的異步事件驅動架構，其中某些...

shixinzhang 2019-08-23 13:57 評論0 收藏0
【每日一包0025】events

摘要：打印的參數分別為移除的監聽事件和該事件的句柄函數默認情況下，每個事件可以注冊最多個監聽器。返回已注冊監聽器的事件名數組。值設為或表示不限制監聽器的數量。持續地記錄返回一個數組，只包含綁定的監聽器。 [github地址：https://github.com/ABCDdouyae...] events 事件觸發器大多數 Node.js 核心 API 構建于慣用的異步事件驅動架構，其中某些...

fxp 2019-08-29 17:31 評論0 收藏0