码迷,mamicode.com
首页 > Web开发 > 详细

EventEmitter:nodeJs事件触发机制

时间:2018-12-09 18:42:57      阅读:466      评论:0      收藏:0      [点我收藏+]

标签:time   正是   使用   app   prot   添加   message   out   请求   

Node.js 所有的异步 I/O 操作在完成时都会发送一个事件到事件队列

Node.js 里面的许多对象都会分发事件:一个 net.Server 对象会在每次有新连接时触发一个事件, 一个 fs.readStream 对象会在文件被打开的时候触发一个事件。 所有这些产生事件的对象都是 events.EventEmitter 的实例

NodeJs事件监听触发机制依赖 events 核心模块,

events 模块只提供了一个对象: events.EventEmitter。EventEmitter 的核心就是事件触发与事件监听器功能的封装

我们来看看它的基本用法

const EventEmitter = require(‘events‘).EventEmitter
//实例化EventEmitter类
const event = new EventEmitter()

//error是特殊事件,系统自动触发,如果程序没有设置监听器的话,系统遇到错误会抛出,终止代码运行
event.on(‘error‘, err => {
    console.log(err)
})
//添加事件监听
event.on(‘init‘, () => {
    console.log(`初始化...`)
})

//可以给一个事件设设置多个监听器
event.on(‘data‘, reciveData)
event.on(‘data‘, processData)

//默认最多为一个事件设置10个监听器,可以通过以下方法修改
// event.setMaxListeners(11)

event.on(‘close‘, () => {
    console.log(`结束..`)
})

//移除监听器
event.removeListener(‘data‘,reciveData)

function reciveData(data){
    console.log(`收到数据: ${data}`)
}
function processData(data){
    console.log(`处理数据: ${data}`)
}

event.emit(‘init‘)

setTimeout(()=>{
    //触发事件,如果事件没被监听返回 false
    event.emit(‘data‘,‘ABCDEFG‘)
},1000)
setTimeout(()=>{
    //触发事件
    event.emit(‘close‘)
},2000)

以上代码介绍了eventEmitter的全部用法,可能我们会问这个eventEmitter有什么卵用吗?

大多数时候我们不会直接使用 EventEmitter,而是在对象中继承它

例如我们常用的方法 http.get 方法,该方法传入两个参数

参数1:需要请求url

参数2:http.IncomingMessage实例,而这个对象正是继承 eventEmitter 对象

下面代码大概模拟了了http.get工作原理

const EventEmitter = require(‘events‘).EventEmitter
var myHttp = {}
myHttp.incomingMessage = function(statusCode, headers){
    this.statusCode = statusCode
    this.headers = headers
}
myHttp.incomingMessage.prototype = new EventEmitter()

myHttp.get = function(url, fn){
    //伪代码:获取url内容
    var im = new this.incomingMessage(200,{‘content-type‘: ‘json/application‘})
    fn(im)
    im.emit(‘data‘,`来自${url}的数据`)
}

module.exports = myHttp

使用

const myHttp = require(‘./event.js‘)

myHttp.get(‘http://www.baidu.com‘, res => {
    console.log(res)
    res.on(‘data‘, data => {
        console.log(data)
    })
})

 

EventEmitter:nodeJs事件触发机制

标签:time   正是   使用   app   prot   添加   message   out   请求   

原文地址:https://www.cnblogs.com/xiaoliwang/p/10092343.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!