深入nodejs-核心模块Events详解(事件驱动)

时间: 2019-01-02阅读: 160标签: 事件

事件驱动

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。Node.js 使用了一个事件驱动、非阻塞式 I/O的模型,使其轻量又高效。Allows you to build scalable network applications usingJavaScript on the server-side.

对于上面这段官方的引用大家应该都看过,nodejs是基于事件驱动和非阻塞I/O的方式来设计运行的,那么作为实现事件驱动的核心模块Events就成了深入学习node.js的关键。在node中大部分的模块的实现都继承了Events类。 比如,文件操作中的fs事件流,网络编程所用到的tcp,http模块等,当你回想自己写的程序后,会发现很多操作都基于事件驱动,Events类。


那么问题是什么是事件驱动呢?

简单来说,就是通过监听事件的状态变化来做出相应的操作。比如读取一个文件,文件读取完毕,或者文件读取错误,那么就触发对应的状态,然后调用对应的回掉函数来进行处理。

我们来简单的看几段代码来回忆一下:

    const fs = require('fs');
    
    let rs = fs.createReadStream('1.txt');
    
    // 监听文件打开操作
    rs.on('open', function() {
      console.log('open');
    });
    
    // 监听数据流读取
    rs.on('data', function(data) {
      console.log(data);
    });
    
    // 监听错误
    rs.on('error', function() {
      console.log('error');
    });
    
    // 监听读取结束操作
    rs.on('end', function() {
      console.log('end');
    });
    
    
    // 监听文件关闭操作
    rs.on('close', function() {
      console.log('close');
    });

上面这段在创建文件读取流的操作上,针对文件的打开,数据,错误,结束,关闭等几个状态进行了监听的回调处理,这也应征了我们上面的定义通过监听事件的状态变化来做出相应的操作。
那么这些监听事件又是如何触发的呢?它是通过Events类中的emit方法去发射事件的。那么下面我们来看一下Events是如何实现这样的监听操作的。


Events类

主要的几个核心API

  • on(eventName, listener)和emitter.addListener(eventName, listener):对指定事件绑定事件处理函数
  • once(eventName, listener):对指定事件指定只执行一次的事件处理函数
  • emit(eventName[, ...args]): 触发指定事件
  • removeListener(eventName, listener):对指定事件解除事件处理函数
  • removeAllListeners([event]):对指定的事件接触所有的事件处理函数
  • setMaxListeners 设置最大队列的长度

下面来看一下代码,看看是怎么使用的

    const events = require('events');
    
    const EventsEmitter = new events();
    
    //===============事件监听部分===============
    EventsEmitter.on('open', function() {
      console.log('open');
    });
    
    EventsEmitter.on('data', function(data) {
      console.log(data);
    });
    
    EventsEmitter.on('error', function() {
      console.log('error');
    });
    
    EventsEmitter.on('end', function() {
      console.log('end');
    });
    
    EventsEmitter.on('close', function() {
      console.log('close');
    });
    
    //=============事件触发部分=================
    
    // 触发open事件
    EventsEmitter.emit('open');
    // 触发data事件,并传递一个字符串参数'test'
    EventsEmitter.emit('data','test');
    // 触发error事件
    EventsEmitter.emit('error');
    // 触发end事件
    EventsEmitter.emit('end');
    // 触发close事件
    EventsEmitter.emit('close');

看完上面这段代码是不是更进一步的理解了呢。我们回顾最最上面的那段文件流监听的代码,其实就是文件在不同的状态下去发射相应的emit事件。 而在那段代码中我们并没有去引入events这个node提供的模块,是因为文件流中继承了events模块,所以rs这个变量也就拥有了相应的rs.on()这个方法了。

看到这里我想应该都了解的差不多了。那么下面来试着实现一下Events这个类,加深理解。


初始化Events模块

  • 创建一个Events类
  • 初始化this.events用来保存我们需要监听的事件
  • 将模块导出
class Events {
  constructor() {
    this.events = {};
  }
}

module.exports = Events;


实现Events.on方法

  • on方法接收两个参数:

    • type:监听的事件类型
    • listener:回调函数
  • 将对应的事件先存放在一个对象中,分两种情况:

    • 该事件对象不存在,那么以type为key,[listener]为值存放在实现初始化好的this.events对象中(注意这里存的是一个数组,例如data事件,this.events = {data:[callback]})
    • 如果该事件已经存在则直接push
    • 监听函数就这么简单的实现了,接下来就是等着被emit触发了。
  /**
   * 事件监听
   * @param {*} type        监听的事件类型
   * @param {*} listener    回调函数
   */
  on(type, listener) {
    if (this.events[type]) {
      this.events[type].push(listener);
    } else {
      this.events[type] = [listener];
    }
  }

这里在补充一下,同一个监听事件是可以添加多个的,所以这里才会this.events[type]才会给一个数组来存储

实现Events.emit方法

  • 接收两个参数:

    • type:要触发的事件类型
    • ...rest:若干个参数,传递给对应事件的回调函数
  • 通过type,在this.events里找到相应的事件,这里我们上面是存成了一个数组,里面对应的是事件的回调好书。
  • 循环数组,执行所有对应事件的回调。
  /**
   * 事件触发
   * @param {*} type        要触发的事件类型
   * @param  {...any} rest  接收到的若干个参数,这个参数会作为参数被传递到对应事件的回调函数中
   */
  emit(type, ...rest) {
    if (this.events[type]) {
      this.events[type].forEach(listener => {
        listener.apply(this, rest);
      });
    }
  }

写到这里,我们之前的代码就能够引入自己写的这个Events模块来执行了


实现Events.removeListener方法

