這篇文章主要介紹了node.js怎么自定義實(shí)現(xiàn)EventEmitter的相關(guān)知識(shí)，內(nèi)容詳細(xì)易懂，操作簡單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇node.js怎么自定義實(shí)現(xiàn)EventEmitter文章都會(huì)有所收獲，下面我們一起來看看吧。

成都創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括銅陵網(wǎng)站建設(shè)、銅陵網(wǎng)站制作、銅陵網(wǎng)頁制作以及銅陵網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，銅陵網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到銅陵省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

一、是什么

我們了解到，Node采用了事件驅(qū)動(dòng)機(jī)制，而EventEmitter就是Node實(shí)現(xiàn)事件驅(qū)動(dòng)的基礎(chǔ)
在EventEmitter的基礎(chǔ)上，Node幾乎所有的模塊都繼承了這個(gè)類，這些模塊擁有了自己的事件，可以綁定／觸發(fā)監(jiān)聽器，實(shí)現(xiàn)了異步操作
Node.js 里面的許多對(duì)象都會(huì)分發(fā)事件，比如 fs.readStream 對(duì)象會(huì)在文件被打開的時(shí)候觸發(fā)一個(gè)事件
這些產(chǎn)生事件的對(duì)象都是 events.EventEmitter 的實(shí)例，這些對(duì)象有一個(gè) eventEmitter.on() 函數(shù)，用于將一個(gè)或多個(gè)函數(shù)綁定到命名事件上

二、nodejs中EventEmitter使用方法

Node的events模塊只提供了一個(gè)EventEmitter類，這個(gè)類實(shí)現(xiàn)了Node異步事件驅(qū)動(dòng)架構(gòu)的基本模式――觀察者模式
在這種模式中，被觀察者(主體)維護(hù)著一組其他對(duì)象派來(注冊(cè))的觀察者，有新的對(duì)象對(duì)主體感興趣就注冊(cè)觀察者，不感興趣就取消訂閱，主體有更新的話就依次通知觀察者們

const EventEmitter = require("events")
class MyEmitter extends EventEmitter {}
const myEmitter = new MyEmitter()
function callback() {
    console.log("觸發(fā)了event事件！")
}
myEmitter.on("event", callback)
myEmitter.emit("event")
myEmitter.removeListener("event", callback);

三、實(shí)現(xiàn)過程

基本代碼如下所示：

//事件派發(fā)機(jī)制
(function() {
    var EventDispatcher = function() {
        var EventDispatcherClosure = function() {

        };
        EventDispatcherClosure.prototype = {
            /**
             * 注冊(cè)事件
             * @param {Object} key
             * @param {Object} fn
             */
            on: function(key, fn) {
                //獲取當(dāng)前的事件對(duì)象
                var curEvents = this._getCurEvents(key);
                //先檢查該事件是否已經(jīng)注冊(cè)過了
                var flag = false;
                for (var i = 0, len = curEvents.length; i < len; i++) {
                    if (curEvents[i].name == fn.name) {
                        //已經(jīng)出現(xiàn)過了,以最新注冊(cè)的函數(shù)為主
                        flag = true;
                        curEvents[i] = fn;
                        break;
                    }
                }
                if (!flag) {
                    curEvents[curEvents.length] = fn;
                }
                this._register(key, curEvents);
            },
            /**
             * 派發(fā)事件
             * @param {Object} key
             * @param {Object} data
             */
            dispatch: function(key) {
                //獲取當(dāng)前的事件對(duì)象
                var curEvents = this._getCurEvents(key);
                var shouldDispatch = true;
                for (var i = 0, len = curEvents.length; shouldDispatch && i < len; i++) {
                    try {
                        //獲取參數(shù)
                        var args = [];
                        for (var j = 1, len1 = arguments.length; j < len1; j++) {
                            args.push(arguments[j]);
                        }
                        shouldDispatch = curEvents[i].apply({}, args);
                    } catch (e) {
                        shouldDispatch = false;
                    }
                }
                return shouldDispatch;
            },
            remove: function(key) {
                if (this._getCurEvents(key)) {
                    delete EventDispatcherClosure.events[key];
                }
            },
            /**
             * 根據(jù)key獲取事件列表
             * @param {Object} key
             */
            _getCurEvents: function(key) {
                return EventDispatcherClosure.events[key] || [];
            },
            /**
             * 注冊(cè)時(shí)間
             * @param {Object} key
             * @param {Object} events
             */
            _register: function(key, events) {
                EventDispatcherClosure.events[key] = events;
            },
        };
        EventDispatcherClosure.events = {};
        return {
            create: function() {
                return new EventDispatcherClosure();
            }
        };
    };
    window.EventDispatcher = new EventDispatcher().create();
})();

首先定義一個(gè)全局變量的匿名函數(shù)，然后將全局變量掛在window上面，這樣可以讓我們?cè)陂_發(fā)過程中的調(diào)用。在匿名函數(shù)的原型鏈上面添加事件分發(fā)、事件監(jiān)聽、事件刪除等方法。

事件分發(fā)的調(diào)用

EventDispatcher.dispatch("test", obj)

事件監(jiān)聽

EventDispatcher.on("test", function callback(obj) {
})

事件刪除

EventDispatcher.on("test")

代碼封裝的比較簡單

關(guān)于“node.js怎么自定義實(shí)現(xiàn)EventEmitter”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對(duì)“node.js怎么自定義實(shí)現(xiàn)EventEmitter”知識(shí)都有一定的了解，大家如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。