资讯专栏INFORMATION COLUMN

eventEmitter3源码分析与学习

wwolf / 2147人阅读

摘要:属性该方法用于存储的整个事件名称与回调函数的集合,初始值为。当该属性当前值为一个对象且其函数不等于函数时,则会将其转换为一个包含这两个事件对象的事件对象数组。

背景

事件监听在前端的开发过程中是一个很常见的情况。DOM上的事件监听方式,让我们看到了通过事件的方式来进行具体的业务逻辑的处理的便捷。

在具体的一些业务场景中,第三方的自定义事件能够在层级较多,函数调用困难以及需要多个地方响应的时候有着其独特的优势——调用方便,避免多层嵌套,降低组件间耦合性。

这篇文章所提到的EventEmitter3,就是一个典型的第三方事件库,能够让我们通过自定义的实践来实现多个函数与组件间的通信。

整体结构图

EventEmitter3的设计较为的简单,具体结构可以看下图所示。

下面我们将按照一般人的正常思路来对这个结构进行介绍。

各部分结构与功能 EE

</>复制代码

  1. function EE(fn, context, once) {
  2. this.fn = fn;
  3. this.context = context;
  4. this.once = once || false;
  5. }

从类EE的代码中我们能够很明确的了解到,第一个参数为回调函数,第二个参数为回调函数的上下文,第三个参数是一个once的标志位。由于代码简单,在这里就简单介绍下了。

Prototype属性 events

该方法用于存储eventEmitter的整个事件名称与回调函数的集合,初始值为undefined。

Prototype方法 eventName

作用:返回当前已经注册的事件名称的列表

参数:无

listeners

作用:返回某一个事件名称的所有监听函数

参数:event——事件名称,exists——是否只判断存在与否

emit

作用:触发某个事件

参数:event——事件名,a1~a5——参数1~5

on

作用:为某个事件添加一个监听函数

参数:event——事件名,fn——回调函数,context——上下文

once

作用:类似on,区别在于该函数只会触发一次

参数:event——事件名,fn——回调函数,context——上下文

removeListner

作用:移除某个事件的监听函数

参数:event——事件名,fn——事件监听函数,context——只移除上下文匹配的事件监听函数,once——只移除类型匹配的事件监听函数

removeAllListener

作用:移除某个时间的所有监听函数

参数:event——事件名

学习思路

下面我们将从添加监听函数, 事件触发与删除监听函数来进行具体的代码分析,从而了解该库的实现思路。

事件对象

具体代码如下所示:

</>复制代码

  1. //一个单一的事件监听函数的单元
  2. //
  3. // @param {Function} fn Event handler to be called. 回调函数
  4. // @param {Mixed} context Context for function execution. 函数执行上下文
  5. // @param {Boolean} [once=false] Only emit once 是否执行一次的标志位
  6. // @api private 私有API
  7. function EE(fn, context, once) {
  8. this.fn = fn;
  9. this.context = context;
  10. this.once = once || false;
  11. }

该类为eventEmitter中用于存储事件监听函数的最小类。

添加监听函数

on函数具体代码如下所示:

</>复制代码

  1. // Register a new EventListener for the given event.
  2. // 注册一个指定的事件的事件监听函数
  3. //
  4. // @param {String} event Name of the event. 事件名
  5. // @param {Function} fn Callback function. 回调函数
  6. // @param {Mixed} [context=this] The context of the function. 上下文
  7. // @api public 公有API
  8. EventEmitter.prototype.on = function on(event, fn, context) {
  9. var listener = new EE(fn, context || this)
  10. , evt = prefix ? prefix + event : event;
  11. if (!this._events) this._events = prefix ? {} : Object.create(null);
  12. if (!this._events[evt]) {
  13. this._events[evt] = listener;//第一次存储为一个事件监听对象
  14. } else {
  15. if (!this._events[evt].fn) {//第三次及以后则直接向对象数组中添加事件监听对象
  16. this._events[evt].push(listener);
  17. } else {//第二次将存储的对象与新对象转换为事件监听对象数组
  18. this._events[evt] = [
  19. this._events[evt], listener
  20. ];
  21. }
  22. }
  23. return this;
  24. }

