第26节 Node.js 事件

Node里很多对象会分发事件: 每次有连接的时候net.Server会分发事件,当文件打开的时候fs.readStream会分发事件。所有能分发事件的对象都是 events.EventEmitter的实例。通过require("events");能访问这个模块。

一般来说,事件名都遵照驼峰规则,但这不是强制规定,任何形式的字符串都可以做为事件名。

为了处理事件,通常将函数关联到对象上。这些函数也叫监听者(listeners)。在这个函数里,this指向监听者所关联的EventEmitter

类: events.EventEmitter

你可以通过require('events').EventEmitter获取EventEmitter类。

EventEmitter实例遇到错误后,通常会触发一个错误事件。错误事件在node里是特殊例子。如果没有监听者,默认的操作是打印一个堆栈信息并退出程序。

当添加新的监听者时, EventEmitters会触发'newListener'事件,当移除时会触发'removeListener'

emitter.addListener(event, listener)

emitter.on(event, listener)

添加一个监听者到特定event的监听数组的尾部,触发器不会检查是否已经添加过这个监听者。 多次调用相同的eventlistener将会导致listener添加多次。

server.on('connection', function (stream) {console.log('someone connected!');
});

返回emitter。

emitter.once(event, listener)

给事件添加一个一次性的listener,这个listener只会被触发一次,之后就会被移除。

server.once('connection', function (stream) {console.log('Ah, we have our first user!');
});

返回emitter。

emitter.removeListener(event, listener)

从一个某个事件的listener数组中移除一个listener。注意,这个操作会改变listener数组内容的次序。

var callback = function(stream) {console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);

removeListener最多会移除数组里的一个listener。如果多次添加同一个listener到数组,那就需要多次调用removeListener来移除每一个实例。

返回emitter。

emitter.removeAllListeners([event])

移除所有的listener,或者某个事件listener。最好不要移除全部listener,尤其是那些不是你传入的(比如socket或文件流)。

返回emitter。

emitter.setMaxListeners(n)

默认情况下,给单个事件添加超过10个listener,事件分发器会打印警告。这样有利于检查内存泄露。不过不是所有的分发器都应该限制在10个,这个函数允许改变 listener数量,无论是0还是更多。

返回emitter。

EventEmitter.defaultMaxListeners

emitter.setMaxListeners(n)设置一个分发器的最大listener数,而这个函数会立即设置所有EventEmitter的当前值和默认值。要小心使用。

请注意,emitter.setMaxListeners(n)的优先级高于EventEmitter.defaultMaxListeners.

emitter.listeners(event)

用于返回事件的listener数组。

