专栏首页YuanXinNodeJS模块研究 - events

NodeJS模块研究 - events

读了 events 模块的文档,研究了几个有意思的问题:

  • ?️ 事件驱动模型
  • ?️ 优雅的错误处理
  • ?️ 监听器器队列顺序处理
  • ?️ 内存管理与防止泄漏
  • ? 配合 Promise 使用

引用/转载 请声明出处:原文链接: xxoo521.com

事件驱动模型

Nodejs 使用了一个事件驱动、非阻塞 IO 的模型。events模块是事件驱动的核心模块。很多内置模块都继承了events.EventEmitter

自己无需手动实现这种设计模式,直接继承EventEmitter即可。代码如下:

const { EventEmitter } = require("events");

class MyEmitter extends EventEmitter {}

const ins = new MyEmitter();
ins.on("test", () => {
    console.log("emit test event");
});
ins.emit("test");

优雅的错误处理

根据文档,应该 EventEmitter 实例的error事件是个特殊事件。推荐做法是:在创建实例后,应该立即注册error事件。

const ins = new MyEmitter();
ins.on("error", error => {
    console.log("error msg is", error.message);
});

注册error事件后,我原本的理解是,所有事件回掉逻辑中的错误都会在 EventEmitter 内部被捕获,并且在内部触发 error 事件。

也就是说下面代码,会打印:”error msg is a is not defined”。

ins.on("test", () => {
    console.log(a);
});

ins.emit("test");

然而,错误并没有捕获,直接抛出了异常。由此可见,EventEmitter 在执行内部逻辑的时候,并没有try-catch。这个原因,请见Node Issue。简单来讲,Error 和 Exception 并不完全一样。

如果按照正常想法,不想每一次都在外面套一层try-catch,那应该怎么做呢?我的做法是在 EventEmitter 原型链上新增一个safeEmit函数。

EventEmitter.prototype.safeEmit = function(name, ...args) {
    try {
        return this.emit(name, ...args);
    } catch (error) {
        return this.emit("error", error);
    }
};

如此一来,运行前一段代码的 Exception 就会被捕获到,并且触发error事件。前一段代码的输出就变成了:

error msg is a is not defined

监听器队列顺序处理

对于同一个事件,触发它的时候,函数的执行顺序就是函数绑定时候的顺序。官方库提供了emitter.prependListener()emitter.prependOnceListener() 两个接口,可以让新的监听器直接添加到队列头部。

但是如果想让新的监听器放入任何监听器队列的任何位置呢?在原型链上封装了 insertListener 方法。

EventEmitter.prototype.insertListener = function(
    name,
    index,
    callback,
    once = false
) {
    // 如果是once监听器,其数据结构是 {listener: Function}
    // 正常监听器,直接是 Function
    const listeners = ins.rawListeners(name);
    const that = this;
    // 下标不合法
    if (index > listeners.length || index < 0) {
        return false;
    }
    // 绑定监听器数量已达上限
    if (listeners.length >= this.getMaxListeners()) {
        return false;
    }
    listeners.splice(index, 0, once ? { listener: callback } : callback);
    this.removeAllListeners(name);
    listeners.forEach(function(item) {
        if (typeof item === "function") {
            that.on(name, item);
        } else {
            const { listener } = item;
            that.once(name, listener);
        }
    });
    return true;
};

使用起来,效果如下:

const ins = new MyEmitter();
ins.on("error", error => {
    console.log("error msg is", error.message);
});

ins.on("test", () => {
    console.log("test 1");
});

ins.on("test", () => {
    console.log("test 2");
});

// 监听器队列中插入新的监听器,一个是once类型,一个不是once类型
ins.insertListener(
    "test",
    0,
    () => {
        console.log("once test insert");
    },
    true
);
ins.insertListener("test", 1, () => {
    console.log("test insert");
});

连续调用两次ins.emit("test"),结果输出如下:

# 第一次
once test insert
test insert
test 1
test 2
# 第二次: once 类型的监听器调用一次后销毁
test insert
test 1
test 2

内存管理与防止泄漏

在绑定事件监听器的时候,如果监听器没有被 remove,那么存在内存泄漏的风险。

我知道的常见做法如下:

  • 经常 CR,移除不需要的事件监听器
  • 通过once绑定监听器,调用一次后,监听器被自动移除
  • [推荐]hack 一个更安全的EventEmitter

TODO: 配合 Promise 使用

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 四:单页面解决方案--代码分割和懒加载

    其中,page.js是入口文件,subPageA.js和subPageB.js共同引用module.js。下面,我们按照代码引用的逻辑,从底向上展示代码:

    心谭博客
  • NodeJS模块研究 - dns

    最直观的体验是,当在浏览器中输入网址时,浏览器能够找到网址对应的服务器的 ip 地址。这个过程就是依赖 DNS 域名解析。

    心谭博客
  • 【serverless实战】腾讯云·云开发+nextjs(SSR or 静态导出)实现官网动态化

    www.cloudbase.net 云开发网站是基于 nextjs 开发,里面的内容是写在 js 配置文件。每当更新网站内容,都需要提交 git,并且本地进行静...

    心谭博客
  • Python使用redis的消息队列

    Criss@陈磊
  • 有个微信小程序想人工智能跟你一起修复老照片

    IT派 - {技术青年圈} 持续关注互联网、大数据、人工智能领域 每到过年,长辈们总会翻出所剩不多的老照片讲讲故事。这些老照片黑白,或者泛黄...

    IT派
  • 印度与巴基斯坦央行禁止银行为加密货币交易提供服务

    据国外媒体报道,去年价格疯涨的比特币等加密货币在今年面临的监管也越来越严格,印度和巴基斯坦央行日前先后发出禁令,禁止银行为加密货币交易提供服务。

    周俊辉
  • 掌握这9大重点要素,智能合约开发不是事儿

    本文详细分析了在智能合约开发过程中,需要考虑的9个重点因素,其中涉及数字货币的波动性、货币的时间价值、交易速度等等。虽然对于每一个因素,没有提供对应的操作细则。...

    区块链大本营
  • 安卓Chrome使用技巧合辑

    美丽应用
  • 腾讯刘琼:互联网+医疗玩什么

      9月15日晚,第15期互联网前沿沙龙如期举行,丁香园董事长李天天、移动医疗创业公司e陪诊CEO岳建雄、春风创投合伙人毕磊、腾讯研究院高级研究员刘琼共同探讨了...

    腾讯研究院
  • 应该使用什么 CI/CD 工具?

    在我们正在进行的 Kubernetes FAQ 系列中,我们回答了社区中一些常见的问题,本周我们将讨论在选择 CI/CD 工具时需要考虑什么。

    LinuxSuRen

扫码关注云+社区

领取腾讯云代金券