環(huán)境：Node v8.2.1; Npm v5.3.0;OS Windows10

Node大多數(shù)核心 API 都采用慣用的異步事件驅(qū)動架構(gòu)，其中某些類型的對象（觸發(fā)器）會周期性地觸發(fā)命名事件來調(diào)用函數(shù)對象（監(jiān)聽器）。

所有能觸發(fā)事件的對象都是 EventEmitter 類的實例。 這些對象開放了一個 eventEmitter.on() 函數(shù)，允許將一個或多個函數(shù)綁定到會被對象觸發(fā)的命名事件上。 事件名稱通常是駝峰式的字符串，但也可以使用任何有效的 JavaScript 屬性名。

當 EventEmitter 對象觸發(fā)一個事件時，所有綁定在該事件上的函數(shù)都被同步地調(diào)用。 監(jiān)聽器的返回值會被丟棄。

下面是一些簡單的例子，對應(yīng)上面的API的一個代碼實現(xiàn)

const EventEmitter = require("events");

//自定義一個對象繼承于EventEmitter
class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

myEmitter.on("event", () => {
  console.log("觸發(fā)了一個事件！");
});

myEmitter.emit("event");

const EventEmitter = require("events");

class MyEmitter extends EventEmitter {}

const myEmitter = new MyEmitter();

myEmitter.on("event", (a,b) => {
 console.log(a,b);
 //1，2
}); 
myEmitter.emit("event","a","b");

當一個普通的監(jiān)聽器函數(shù)被 EventEmitter 調(diào)用時，標準的 this 關(guān)鍵詞會被設(shè)置指向監(jiān)聽器所附加的 EventEmitter。

const EventEmitter = require("events");

class MyEmitter extends EventEmitter {}

const myEmitter = new MyEmitter();

myEmitter.on("event", function() {
    console.log(this);
    /*
        a b MyEmitter {
            domain: null,
            _events: { event: [Function] },
            _eventsCount: 1,
            _maxListeners: undefined 
        }
    */
   }); 
myEmitter.emit("event");

也可以使用 ES6 的箭頭函數(shù)作為監(jiān)聽器。但是這樣 this 關(guān)鍵詞就不再指向 EventEmitter 實例：

const EventEmitter = require("events");

class MyEmitter extends EventEmitter {}

const myEmitter = new MyEmitter();

myEmitter.on("event", () => {
    console.log(this);
    //{}
}); 

myEmitter.emit("event");

EventListener 會按照監(jiān)聽器注冊的順序同步地調(diào)用所有監(jiān)聽器，監(jiān)聽器函數(shù)可以使用 setImmediate() 或 process.nextTick() 方法切換到異步操作模式：

const EventEmitter = require("events");

class MyEmitter extends EventEmitter {}

const myEmitter = new MyEmitter();

myEmitter.on("event", (a,b) => {
    setImmediate(()=>{
        //異步觸發(fā)
        console.log(a,b);
    })
    console.log("c");
}); 

myEmitter.emit("event","a","b");
//c
//a b

事件默認是可以無限次數(shù)的觸發(fā)的，只要觸發(fā)一次，對應(yīng)的監(jiān)聽函數(shù)就執(zhí)行一次；有時候我們希望只執(zhí)行一次監(jiān)聽函數(shù)，可以使用【once】對事件進行綁定

多次觸發(fā)：

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

let m = 0;

myEmitter.on("event", () => {
    console.log(++m);
});

myEmitter.emit("event");    //1

myEmitter.emit("event");    //2

myEmitter.emit("event");    //3

一次觸發(fā)：

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

let m = 0;

myEmitter.once("event", () => {
    console.log(++m);
});

myEmitter.emit("event");    //1

myEmitter.emit("event");    //忽略

myEmitter.emit("event");    //忽略

當 EventEmitter 實例中發(fā)生錯誤時，會觸發(fā)一個 "error" 事件，如果 EventEmitter 沒有為 "error" 事件注冊至少一個監(jiān)聽器，則當 "error" 事件觸發(fā)時，會拋出錯誤、打印堆棧跟蹤、且退出 Node.js 進程。

const EventEmitter = require("events");

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

myEmitter.emit("error", new Error("whoops!"));
// 拋出錯誤，并使 Node.js 崩潰

為了防止 Node.js 進程崩潰，可以在 process 對象的 uncaughtException 事件上注冊監(jiān)聽器

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();
//在進程上面注冊錯誤監(jiān)聽，使進程不崩潰
process.on("uncaughtException",()=>{
    console.error("有錯誤");
});

myEmitter.emit("error",new Error("whoops"))

上面這樣的方式并不是最佳實踐，最好是為【error】注冊監(jiān)聽函數(shù)

Node默認一個事件的監(jiān)聽數(shù)量為10個，超過十個將會發(fā)出警告

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

console.log(EventEmitter.defaultMaxListeners);    //10

for (let i = 0; i < 11; i++) {
    myEmitter.on("event", () => {
        console.log(i);
    });
}
myEmitter.emit("event")
//MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 event listeners added. Use emitter.setMaxListeners() to increase limit

改變指定的 EventEmitter 實例的監(jiān)聽器限制

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter();

myEmitter.setMaxListeners(13);

for (let i = 0; i < 11; i++) {
    myEmitter.on("event", () => {
        console.log(i);
    });
}
myEmitter.emit("event")

EventEmitter 實例會在一個監(jiān)聽器被添加到其內(nèi)部監(jiān)聽器數(shù)組【之前】觸發(fā)自身的 "newListener" 事件

const EventEmitter = require("events")

class MyEmitter extends EventEmitter { }

const myEmitter = new MyEmitter()

myEmitter.once("newListener", (event, listener) => {
    if(event === "event"){
        myEmitter.on("event",()=>{
            console.log("B");
        })
    }
});

myEmitter.on("event",()=>{
    console.log("A");
});

myEmitter.emit("event")
/*
B
A
*/

CSDN 【Node事件模塊Events】同步更新