深入聊聊node.js中的EventEmitter

本篇文章带大家了解一下node中的eventemitter,简单聊聊一下异步操作、error事件、eventemitter类,希望对大家有所帮助!

深入聊聊node.js中的EventEmitter

events(事件触发器)

events是nodejs内置的事件触发器,在node的内置模块里很多都用到了events,比如http.server在每次接受到请求时触发事件,还有stream就是基于事件的使用on来监听对应的事件。所有触发事件的对象都是EventEmitter实例,这些对象暴露了EventEmitter.on(‘事件’,callback),通常使用EventTmitte.on注册事件,EventEmitter.emit触发事件。

例子:

  const events= require('events');const event=new events();//实例化EventEmitterevent.on('data',(a,b)=>{    console.log('参数'+a+b)    console.log(this,'this')    //注意,如果callback是 箭头函数的话this指向的是全局对象    //      如果callback是function(){}形式的话,this会绑定到EventEmitter实例上    console.log('emit触发了data事件')})event.emit('data',1,2); //使用emit触发事件

异步操作

因为EventEmitter.on(‘事件名称’,callback)里的callback是同步执行的,但是在某些情况下我们不得不使用异步操作所以我们可以在使用SetImmediate来执行异步操作

 const events= require('events');const event=new events();event.on('event', (a, b) => {      setImmediate(() => {    console.log('this happens asynchronously');  });  //因为这里的监听器是同步执行的,但是我们可以使用setImediate函数等待监听器里的其他内容执行完再执行});event.emit('event',1,2);

触发一次

我们正常通过emit触发事件时,emit有几个事件就会被触发几次,但是我们可以使用once注册事件,使用once触发的事件只能被触发一次

  const EventEmitter =require('events');  const MyEventEmitter=new EventEmitter();  let a=0;  //正常注册事件和触发  MyEventEmitter.on('add',()=>{      a++      console.log(a)   })  MyEventEmitter.emit('add'); // 1;  MyEventEmitter.emit('add'); // 2;  // 使用once注册  MyEventEmitter.once('add',()=>{      a++      console.log(a);  })  MyEventEmitter.emit('add') // 1  MyEventEmitter.emit('add') // 不生效了

error事件

EventEmitter是没有error事件的,所以当发生错误的时候只能强制退出执行,所以我们必须自己注册一个error事件,以致于在发生错误的时候触发到error事件

 const EventEmitter=require('events'); const MyEventEmitter=new EventEmitter(); MyEvenEmitter.on('error',(err)=>{   console.error(err,'报错了') })

除了上面那种方式我们还可以通过errorMonitor在不注册error事件的情况下,来监听emit触发的报错使用了errorMonitor我们就不必要再去通过手动注册error事件了

  const {EventEmitter,errorMonitor}=require('events');  const MyEventEmitter=new EventEmitter();  MyEventEmitter.on(errorMonitor,(err)=>{      console.log(err);  })  MyEventEmitter('error' , new Error('报错了'))

EventEmitter类

newListener事件

在我们添加事件监听的时候会触发newListener事件,所以我们可以注册newListener事件用来在添加事件监听的时候做一些事情

百度文心百中 百度文心百中

百度大模型语义搜索体验中心

百度文心百中 22 查看详情 百度文心百中

 const {EventEmitter}=require('events');  const MyEvent=new EventEmitter();  MyEvent.on('newListener',(name,litener)=>{      //name就是正在监听的事件的名称      //listener是事件的处理函数      MyEvent.on('event',()=>{        console.log('在newListener添加的事件')      })    })  MyEvent.on('event',()=>{      console.log('正常注册的event事件')  })  //此时我们再不触发event事件的情况下,newListener事件就会执行,因为我们只要正在注册事件就会触发newListener事件  //注意:newListener事件必须要使用EventEmitter.once()注册,因为如果我们在newListener事件里再去添加注册事件的话,而且外边有多个注册事件就会触发多次newListener事件,就会发生堆栈溢出 MyEvent.emit('event'); //打印的结果   //    在newListener注册的事件   //     正常注册的event事件

removeListener事件

removeListener事件用于删除已经注册的事件,但是,removeListener不会阻止掉正在被emit触发的事件

 const callbackB=()=>{    console.log('B')}const callbackA=()=>{    console.log('A')    event.removeListener('data',callbackB)}event.on('data',callbackA)event.on('data',callbackB)event.emit('data'); //在执行callbackA的时候删除了data,但是不会阻止掉下一个emit的触发event.emit('data'); //在这里的时候才是真正被删除掉了

addListener 和on的作用一样

eventNames

返回一个数组,数组里包含了所有已经注册的事件的名称

 const {EventEmitter} =require('events'); const MyEvent=new EventEmitter(); MyEvent.on('data',()=>{}); MyEvent.on('finish',()=>{}); console.log(MyEvent.eventNames());  //打印结果  ['data','finish']

getMaxListeners

返回可以注册的事件的最大数值,默认是10,如果超过10个会有警告但是我们可以通过setMaxListener(20) 去进行修改

const {EventEmitter} =require('events'); const MyEvent=new EventEmitter(); console.log(MyEvent.getMaxListener()); //10 event.setMaxListener(20);  console.log(MyEvent.getMaxListener(20));

listenerCount

返回注册的事件的数量

 const {EventEmitter} =require('events'); const MyEvent=new EventEmitter(); MyEvent.on('data',()=>{}); MyEvent.on('data',()=>{}); MyEvent.on('finish',()={}); console.log(MyEvent.listenerCount()) // 2

更多node相关知识,请访问:nodejs 教程!

以上就是深入聊聊node.js中的EventEmitter的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/550704.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月9日 19:58:02
下一篇 2025年11月9日 19:59:25

相关推荐

  • 微服务容器化高可用部署示例

    微服务容器化高可用部署通过Kubernetes实现弹性伸缩与故障自愈。1. 使用Docker将各服务打包为镜像并推送至仓库;2. Kubernetes中通过Deployment管理多副本Pod,结合livenessProbe和readinessProbe实现健康检查与自动恢复;3. Service提…

    2025年12月16日
    000
  • Golang如何使用指针实现树结构

    Go语言通过结构体与指针定义二叉树节点,如type TreeNode struct{ Val int; Left, Right *TreeNode },使用NewNode函数返回节点指针并构建树结构,通过递归实现前序遍历等操作,利用指针直接修改树的结构,如插入、删除或交换子树,确保多处共享同一节点,…

    2025年12月16日
    000
  • Go语言垃圾回收机制:理解循环引用与可达性分析

    go语言的垃圾回收器采用基于可达性分析的标记-清除算法。即使对象之间存在循环引用,只要它们不再能从任何gc根(如全局变量、栈变量)访问到,go gc也能有效地识别并回收这些不可达的内存,从而避免因循环引用导致的内存泄漏。 在Go语言的内存管理中,理解垃圾回收器(GC)的工作原理对于编写高效且无内存泄…

    2025年12月16日
    000
  • Go语言垃圾回收机制深度解析:可达性与循环引用处理

    go语言的垃圾回收器采用可达性分析模型。即使对象之间存在循环引用(如双向链表),只要这些对象不再能从任何gc根(如全局变量、活跃的栈帧)被访问到,它们就会被视为不可达并被垃圾回收器回收。这意味着开发者通常无需手动打破循环引用以释放内存。 理解Go语言的垃圾回收机制 Go语言的垃圾回收(GC)机制是其…

    2025年12月16日
    000
  • 理解Go语言垃圾回收:循环引用对象如何被回收

    go语言的垃圾回收机制基于可达性分析,而非传统的引用计数。这意味着即使对象之间存在循环引用,只要它们从任何垃圾回收根(gc roots)都不可达,go运行时环境的垃圾收集器就会将其识别并回收。本文将通过具体代码示例,深入探讨go语言如何高效处理循环引用,确保内存资源的有效管理。 Go语言垃圾回收机制…

    2025年12月16日
    000
  • Go语言中高效提取HTML节点文本内容的教程

    在使用go语言进行web内容抓取和解析时,`golang.org/x/net/html`(原`code.google.com/p/go.net/html`)库是一个强大而基础的工具,它能将html文档解析成一个dom树结构。然而,对于初学者而言,一个常见的困惑是如何从一个`html.node`中提取…

    2025年12月16日
    000
  • 深入理解Go GC:如何处理循环引用与不可达性

    本文深入探讨go语言垃圾回收器如何处理包含循环引用的数据结构。go gc采用基于可达性分析的并发标记清除算法,这意味着即使对象间存在循环引用,只要它们从程序根节点变得不可达,gc便能有效回收这些内存,从而避免了传统引用计数机制中常见的循环引用导致的内存泄漏问题。通过一个链表示例,我们将详细阐述这一机…

    2025年12月16日
    000
  • 理解Go语言垃圾回收:如何处理循环引用对象

    go语言的垃圾回收器采用可达性分析而非引用计数。这意味着即使对象之间存在循环引用,只要它们不再被任何gc根引用而变得不可达,垃圾回收器就能自动将其回收。本文将通过示例代码深入解析go gc如何有效管理内存,避免循环引用导致的内存泄漏。 Go语言垃圾回收机制概述 Go语言内置的垃圾回收(GC)机制是其…

    2025年12月16日
    000
  • 如何在Golang中配置多版本管理

    使用gvm、asdf或手动方式可实现Go多版本管理。gvm支持快速安装与切换,如gvm use go1.20.7;asdf适用于多语言统一管理,通过asdf global/local设置版本;手动方案则通过别名切换GOROOT和PATH。选择依据工作流,关键确保环境变量正确指向目标版本。 在Gola…

    2025年12月16日
    000
  • Golang环境搭建中如何切换Go版本

    使用g工具可高效管理多版本Go,安装后通过g install、g use和g set命令切换或设置默认版本,gvm功能更全面但依赖shell配置,手动方式则需自定义目录并修改GOROOT和PATH环境变量,适合不用第三方工具的场景。 在Golang开发中,经常需要在不同项目中使用不同版本的Go。为了…

    2025年12月16日
    000
  • Go语言go.net/html库:深入解析与提取html.Node的文本内容

    本文详细介绍了如何使用go语言的`go.net/html`库从html文档中提取特定`html.node`的完整文本内容。当节点包含嵌套元素时,直接获取文本会遇到挑战。教程通过递归遍历子节点并收集所有`textnode`数据的方法,提供了一个高效且通用的解决方案,并附带了具体的代码示例。 在使用Go…

    2025年12月16日
    000
  • Go net/http:高效获取URL查询参数的FormValue方法

    本文详细介绍了在go语言的`net/http`包中如何高效地获取url查询参数,解答了node.js中`request.param`在go中的对应实现。核心是利用`*http.request`对象的`formvalue`方法,它能便捷地提取指定名称的参数值,并兼顾了post/put请求体参数的优先级…

    2025年12月16日
    000
  • Golang进程控制与信号处理:构建健壮的进程包装器

    本文深入探讨了go语言中实现进程管理和信号处理的多种方法。我们将详细介绍go中执行外部程序的不同途径,以及如何利用`os/signal`包捕获发送给go应用程序的系统信号,同时阐述如何向其他进程发送信号。通过理解这些机制,开发者能够构建出健壮的进程包装器,实现对子进程的有效监控与控制。 在Go语言中…

    2025年12月16日
    000
  • Go语言中利用go.net/html库高效提取HTML节点文本内容

    本教程详细讲解如何使用go语言的`go.net/html`库从html节点中提取纯文本内容。针对文本可能嵌套在多层子元素中的情况,文章提供了一种递归遍历节点树并收集所有文本节点的通用方法,并通过示例代码展示了如何将其集成到html解析和遍历流程中,帮助开发者准确获取所需数据。 理解go.net/ht…

    2025年12月16日
    000
  • 深入理解go.net/html:如何获取HTML节点的完整文本内容

    本教程详细介绍了如何使用go语言的`go.net/html`库解析html并准确提取html元素的内部文本内容。文章阐明了html节点树结构中`elementnode`与`textnode`的区别,并提供了一种通过递归遍历子节点来收集所有文本内容的通用方法,辅以示例代码和注意事项,帮助开发者高效处理…

    2025年12月16日
    000
  • Go语言中高效获取HTML节点文本内容的教程

    本文详细介绍了如何在go语言中使用`go.net/html`库高效地提取html节点的文本内容。针对文本可能嵌套在子元素中的复杂情况,文章提供了一种递归遍历节点树并收集所有文本节点的解决方案,并通过示例代码演示了如何准确获取链接等元素的可见文本,从而克服直接获取`elementnode`数据时的局限…

    2025年12月16日 好文分享
    000
  • 如何在Golang中实现网络数据加密传输

    答案:Golang中通过TLS实现网络加密传输,服务端使用ListenAndServeTLS启用HTTPS,客户端配置http.Transport支持安全连接,非HTTP场景可用crypto/tls封装TCP通信,开发可自签证书,生产需CA签发并正确配置根证书池以确保安全。 在Golang中实现网络…

    2025年12月16日
    000
  • Golang如何实现指针链表遍历

    定义ListNode结构体后,通过循环或递归遍历链表。循环方式更安全高效,从头节点开始逐个访问直至nil,避免栈溢出风险。 在Go语言中实现指针链表的遍历,核心是定义一个链表节点结构体,使用指针连接各个节点,然后通过循环或递归方式从头节点开始逐个访问每个节点的数据。 定义链表节点结构 链表由多个节点…

    2025年12月16日
    000
  • Golang go.mod文件内容如何理解

    go.mod是Go模块的核心配置文件,定义模块名、Go版本及依赖。module声明模块路径,作为导入包的前缀;go指定Go语言版本,影响语法特性和模块行为;require列出直接依赖及其版本,支持// indirect标记间接依赖;replace可替换依赖源,常用于本地调试;exclude用于排除特…

    2025年12月16日
    000
  • Go 服务部署策略:跨平台编译与自动化实践

    本文探讨了go语言服务的部署策略,重点介绍了其强大的跨平台编译能力,允许开发者在不同操作系统和架构上生成可执行文件,从而避免在生产环境进行编译。文章还强调了通过go语言或现有工具(如capistrano)进行自动化部署的重要性,并鼓励利用go社区资源获取最新实践和工具。 Go语言因其高性能和并发特性…

    2025年12月16日
    000

发表回复

登录后才能评论
关注微信