Node.js 事件循环

  • 事件循环

    Node.js是一个单线程应用程序,但是它可以通过事件和回调的概念来支持并发。Node.js的每个API都是异步的并且是单线程的,它们使用异步函数调用来维护并发性。Nodejs使用观察者模式。Node线程保持事件循环,每当任务完成时,它就会触发相应的事件,从而发出事件侦听器函数要执行的信号。
  • 事件驱动编程

    Node.js大量使用事件,这也是与其他类似技术相比Node.js相当快的原因之一。Node一旦启动其服务器,便会简单地初始化其变量,声明函数,然后简单地等待事件发生。在事件驱动的应用程序中,通常有一个主循环侦听事件,然后在检测到其中一个事件时触发回调函数。
    尽管事件看起来与回调非常相似,但是不同之处在于,当异步函数返回其结果时将调用回调函数,而事件处理则基于观察者模式。侦听事件的功能充当观察者。每当触发事件时,其侦听器函数就会开始执行。Node.js通过事件模块和EventEmitter类提供了多个内置事件,这些事件用于绑定事件和事件监听器,如下所示:
    
    // 导入模块
    var events = require('events');
    
    // 建立 eventEmitter 对象
    var eventEmitter = new events.EventEmitter();
    
    以下是将事件处理程序与事件绑定的语法-
    
    // 如下绑定事件和事件处理程序
    eventEmitter.on('eventName', eventHandler);
    
    现在运行main.js以查看结果-
    
    // 触发事件
    eventEmitter.emit('eventName');
    
  • 示例

    使用以下代码创建一个名为main.js的js文件-
    
    // 导入 events 模块
    var events = require('events');
    
    // 建立 eventEmitter 对象
    var eventEmitter = new events.EventEmitter();
    
    // 创建事件处理程序,如下所示
    var connectHandler = function connected() {
       console.log('连接成功');
      
       // 触发data_received事件
       eventEmitter.emit('data_received');
    }
    
    // 将连接事件与处理程序绑定
    eventEmitter.on('connection', connectHandler);
     
    // 将data_received事件与匿名函数绑定
    eventEmitter.on('data_received', function() {
       console.log('数据成功接收');
    });
    
    // 触发连接事件
    eventEmitter.emit('connection');
    
    console.log("程序终止");
    
    尝试一下
    
    $ node main.js
    
    应该产生以下结果-
    
    连接成功
    数据成功接收
    程序终止
    
  • Node.js应用程序如何工作?

    在Node应用程序中,任何异步函数都将回调作为最后一个参数,而回调函数将错误作为第一个参数。让我们再次回顾前面的示例。创建一个具有以下内容的名为input.txt的文本文件。
    
    菜鸟教程提供了自学内容
    用简单的方法教编程!
    
    使用以下代码创建一个名为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("程序终止");
    
    这里fs.readFile()是一个异步函数,其目的是读取文件。如果在读取操作期间发生错误,则err对象将包含相应的错误,否则数据将包含文件的内容。读取操作完成后,readFile将err和数据传递给回调函数,最终打印出内容。