[NodeJS]核心模块--Events

Events是Node中的一个很重要的核心模块,Stream, 网络,文件系统统统都是继承自这个模块。

Streams模块就是继承自EventEmitter,所以说弄明白Events模块,特别是EventEmitter对象, 对于理解Node中的很多模块都是有好处的。

Stream非常擅长处理数据,无论是读,写或者是转换。比如,你可以用Stream接收数据库中的数据,将其流出到csv的流中,导出成为csv格式。

接着你可以再传入一个http请求(也是一种流)将数据再流入到http流中,这样就可以直接将数据显示在浏览器中。

或者你可以将数据流入到一个可写的文件流中,通过创建文件将文件发送给浏览器。

除了Node自身的核心模块,很多第三方开源项目也都是基于EventEmitter构建的。如 Express, Connect, RedisClient

EventEmitter

通常来说,我们都希望自定义类能够实现EventEmitter类提供的基本功能。

于是我们可以使用util模块提供的util.inherits()方法来实现原型链上的继承。

而EventEmitter类提供了on() 和 emit() 方法用于绑定事件和触发事件。

也可以使用removeListener() 方法来删除监听器,但是需要注意,和定时器一样,你需要将监听器保存在某个函数变量中。

同样,可以使用 once() 方法来绑定只执行一次的监听事件。

// musicPlayer.js
// 通过继承EventEmitter来实现一个基于事件的音乐播放器

var util = require("util");
var events = require("events");

function MusicPlayer(){
    this.playing = false;
        events.EventEmitter.call(this);
}

util.inherits(MusicPlayer, events.EventEmitter);

var audioDevice = {
    play: function(track){
        console.log("play in ", track);
    },
    stop: function(){
        console.log("stop play");
    }
};

// 实例化播放器类
var myMusicPlayer = new MusicPlayer();
myMusicPlayer.on(‘play‘, function() {
    this.playing = true;
});
myMusicPlayer.on(‘stop‘, function() {
    this.playing = false;
    audioDevice.stop();
});
myMusicPlayer.once(‘play‘, function(){
    console.log("begin play");
});
myMusicPlayer.on(‘play‘, function(track) {
    audioDevice.play(track);
});

myMusicPlayer.emit("play", "The roots - the fire");

setTimeout(function(){
    myMusicPlayer.emit("stop");
    setTimeout(function(){
        myMusicPlayer.emit("play", "Country Road");
    }, 3000);
}, 2000);

混合EventEmitter类

有些时候你使用的类是别人提供给你的类,这个时候不能简单的将其继承自EventEmitter类。那么可以通过for ... in 循环将一个原型对象上的属性拷贝到另外一个原型对象上。

前面那个音乐播放器类可以升级为

// musicPlayer 音乐播放器类升级版

var EventEmitter = require("events").EventEmitter;

function MusicPlayer(track){
    this.track = track;
    this.playing = false;

    for(var method in EventEmitter.prototype){
        this[method] = EventEmitter.prototype[method];
    }
}

MusicPlayer.prototype.toString = function(){
    if(this.playing){
        return "Now playing: " + this.track;
    }else{
        return "Stopped";
    }
};

var myMusicPlayer = new MusicPlayer("Girl Talk - Still Here");
myMusicPlayer.on(‘play‘, function() {
    this.playing = true;
    console.log(this.toString());
});

myMusicPlayer.on("stop", function(){
    this.playing = false;
    console.log(this.toString());
});

myMusicPlayer.emit("play");

setTimeout(function(){
    myMusicPlayer.emit("stop");
},3000);

异常处理

在Node中,error事件被当做特殊情况。如果没有针对error的监听器,那么一旦发生错误,则系统将会按照默认的方式进行处理,即打印一个堆栈并且退出程序。

建议使用 on() 方法来监听 error 事件。上面这种是常用的处理异常的一种方式,其实到这一步,就可以了。

但是如果想了解更多如何集中处理多个异常操作,特别是当你正在执行多个非阻塞IO操作时,如何有效处理异常则是需要认真学习的地方。这里需要使用到node的核心模块 domain

domain接口提供了用异常处理封装已有的非阻塞API以及错误的方法。能够帮助我们集中处理所有的异常,特别是有多个相互依赖的IO操作时非常有用。

domain模块使用create() 方法创建实例,给实例绑定一个error事件监听器,于是在实例的run 方法中运行回调函数导致的error都会被domain覆盖。

根据最新Node官方文档,一旦有新的可替代方案出现,domain模块就会被彻底废弃。所以第二种方法就不介绍了。

反射

Node的events模块提供了一个 newListener 事件,用于跟踪监听器何时被添加,而监听这个事件的监听器函数会接收到事件名称和事件处理程序(监听器的方法)

也就是说当你通过 on() 方法添加事件监听器时就会触发 newListener 事件。在这个回调函数中,新注册的同名事件都会被插入到同名事件监听器队列的前面。

eventEmitter.on("newListener", function(eventName, function){ });

EventEmitter实例的 listeners(eventName) 方法会返回指定事件名称的监听器数组的副本,通过 length属性检查当前监听器的数量。

接下来说到一个小技巧: 如何管理模块中众多的事件名,而不会出现混乱。

