Node.js 事件循环与异步机制详解

Node.js 事件循环基础

Node.js 采用单进程单线程架构，但借助事件机制与回调函数支持并发处理，从而具备极高的运行性能。

JavaScript 语言本身是单线程且异步的，其共同特征在于事件驱动（event-driven），而驱动这些事件的来源是一个异构的平台。

Node.js 中的每个 API 均为异步设计，并作为独立线程运行。通过异步函数调用，系统能够有效处理并发请求。

Node.js 中几乎所有的事件机制均基于设计模式中的观察者模式（Observer Pattern）来实现。

Node.js 的单线程模型类似于进入一个无限循环（while(true)）的事件循环。只要存在未退出的事件观察者，系统就会持续运行；每个异步事件都会生成一个对应的事件观察者，一旦事件发生，便调用相应的回调函数。

事件驱动模型解析

事件驱动模型

Node.js 采用事件驱动模型。当 Web 服务器接收到请求时，会立即关闭当前连接并进行处理，随后去服务下一个 Web 请求。

当请求处理完成后，结果会被放回处理队列。当该结果到达队列头部时，系统将其返回给用户。

这种模型具有极高的效率和可扩展性，因为 Web 服务器持续接收请求，而不等待任何读写操作完成。这被称为非阻塞式 I/O 或事件驱动 I/O。

在事件驱动模型中，系统会生成一个主循环来监听事件。一旦检测到事件，即触发相应的回调函数。

整个事件驱动流程简洁明了。其原理类似于观察者模式：事件相当于主题（Subject），而所有注册到该事件上的处理函数则相当于观察者（Observer）。

EventEmitter 使用示例

Node.js 提供了多个内置事件。我们可以通过引入 events 模块，并实例化 EventEmitter 类来绑定和监听事件，具体代码如下。

//引入events模块
var events = require('events');
//创建eventEmitter对象
var eventEmitter = new events.EventEmitter();
//创建事件处理程序
var connectHandler = function connected() {
 console.log('连接成功。');
 //触发data_received事件 
 eventEmitter.emit('data_received');
}
//绑定connection事件处理程序
eventEmitter.on('connection', connectHandler);
//使用匿名函数绑定data_received事件
eventEmitter.on('data_received', function(){
 console.log('数据接收成功。');
});
//触发connection事件 
eventEmitter.emit('connection');
console.log("程序执行完毕。"); 

上述代码执行后的输出结果如下：

连接成功。

数据接收成功。

程序执行完毕。

上述输出结果符合预期，通过这种事件驱动模型，我们可以轻松实现异步操作。

例如，在读取文件的同时可以执行其他命令。文件读取完成后，文件内容将作为回调函数的参数返回。这种方式避免了阻塞或等待文件 I/O 操作，从而显著提高了 Node.js 的性能，使其能够处理大量并发请求。

var fs = require("fs");
fs.readFile('input.txt', function (err, data) {
 if (err){
 console.log(err.stack);
 return;
 }
 console.log(data.toString());
});
console.log("程序执行完毕。"); 

上述代码执行后的输出结果如下：

程序执行完毕。

input.txt 文件的内容。

从上述代码可以看出，fs.readFile 可以分发事件。实际上，Node.js 中的许多对象都会分发事件，例如 net.Server 对象在新连接建立时也会分发事件。所有产生事件的对象均为 events.EventEmitter 的实例。

不过，大多数情况下我们不会直接使用 EventEmitter，而是在对象中继承它。包括 fs、net、http 在内的所有支持事件响应的核心模块，都是 EventEmitter 的子类。

这样做的原因主要有两点：

首先，具有特定实体功能的对象实现事件符合语义规范，事件的监听和发射应当是对象的方法。其次，JavaScript 的对象机制基于原型，支持部分多重继承，继承 EventEmitter 不会破坏对象原有的继承关系。

Node.js 项目部署实战

接下来分享一个基础的 Node.js 项目示例。

Node.js 的安装通常有两种方式：自行编译源代码或使用编译好的文件。此处我使用编译好的文件，当前 home 目录下已有刚下载的 node-v4.2.3-linux-x64 版本。

第一步是解压缩文件。

tar xvf node-v4.2.3-linux-x64

第二步是设置链接，目的是在任何路径下都能使用 node 命令。

ln -s /home/node-v4.2.3-linux-x64/bin/node /usr/local/bin/node
ln -s /home/node-v4.2.3-linux-x64/bin/npm /usr/local/bin/npm

第三步，在 home 文件夹下创建一个名为 mynodeproj 的目录，并在其中创建一个名为 server.js 的文件（文件名可自定义）。

var http = require('http');
http.createServer(function (request, response) {
 //发送 HTTP 头部 
 //HTTP 状态值: 200 : OK
 //内容类型: text/plain
 response.writeHead(200, {'Content-Type': 'text/plain'});
 //发送响应数据 "Hello World"
 response.end('Hello World\n');
}).listen(8888);
//终端打印如下信息
console.log('Server running at http://127.0.0.1:8888/'); 

第四步，使用 node 命令执行上述代码。

node server.js

执行上述命令后，命令行将显示 "Server runnint at http://127.0.0.1:8888/"，这表明程序已成功执行。

由于该服务器运行在阿里云环境中，只需在外部浏览器中输入阿里云 IP 地址加上端口号即可访问。