您好，登录后才能下订单哦！
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
这期内容当中小编将会给大家带来有关nodejs中怎么实现事件和事件循环，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
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执行环境来调用的。
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 会在当前函数之后被立即执行。
也就是说先执行栈，再执行作业队列，最后执行消息队列。
先给大家一个定义叫做tick，一个tick就是指一个事件周期。而process.nextTick()就是指在下一个事件循环tick开始之前，调用这个函数：
process.nextTick(() => {
console.log('i am the next tick');
})所以nextTick一定要比消息队列的setTimeout要快。
nodejs提供了一个setImmediate方法，来尽快的执行代码。
setImmediate(() => {
console.log('I am immediate!');
})setImmediate中的函数会在事件循环的下一个迭代中执行。
setImmediate() 和 setTimeout(() => {}, 0)的功能基本上是类似的。它们都会在事件循环的下一个迭代中运行。
如果想要定时执行某些回调函数，则需要用到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)上述就是小编为大家分享的nodejs中怎么实现事件和事件循环了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。