当我们向事件E添加函数F时,会调用on方法,此时on方法会检查eventEmitter中prototype属性events的E属性。

当这个属性为undefined时,直接将该函数所在的事件对象赋值给evt属性。

当该属性当前值为一个对象且其函数fn不等于函数F时,则会将其转换为一个包含这两个事件对象的事件对象数组。

当这个属性已经是一个对象数组时,则直接通过push方法向数组中添加对象。

prefix是用来判断Object.create()方法是否存在,如果存在则直接调用该方法来创建属性,否则通过在属性前添加~来避免覆盖原有属性。

once的函数实现与on函数基本一致,所以在此就不再进行分析。

触发监听函数

emit函数代码如下所示:

</>复制代码

  1. // Emit an event to all registered event listeners.
  2. // 触发已经注册的事件监听函数
  3. //
  4. // @param {String} event The name of the event. 事件名
  5. // @returns {Boolean} Indication if we"ve emitted an event. 如果触发事件成功,则返回true,否则返回false
  6. // @api public 公有API
  7. EventEmitter.prototype.emit = function emit(event, a1, a2, a3, a4, a5) {
  8. var evt = prefix ? prefix + event : event;
  9. if (!this._events || !this._events[evt]) return false;
  10. var listeners = this._events[evt]
  11. , len = arguments.length
  12. , args
  13. , i;
  14. if ("function" === typeof listeners.fn) {
  15. if (listeners.once) this.removeListener(event, listeners.fn, undefined, true);
  16. switch(len) {
  17. case 1:
  18. return listeners.fn.call(listeners.context), true;
  19. case 2:
  20. return listeners.fn.call(listeners.context, a1), true;
  21. case 3:
  22. return listeners.fn.call(listeners.context, a1, a2), true;
  23. case 4:
  24. return listeners.fn.call(listeners.context, a1, a2, a3), true;
  25. case 5:
  26. return listeners.fn.call(listeners.context, a1, a2, a3, a4), true;
  27. case 6:
  28. return listeners.fn.call(listeners.context, a1, a2, a3, a4, a5), true;
  29. }
  30. for(i = 1, args = new Array(len - 1); i < len; i++) {
  31. args[i - 1] = arguments[i];
  32. }
  33. listeners.fn.apply(listeners.context, args);
  34. } else {
  35. //由于篇幅原因省略E属性为数组时通过循环调用来实现事件触发的过程
  36. }
  37. return true;
  38. };

当我们触发事件E时,我们只需要调用emit方法。该方法会自动检索事件E中所有的事件监听对象,触发所有的事件监听函数,同时移除掉通过once添加,只需要触发一次的事件监听函数。

移除事件监听函数

removeListener函数代码如下:

</>复制代码

  1. // Remove event listeners.
  2. // 移除事件监听函数
  3. //
  4. // @param {String} event The event we want to remove. 需要被移除的事件名
  5. // @param {Function} fn The listener that we need to find. 需要被移除的事件监听函数
  6. // @param {Mixed} context Only remove listeners matching this context. 只移除匹配该参数指定的上下文的监听函数
  7. // @param {Boolean} once Only remove once listeners. 只移除匹配该参数指定的once属性的监听函数
  8. // @api public 公共API
  9. EventEmitter.prototype.removeListener = function removeListener(event, fn, context, once) {
  10. var evt = prefix ? prefix + event : event;
  11. if (!this._events || !this._events[evt]) return this;
  12. var listeners = this._events[evt]
  13. , events = [];
  14. if (fn) {
  15. if (listeners.fn) {
  16. if (
  17. listeners.fn !== fn
  18. || (once && !listeners.once)
  19. || (context && listeners.context !== context)
  20. ) {
  21. events.push(listeners);
  22. }
  23. } else {
  24. //由于篇幅原因省去便利listeners属性查找函数删除的代码
  25. }
  26. }
  27. //
  28. // Reset the array, or remove it completely if we have no more listeners.
  29. //
  30. if (events.length) {
  31. this._events[evt] = events.length === 1 ? events[0] : events;
  32. } else {
  33. delete this._events[evt];
  34. }
  35. return this;
  36. };