server.on('connection', function (stream) {console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection'))); // [ [Function] ]

emitter.emit(event[, arg1][, arg2][, ...])

允许你使用指定的参数顺序的执行每一个listener.

如果事件有 listener,返回true, 否则false

类方法: EventEmitter.listenerCount(emitter, event)

返回指定事件的listener数量。

Event: 'newListener'

  • event{String}事件名
  • listener{Function}事件处理函数

添加listener的时候会触发这个事件。当这个事件触发的时候,listener可能还没添加到listener数组。

Event: 'removeListener'

  • event{String}事件名
  • listener{Function}事件处理函数

删除listener的时候会触发这个事件。当这个事件触发的时候,listener可能还还没从listener数组移除。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.pswp.cn/web/83722.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

LangChain + MCP + vLLM + Qwen3-32B 构建本地私有化智能体应用

一、私有化智能体应用 在本专栏的前面文章基于Spring AI MCP实现了本地 ChatBI 问答应用,本文还是依据该场景,采用 LangChain vLLM Qwen3-32B MCP 技术栈构建该流程,整体过程如下图所示: 实现效果如下所示: 关于 M…

AKS升级路线最佳实践方案

前言 Kubernetes 社区大约每 4 个月发布次要版本,次要版本包括新增功能和改进。补丁发布更为频繁(有时每周都会发布),适用于次要版本中的关键 Bug 修复。修补程序版本包括针对安全漏洞或主要 bug 的修复。对于受支持版本列表以…

树莓派智能小车基本移动实验指导书

1.安装LOBOROBOT库函数 LOBOROBOT.py代码如下: #!/usr/bin/python # -*- coding: utf-8 -*-import time import math import smbus import RPi.GPIO as GPIODir [forward,backward, ]class PCA9685:# Registers/etc.__SUBADR1 0x02__SUBADR2 …

如何对目标检测算法RT-DETR进行创新和改进:突破瓶颈,提升性能!

更多精彩,详见文末~~~ 在目标检测的高速发展中,RT-DETR作为DETR(DEtection TRansformer)的高效变体,凭借其优异的性能和较快的推理速度,已经成为许多实际应用中的首选算法。然而,尽管RT-DETR在…

Java-String

前言 package com.kjxy.st;public class TestString1 {public static void main(String[] args) {String s1 "hello";String s2 "hello";String s3 new String("hello");String s4 new String("hello");System.out.println(s1 s2…

计算机组成原理——C/存储系统

🌈个人主页:慢了半拍 🔥 创作专栏:《史上最强算法分析》 | 《无味生》 |《史上最强C语言讲解》 | 《史上最强C练习解析》|《史上最强C讲解》|《史上最强计组》|《史上最强数据结构》 🏆我的格言:一切只是时…

什么是电输运性能

电输运性能‌是指材料在电场作用下,电子在材料中传输的能力和效率。具体来说,电输运性能包括以下几个方面: ‌电子的自由移动性‌:导体中的电子具有较大的自由移动能力,这是由于导体中的原子或分子结构具有一定的松散…

k3s入门教程(二)部署前后端分离程序

文章目录 部署基础服务部署Redis部署MySQL端口转发测试 运行与构建前后端镜像构建后端镜像 docker build -t ruoyi-admin:v3.8 .构建前端镜像 docker build -t ruoyi-ui:v3.8 .创建私库,推拉镜像 前后端应用部署后端应用部署前端应用部署 启动顺序与初始化容器修改前…

Seata如何与Spring Cloud整合?

🔧 一、整合核心步骤 1. 启动 Seata Server(TC) 环境准备: 修改 registry.conf,指定注册中心(如 Nacos)和配置中心:registry {type "nacos"nacos {serverAddr "l…

Python惰性函数与技术总结-由Deepseek产生

在Python中,惰性(Lazy)技术指延迟计算直到真正需要结果时才执行,常用于优化内存和性能。以下是常见的惰性函数和技术: 1. 生成器(Generators) 原理:使用 yield 返回迭代结果&#x…

轮廓 裂缝修复 轮廓修复 填补孔洞 源代码

目录 1. 形态学闭合操作填补小孔洞 完整代码: 使用 Douglas-Peucker 算法对轮廓进行多边形逼近 2.裂缝修复 轮廓修复 轮廓补全 函数封装 调用示例: 1. 形态学闭合操作填补小孔洞 完整代码: import cv2 import numpy as np# 创建模拟图像(白色区域 + 多个不规则黑洞)…

HTTP1.1

HTTP基础知识 HTTP(HyperText Transfer Protocol)是用于传输超文本 的应用层协议,采用客户端-服务器 模型。 客户端(如浏览器)发起请求,服务器响应并返回数据。 工作原理 客户端发送HTTP请求至服…

【Linux教程】Linux 生存指南:掌握常用命令,避开致命误操作

Linux 常用操作命令:避免误操作指南 在 Linux 系统中,熟练掌握常用操作命令是高效工作的基础,但同时也要警惕误操作带来的风险。无论是部署程序、配置防火墙、管理端口还是处理进程,一个小小的失误都可能导致系统故障、数据丢失等…

PHP:Web 开发领域的常青树

在当今数字化浪潮中,Web 开发技术日新月异,各种新兴语言和框架层出不穷。然而,PHP 作为一门经典的后端开发语言,依然在 Web 开发领域占据着重要地位,展现出强大的生命力和广泛的应用价值。 PHP 的历史与现状 PHP&…

平均数与倍数

目录 一. 平均数现期平均数基期平均数(比较冷门)两期平均数-比较平均数的增长量平均数的增长率 二. 倍数基期倍数 \quad 一. 平均数 \quad 现期平均数 \quad \quad \quad \quad \quad \quad \quad \quad \quad \quad 平均数速算技巧:削峰填谷…

一个完整的日志收集方案:Elasticsearch + Logstash + Kibana+Filebeat (三)

现在我们主要完成AI-RAG服务的扩展,利用ES的向量检索能力完成历史聊天记录的存储和向量检索,让ai聊天有记忆。 主要做法是在首次聊天完成后将对话内容写出日志到D:\dev\dev2025\EC0601\logs\chat-his.log 写出日志同时嵌入向量 向量可以从ollama的端点&…

Vue嵌套(多级)路由

一、前言 在构建中大型单页应用(SPA)时,页面结构往往比较复杂,比如仪表盘、用户中心、商品管理等模块通常包含多个子功能页面。为了更好地组织这些页面,Vue Router 提供了嵌套(多级)路由的功能。 通过嵌套路由,我们可以在父级组件中嵌入一个 <router-view> 来展…

Kubernetes 集群安全(身份认证机制、SecurityContext、Network Policy网络策略、预防配置泄露、全面加固集群安全)

Kubernetes 集群安全(身份认证机制、SecurityContext、Network Policy网络策略、预防配置泄露、全面加固集群安全) 一、Kubernetes 身份认证机制 身份认证(Authentication): 在 K8S 中,身份认证是安全访问控制的第一道大门,它的目标是: 确认请求发起者的真实身份 K8…

【VUE3】基于Vue3和Element Plus的递归组件实现多级导航栏

文章目录 前言一、递归的意义二、递归组件的实现——基于element-plus UI的多级导航栏2.1 element-plus Menu菜单官方示例2.2 接口定义2.3 组件递归2.4 父组件封装递归组件 三、完整代码——基于element-plus UI的多级导航栏3.1 组件架构3.2 types.ts3.3 menuTreeItem.vue3.4 i…

思科资料-ACL的基础配置-详细总结

一、ACL技术 1、定义 访问控制列表访问控制列表使用包过滤技术&#xff0c;在路由器上读取第三层及第四层包头中的信息如源地址&#xff0c;目的地址&#xff0c;源端口&#xff0c;目的端口等&#xff0c;根据预先定 义好的规则对包进行过滤&#xff0c;从而达到访问控制的目…