Node.js - 事件循环

---

Node.js 是一个单线程应用程序，但它可以通过事件和回调的概念支持并发。Node.js 的每个 API 都是异步且单线程的，它们使用异步函数调用来保持并发性。节点使用观察者模式。节点线程保持一个事件循环，每当任务完成时，它就会触发相应的事件，通知事件侦听器函数执行。

事件驱动编程

Node.js 大量使用事件，这也是 Node.js 与其他类似技术相比速度相当快的原因之一。一旦 Node 启动它的服务器，它就简单地初始化它的变量，声明函数，然后简单地等待事件发生。

在事件驱动的应用程序中，通常有一个主循环来侦听事件，然后在检测到其中一个事件时触发回调函数。

尽管事件看起来与回调非常相似，但不同之处在于，回调函数是在异步函数返回其结果时调用的，而事件处理则采用观察者模式。监听事件的函数充当观察者。每当事件被触发时，它的监听器函数就会开始执行。Node.js 通过事件模块和 EventEmitter 类提供多个内置事件，用于绑定事件和事件侦听器，如下所示 -

// Import events module
var events = require('events');

// Create an eventEmitter object
var eventEmitter = new events.EventEmitter();

以下是将事件处理程序与事件绑定的语法 -

// Bind event and event  handler as follows
eventEmitter.on('eventName', eventHandler);

我们可以通过编程方式触发事件，如下所示 -

// Fire an event 
eventEmitter.emit('eventName');

例子

使用以下代码创建一个名为 main.js 的 js 文件 -

// Import events module
var events = require('events');

// Create an eventEmitter object
var eventEmitter = new events.EventEmitter();

// Create an event handler as follows
var connectHandler = function connected() {
   console.log('connection succesful.');
  
   // Fire the data_received event 
   eventEmitter.emit('data_received');
}

// Bind the connection event with the handler
eventEmitter.on('connection', connectHandler);
 
// Bind the data_received event with the anonymous function
eventEmitter.on('data_received', function() {
   console.log('data received succesfully.');
});

// Fire the connection event 
eventEmitter.emit('connection');

console.log("Program Ended.");

现在让我们尝试运行上面的程序并检查其输出 -

$ node main.js

IT 应产生以下结果 -

connection successful.
data received successfully.
Program Ended.

节点应用程序如何工作？

在节点应用程序中，任何异步函数都接受回调作为最后一个参数，回调函数接受错误作为第一个参数。让我们再次回顾一下前面的例子。创建一个名为 input.txt 的文本文件，其中包含以下内容。

Tutorials Point is giving self learning content
to teach the world in simple and easy way!!!!!

创建一个名为 main.js 的 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("Program Ended");

这里 fs.readFile() 是一个异步函数，其目的是读取文件。如果在读取操作期间发生错误，则err 对象将包含相应的错误，否则 data 将包含文件的内容。readFile在读操作完成后将 err 和 data 传递给回调函数，最终打印内容。

Program Ended
Tutorials Point is giving self learning content
to teach the world in simple and easy way!!!!!