解决方案就是给你的模块定义一个events对象专门用来存放事件名。

结语

虽然EventEmitter模块很重要,并且很多开源项目都是基于EventEmitter开发的。但是,并不能说EventEmitter就是完美的。所以就出现了替代品。如 AMQP, ZeroMQ, js-signals, Redis等等

时间: 2024-10-06 00:31:07

[NodeJS]核心模块--Events的相关文章

Nodejs核心模块

全局对象 Nodejs中全局对象是 global(作为全局变量的宿主),所有全局变量都是global对象的属性,在Nodejs中能够直接访问到的对象通常都是global的属性,如 console,process等. 在最外层定义的变量 全局对象的属性: 隐式定义的变量(未定义直接赋值的变量) 当定义一个全局变量时,这个变量同时也会成为全局对象的属性. 注意:永远使用var定义变量,以避免引入全局变量,因为全局变量会污染命名空间,提高代码耦合的风险. 1.1.process process.arg

nodejs 核心模块crypto

crypto用于加密解密 'use strict'var crypto=require('crypto'); var data={age:18}var key='dt';//定义一个钥匙var plaintext = JSON.stringify(data);var cryped = '';// aes192是一种加密算法,此处也可换成blowfishvar cipher = crypto.createCipher('aes192', key);//加密cryped += cipher.upda

Nodejs进阶:核心模块net入门与实例讲解

模块概览 net模块是同样是nodejs的核心模块.在http模块概览里提到,http.Server继承了net.Server,此外,http客户端与http服务端的通信均依赖于socket(net.Socket).也就是说,做node服务端编程,net基本是绕不开的一个模块. 从组成来看,net模块主要包含两部分,了解socket编程的同学应该比较熟悉了: net.Server:TCP server,内部通过socket来实现与客户端的通信. net.Socket:tcp/本地 socket的

nodejs第三天(核心模块与文件模块,核心模块和文件模块引入的区别,从模块外部访问模块内部,使用exports对象,npm包管理工具package.json文件,模块对象属性,将模块定义分类,npm发布流程,安装淘宝镜像,模块的管理)

核心模块与文件模块 ndejs是一个js运行环境,是一个平台.nodejs基于操作系统,封装了一些功能,http,tcp,udp,i/o模块,path,fs,stream等等 通过nodejs内置的模块,他们就称为核心模块.(他们都是nodejs内置的)http,fs,path等 文件模块:只要写一个js文件,每一个文件都是模块 .(自己写的js文件都被称为文件模块) 核心模块和文件模块引入的区别 核心模块有环境变量做调度 文件模块需要给出文件路径 注意:核心模块是nodejs内置的一些功能模块

nodeJS之事件events

前面的话 events模块是node的核心模块,几乎所有常用的node模块都继承了events模块,比如http.fs等.本文将详细介绍nodeJS中的事件机制 EventEmitter 多数 Node.js 核心 API 都是采用惯用的异步事件驱动架构,其中某些类型的对象(称为触发器)会周期性地触发命名事件来调用函数对象(监听器).例如,一个net.Server对象会在每次有新连接时触发一个事件:一个 fs.ReadStream 会在文件被打开时触发一个事件:一个 stream会在数据可读时触

Node.js【5】核心模块

笔记来自<Node.js开发指南>BYVoid编著 第4章 Node.js核心模块 4.1.全局对象 Node.js中的全局对象是global,所有全局变量(除了global本身以外)都是global对象的属性.我们在Node.js中能够直接访问到对象通常都是global的属性,如console.process等. 永远使用var定义变量以避免引入全局变量,因为全局变量会污染命名空间,提高代码的耦合风险. process用于描述当前Node.js进程状态的对象,提供了一个与操作系统的简单接口.

Nodejs的模块系统以及require的机制

一.简介 Nodejs 有一个简单的模块加载系统.在 Nodejs 中,文件和模块是一一对应的(每个文件被视为一个独立的模块),这个文件可能是 JavaScript 代码,JSON 或编译过的C/C++ 扩展,例如: /** *foo.js *将这个js文件导出为模块 */ exports.hello = function() { console.log("hello Nodejs!"); } /** *main.js *main.js和foo.js在同一目录下 *在控制台中将会输出:

【Nginx】核心模块ngx_events_module

核心模块ngx_events_module是一个专门用于管理事件模块的模块.它的实现很简单,下面是该模块的定义: ngx_module_t ngx_events_module = { NGX_MODULE_V1, &ngx_events_module_ctx, /* module context */ ngx_events_commands, /* module directives */ NGX_CORE_MODULE, /* module type */ NULL, /* init mast

node.js学习笔记5——核心模块1

Node.js核心模块主要内容包括:(1)全局对象 (2)常用工具 (3)事件机制 (4)文件系统访问 (5)HTTP服务器与客户端 一: 全局对象 Node.js中的全局对象是global,所有的全局变量(除了global本身以外)都是global的属性. global 最根本的作用是作为全局变量的宿主. 全局变量的条件: (1)在最外层定义的变量; (2)全局对象的属性: (3)隐式定义的变量(未定义直接赋值的变量(strict模式下不可以)) 在Node.js中不可能在最外层定义变量,因为