简介

相熟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()

下面的代码输入：

action1action2action3

栈和音讯队列

咱们晓得函数间的调用是通过栈来实现的，下面的例子中，咱们的调用程序也是通过栈来实现的。

但并不是函数中所有的办法都会入栈，还有一些办法会被放入音讯队列。

咱们再举一个例子：

const action2 = () => console.log('action2')const action3 = () => console.log('action3')const action1 = () => {    console.log('action1')    setTimeout(action2, 0)    action3()}action1()

下面的代码运行后果：

action1action3action2

后果不一样了。这是因为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()

输入后果：

action1action3应该在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的博客

欢送关注我的公众号:「程序那些事」最艰深的解读，最粗浅的干货，最简洁的教程，泛滥你不晓得的小技巧等你来发现！