removeListener函数实现较为简单。当我们需要移除事件E的某个函数时,它使用一个event属性来保存不需要被移除的事件监听对象,然后便利整个事件监听数组(单个时为对象),并且最后将event属性的值赋值给E属性从而覆盖掉原有的属性,达到删除的目的。

其他

该库中还有一些其他的函数,由于对整个库的理解不产生太大影响,因此没有在此进行讲解,有需要的可以前往我的github仓库进行查看。

缺点

eventEmitter的代码虽然结构清晰,但是仍然存在一些问题。例如ononce方法的实现中,只有一个属性不同,其余代码都一模一样,其实可以抽出一个特定的函数来进行处理,通过属性来进行区分调用即可。

同时,在同一个函数例如emit中,也存在大量的重复代码,可以进行进一步的抽象和整理,使得代码更加简单。

总结

eventEmitter第三方事件库从实现上来看较为简单,并且结构清晰容易阅读,推荐有兴趣的可以花大约一个小时的时间来学习下。

附录

本人github地址——eventEmitter3
官方github地址

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/87759.html

相关文章

  • JavaScript EventEmitter

    摘要:事件删除可有可无。创建了一个类,然后在构造函数里初始化一个类的属性,这个属性不需要要继承任何东西,所以用了。但这不是必要的,因为实例化一个都会调用构造函数,皆为初始状态,应该是不可能已经定义了的,可去掉。成功执行结束后返回。 GitHub地址:JavaScript EventEmitter博客地址:JavaScript EventEmitter 水平有限,欢迎批评指正 2个多月前把 ...

    lovXin 评论0 收藏0
  • Flink 源码解析 —— 分析 Batch WordCount 程序的执行过程

    摘要:批处理的程序分析博客从到学习介绍从到学习上搭建环境并构建运行简单程序入门从到学习配置文件详解从到学习介绍从到学习如何自定义从到学习介绍从到学习如何自定义从到学习转换从到学习介绍中的从到学习中的几种详解从到学习读取数据写入到从到学习项 批处理的 WordCount 程序分析: https://t.zsxq.com/YJ2Zrfi 博客 1、Flink 从0到1学习 —— Apache ...

    LdhAndroid 评论0 收藏0
  • 你公司到底需不需要引入实时计算引擎?

    摘要:再如通过处理流数据生成简单的报告,如五分钟的窗口聚合数据平均值。复杂的事情还有在流数据中进行数据多维度关联聚合塞选,从而找到复杂事件中的根因。因为各种需求,也就造就了现在不断出现实时计算框架,而下文我们将重磅介绍我们推荐的实时计算框架。 前言 先广而告之,本文摘自本人《大数据重磅炸弹——实时计算框架 Flink》课程第二篇,内容首发自我的知识星球,后面持续在星球里更新,这里做个预告,今...

    HackerShell 评论0 收藏0
  • 源码之下无秘密 ── 做最好的 Netty 源码分析教程

    摘要:背景在工作中虽然我经常使用到库但是很多时候对的一些概念还是处于知其然不知其所以然的状态因此就萌生了学习源码的想法刚开始看源码的时候自然是比较痛苦的主要原因有两个第一网上没有找到让我满意的详尽的源码分析的教程第二我也是第一次系统地学习这么大代 背景 在工作中, 虽然我经常使用到 Netty 库, 但是很多时候对 Netty 的一些概念还是处于知其然, 不知其所以然的状态, 因此就萌生了学...

    shenhualong 评论0 收藏0
  • 区块链技术学习指引

    摘要:引言给迷失在如何学习区块链技术的同学一个指引,区块链技术是随比特币诞生,因此要搞明白区块链技术,应该先了解下比特币。但区块链技术不单应用于比特币,还有非常多的现实应用场景,想做区块链应用开发,可进一步阅读以太坊系列。 本文始发于深入浅出区块链社区, 原文:区块链技术学习指引 原文已更新,请读者前往原文阅读 本章的文章越来越多,本文是一个索引帖,方便找到自己感兴趣的文章,你也可以使用左侧...

    Cristic 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<