这个方法是用来删除对应事件的某个监听函数,那么我们只需要把该事件从this.events[type]中删除即可

  • 接收两个参数:

    • type:事件类型
    • listener:要删除的监听函数
  • 通过this.events[type]找到对应的事件监听函数数组
  • 通过filter对要删除的监听函数进行过滤
  /**
   * 删除指定事件中的监听函数
   * @param {*} type      对应的事件 
   * @param {*} listener  要删除的监听函数
   */
  removeListener(type, listener) {
    if (this.events[type]) {
      this.events[type].filter(l => l !== listener);
    }
  }  


实现Events.once方法

这个方法和on一样,唯一的区别就是它只会执行一次,即便多次调用emit去触发相同的事件监听,它也只会执行一次。

  • 实现方式其实就是对on()方法做了一层封装,将一个封装好的wraper代替listener传递给on()方法
  • wraper内部会执行一次监听回调函数,然后再调用this.removeListern对该回调进行删除。
  /**
   * 事件监听,但是只执行一次
   * @param {*} type        监听的事件类型
   * @param {*} listener    回调函数
   */
  once(type, listener) {
    const wraper = (...rest) => {
      listener.apply(this, rest);
      this.removeListener(type, wraper);
    };
    this.on(type, wrapper);
  }


完整代码

class Events {
  constructor() {
    this.events = {};
  }
  /**
   * 事件监听
   * @param {*} type        监听的事件类型
   * @param {*} listener    回调函数
   */
  on(type, listener) {
    if (this.events[type]) {
      this.events[type].push(listener);
    } else {
      this.events[type] = [listener];
    }
  }

  /**
   * 事件监听,但是只执行一次
   * @param {*} type        监听的事件类型
   * @param {*} listener    回调函数
   */
  once(type, listener) {
    const wraper = (...rest) => {
      listener.apply(this, rest);
      this.removeListener(type, wraper);
    };
    this.on(type, wrapper);
  }

  /**
   * 事件触发
   * @param {*} type        要触发的事件类型
   * @param  {...any} rest  接收到的若干个参数,这个参数会作为参数被传递到对应事件的回调函数中
   */
  emit(type, ...rest) {
    if (this.events[type]) {
      this.events[type].forEach(listener => {
        listener.apply(this, rest);
      });
    }
  }

  /**
   * 删除指定事件中的监听函数
   * @param {*} type      对应的事件
   * @param {*} listener  要删除的监听函数
   */
  removeListener(type, listener) {
    if (this.events[type]) {
      this.events[type].filter(l => l !== listener);
    }
  }
}

module.exports = Events;


总结

Events模块是node非常核心的模块,它对你深入去学习node有很大的帮助,上面我只写了几个方法,内部还有几个API以及一些非常细节的地方可以自己试着去扩展,我这里就不一个一个的去写了


JavaScript模拟事件的注意要点

DOM中的事件模拟三个步骤: 首先通过document.createEvent()方法创建event对象,接收一个参数,即表示要创建的事件类型的字符串:UIEvents(DOM3中的UIEvent)鼠标和键盘事件

手写事件代理函数

面试是不是听过无数遍呢 !今天我们来手写一个这样的事件委托函数,它是通过事件冒泡机制,即子元素上触发的事件会冒泡到父级上, 即父级也会触发该类型的事件

Selenium WebDriver 中鼠标和键盘事件分析及扩展

在使用 Selenium WebDriver 做自动化测试的时候,会经常模拟鼠标和键盘的一些行为。比如使用鼠标单击、双击、右击、拖拽等动作;或者键盘输入、快捷键使用、组合键使用等模拟键盘的操作

Js中的事件委托/事件代理

什么叫事件委托/事件代理呢 ?JavaScript高级程序设计上讲:事件委托就是利用事件冒泡,只指定一个事件处理程序,就可以管理某一类型的所有事件。

JavaScript 事件冒泡和捕获模式

捕获模式1,addEventListener 的第三个参数 useCapture 为 true 则为捕获模式2,点击 C 时事件触发顺序为 A -> B -> C

js 冒泡事件与解决冒泡事件

事件冒泡 :当一个元素接收到事件的时候 会把他接收到的事件传给自己的父级,一直到window 。取消事件冒泡有两种方式:e.stopPropagation(); window.event.cancelBubble=true;

JS自定义事件

自定义事件,就是自己定义事件类型,自己定义事件处理函数。我们平时操作dom时经常会用到onclick、onmousemove等浏览器特定行为的事件类型。封装is自定义事件基本的构思:

js 任意元素解绑任意事件的兼容代码

解绑事件有三种:注意:用什么方式绑定事件,就应该用对应的方式解绑事件,解绑事件(IE 谷歌 火狐都支持 但是得对于的ON事件),对象.addEventListener(没有on的事件类型,命名函数,false);---绑定事件

vue公共事件总线eventBus的简单理解和使用

公共事件总线eventBus的实质就是创建一个vue实例,通过一个空的vue实例作为桥梁实现vue组件间的通信。它是实现非父子组件通信的一种解决方案。

Js事件传播流程

js事件传播流程主要分三个阶段:事件捕获阶段、处于目标阶段、事件冒泡阶段。在我们平常用的addEventListener方法中,一般只会用到两个参数,一个是需要绑定的事件,另一个是触发事件后要执行的函数

内容以共享、参考为目的,请勿用于商业用途。其版权归原作者所有,如有侵权,请与小编联系,情况属实将予以删除!

广告赞助文章投稿关于web前端网站点搜索站长推荐网站地图站长QQ:522607023

小程序专栏: 土味情话心理测试脑筋急转弯幽默笑话段子句子语录成语大全