简介
相熟 javascript 的敌人应该都应用过事件,比方鼠标的挪动,鼠标的点击,键盘的输出等等。咱们在 javascript 中监听这些事件,从而触发相应的解决。
同样的 nodejs 中也有事件,并且还有一个专门的 events 模块来进行专门的解决。
同时事件和事件循环也是 nodejs 构建异步 IO 的十分重要的概念。
明天咱们来具体理解一下。
事件
nodejs 为事件提供了一个专门的模块:lib/events.js。
还记得咱们在讲应用 nodejs 构建 web 服务器吗?
const server = http.createServer((req, res) => {
res.statusCode = 200
res.setHeader('Content-Type', 'text/plain')
res.end('welcome to www.flydean.com\n')
})
这里,每个申请都会触发 request 事件。
nodejs 的外围 API 是基于异步事件驱动来进行架构的,所以 nodejs 中有十分多的事件。
比方:net.Server 会在每次有新连贯时触发事件,fs.ReadStream 会在关上文件时触发事件,stream 会在数据可读时触发事件。
咱们看一下怎么来构建一个 nodejs 的事件:
const EventEmitter = require('events')
const eventEmitter = new EventEmitter()
events 罕用的办法有两个,别离是 on 和 emit。
on 用来监听事件,emit 用来触发事件。
eventEmitter.on('fire', () => {console.log('停火')
})
eventEmitter.emit('fire')
emit 还能够带参数,咱们看下一个参数的状况:
eventEmitter.on('fire', who => {console.log(` 停火 ${who}`)
})
eventEmitter.emit('fire', '美帝')
再看看两个参数的状况:
eventEmitter.on('fire', (who, when) => {console.log(` 停火 ${who} ${when}`)
})
eventEmitter.emit('fire', '川建国','now')
默认状况下,EventEmitter 以注册的程序同步地调用所有监听器。这样能够确保事件的正确排序,并有助于防止竞态条件和逻辑谬误。
如果须要异步执行,则能够应用 setImmediate() 或者 process.nextTick() 来切换到异步执行模式。
eventEmitter.on('fire', (who, when) => {setImmediate(() => {console.log(` 停火 ${who} ${when}`);
});
})
eventEmitter.emit('fire', '川建国','now')
除此之外,events 还反对其余几个办法:
once(): 增加单次监听器
removeListener() / off(): 从事件中移除事件监听器
removeAllListeners(): 移除事件的所有监听器
事件循环
咱们晓得 nodejs 的代码是运行在单线程环境中的,每次只会去解决一件事件。
这一种解决形式,防止了多线程环境的数据同步的问题,大大的晋升了解决效率。
所谓事件循环,就是指处理器在一个程序周期中,解决完这个周期的事件之后,会进入下一个事件周期,解决下一个事件周期的事件,这样一个周期一个周期的循环。
事件循环的阻塞
如果咱们在事件处理过程中,某个事件的解决产生了阻塞,则会影响其余的事件的执行,所以咱们能够看到在 JS 中,简直所有的 IO 都是非阻塞的。这也是为什么 javascript 中有这么多回调的起因。
事件循环举例
咱们看一个简略的事件循环的例子:
const action2 = () => console.log('action2')
const action3 = () => console.log('action3')
const action1 = () => {console.log('action1')
action2()
action3()}
action1()
下面的代码输入:
action1
action2
action3
栈和音讯队列
咱们晓得函数间的调用是通过栈来实现的,下面的例子中,咱们的调用程序也是通过栈来实现的。
但并不是函数中所有的办法都会入栈,还有一些办法会被放入音讯队列。
咱们再举一个例子:
const action2 = () => console.log('action2')
const action3 = () => console.log('action3')
const action1 = () => {console.log('action1')
setTimeout(action2, 0)
action3()}
action1()
下面的代码运行后果:
action1
action3
action2
后果不一样了。这是因为 settimeout 触发了定时器,当定时器到期的时候,回调函数会被放入音讯队列中期待被解决,而不是放入栈中。
事件循环会优先解决栈中的事件,只有栈中没有任何数据的时候,才会去转而生产音讯队列中的事件。
尽管下面例子中 setTimeout 的 timeout 工夫是 0,然而还是要等到 action3 执行结束能力执行。
留神,setTimeout 中的 timeout 并不是在以后线程进行期待的,它是由浏览器或者其余 JS 执行环境来调用的。
作业队列和 promise
ES6 中的 Promise 引入了作业队列的概念,应用作业队列将会尽快地执行异步函数的后果,而不是放在调用堆栈的开端。
举个例子:
const action2 = () => console.log('action2')
const action3 = () => console.log('action3')
const action1 = () => {console.log('action1')
setTimeout(action2, 0)
new Promise((resolve, reject) =>
resolve('应该在 action3 之后、action2 之前')
).then(resolve => console.log(resolve))
action3()}
action1()
输入后果:
action1
action3
应该在 action3 之后、action2 之前
action2
这是因为,在以后函数完结之前 resolve 的 Promise 会在以后函数之后被立刻执行。
也就是说先执行栈,再执行作业队列,最初执行音讯队列。
process.nextTick()
先给大家一个定义叫做 tick,一个 tick 就是指一个事件周期。而 process.nextTick() 就是指在下一个事件循环 tick 开始之前,调用这个函数:
process.nextTick(() => {console.log('i am the next tick');
})
所以 nextTick 肯定要比音讯队列的 setTimeout 要快。
setImmediate()
nodejs 提供了一个 setImmediate 办法,来尽快的执行代码。
setImmediate(() => {console.log('I am immediate!');
})
setImmediate 中的函数会在事件循环的下一个迭代中执行。
setImmediate() 和 setTimeout(() => {}, 0) 的性能基本上是相似的。它们都会在事件循环的下一个迭代中运行。
setInterval()
如果想要定时执行某些回调函数,则须要用到 setInterval。
setInterval(() => {console.log('每隔 2 秒执行一次');
}, 2000)
要革除下面的定时工作,能够应用 clearInterval:
const id = setInterval(() => {console.log('每隔 2 秒执行一次');
}, 2000)
clearInterval(id)
留神,setInterval 是每隔 n 毫秒启动一个函数,不论该函数是否执行结束。
如果一个函数执行工夫太长,就会导致下一个函数同时执行的状况,怎么解决这个问题呢?
咱们能够思考在回调函数外部再次调用 setTimeout,这样造成递归的 setTimeout 调用:
const myFunction = () => {console.log('做完后,隔 2s 再次执行!');
setTimeout(myFunction, 2000)
}
setTimeout(myFunction, 2000)
本文作者:flydean 程序那些事
本文链接:http://www.flydean.com/nodejs-event/
本文起源:flydean 的博客
欢送关注我的公众号:「程序那些事」最艰深的解读,最粗浅的干货,最简洁的教程,泛滥你不晓得的小技巧等你来发现!