同步-异步
Node.js
是单进程单线程应用程序,但是因为 V8 引擎提供的异步执行回调接口,通过这些接口可以处理大量的并发,所以性能非常高。
Node.js 异步编程的直接体现就是回调。
异步编程依托于回调来实现,但不能说使用了回调后程序就异步化了。
回调函数在完成任务后就会被调用,Node 使用了大量的回调函数,Node 所有 API 都支持回调函数。
异步编程使得Node.js在执行代码时就没有阻塞,从而使得Node.js可以处理大量的并发请求。
回调函数一般作为函数的最后一个参数出现:
代码示例
// 引入fs模块
var fs = require('fs')
// 文件读取模块
// 非回调
// 同步加载方法:readFileSync
// 加载input文件
var data = fs.readFileSync('./txt/input.txt')
// data是一个二进制流
console.log(data.toString())
console.log("第一次执行结束")
// 回调
// 异步加载方法:readFileSync
fs.readFile('./txt/input.txt',function(err,data){
if(err) return console.error(err)
console.log(data.toString())
})
console.log("再一次结束")
事件
Node.js 基本上所有的事件机制都是用设计模式中观察者模式实现。
Node.js 有多个内置的事件,我们可以通过引入 events 模块,并通过实例化 EventEmitter 类来绑定和监听事件;
//引入events模块
var events = require("events")
//创建eventsEmitter对象
//events 模块只提供了一个对象: events.EventEmitter。
var eventEmitter = new events.EventEmitter()
//创建事件处理程序
var connectHandler = function connected() {
console.log("连接成功。")
//触发 data_received 事件
eventEmitter.emit("data_received")
}
// 绑定connection事件及connection事件的处理程序
// 该对象支持多个事件监听,即绑定多个事件,依次调用
// 用addListener 可以添加多个事件
eventEmitter.on('connection', connectHandler)
eventEmitter.on('connection', function(arg1,arg2){
console.log("connection事件2",arg1,arg2)
})
eventEmitter.on('data_received', function () {
console.log('数据接收成功。')
})
//触发事件 同时可以传递参数
eventEmitter.emit('connection',"Hello", "Node.js")
console.log("程序执行完毕")
var listener1 = function(){
console.log("监听器 listener1 执行。")
}
var listener2 = function(){
console.log("监听器 listener2 执行。")
}
// 绑定 listener 事件,处理函数为 listener1
eventEmitter.addListener("listener",listener1)
// 绑定 listener 事件,处理函数为 listener2
eventEmitter.on("listener",listener2)
var eventListeners = eventEmitter.listenerCount("listener")
console.log(eventListeners+"个监听器监听连接事件。")
// 处理 listener 事件
eventEmitter.emit("listener")
//移除listener绑定的listener1事件
eventEmitter.removeListener("listener",listener1)
console.log("listener1 不再受监听.")
//触发 listener 事件
eventEmitter.emit("listener")
eventListeners = eventEmitter.listenerCount("listener")
console.log(eventListeners+"个监听器监听连接事件。")
console.log("程序执行完毕。")
执行结果:
连接成功。
数据接收成功。
connection事件2 Hello Node.js
程序执行完毕
2个监听器监听连接事件。
监听器 listener1 执行。
监听器 listener2 执行。
listener1 不再受监听.
监听器 listener2 执行。
1个监听器监听连接事件。
程序执行完毕。