nodejs 事件驱动
熟悉 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(): 移除事件的所有监听器
- eventNames():返回已注册监听器的事件名数组