江湖数字化平台
登录

深入了解Node.js

12002

1、深入 egg.js

  • 生命周期

Egg.js 框架有着丰富的生命周期，包括以下几个阶段：

  1. Config 配置加载阶段： 在这个阶段，Egg 会加载应用程序的配置信息，包括配置文件 config/config.default.js、config/config.${env}.js 和 config/config.${env}.js。

  2. App 应用启动阶段： 在这个阶段，框架会调用 beforeStart 方法，用户可以在这个方法中进行一些应用启动前的初始化工作。

  3. 定时任务启动阶段： Egg.js 内置了定时任务模块，用户可以通过配置文件进行定时任务的设置。在这个阶段，框架会自动启动这些定时任务。

  4. 应用启动完成阶段： 在这个阶段，框架会调用 beforeStart 方法，用户可以在这个方法中进行一些应用启动后的初始化工作。

  5. Worker 工作进程启动阶段： 在这个阶段，框架会调用 beforeStart 方法，用户可以在这个方法中进行一些工作进程启动前的初始化工作。

  6. 应用停止阶段： 在应用停止时，框架会调用 beforeClose 方法，用户可以在这个方法中进行一些应用关闭前的清理工作。

  • 配置

Egg.js 的配置文件是一个 JavaScript 文件，默认情况下，项目目录下的 config 文件夹中会包含一个 config.default.js 文件，这是默认的配置文件。此外，你还可以根据环境（如开发环境、测试环境、生产环境）添加对应的配置文件，例如 config.dev.js、config.test.js、config.prod.js。

配置文件中定义了一些常用的配置项，例如数据库连接信息、中间件配置、定时任务配置等。框架会在启动时加载这些配置，供应用程序使用。

下面是一个简单的 Egg.js 配置文件的示例：

  1. // config/config.default.js
  2. module.exports = {
  3.   // 配置项
  4.   myConfig: 'value',
  6.   // 中间件配置
  7.   middleware: ['middleware1', 'middleware2'],
  9.   // 数据库连接信息
  10.   sequelize: {
  11.     dialect: 'mysql',
  12.     host: 'localhost',
  13.     port: 3306,
  14.     username: 'root',
  15.     password: '123456',
  16.     database: 'test',
  17.   },
  19.   // 定时任务配置
  20.   schedule: {
  21.     interval: '1m', // 每隔 1 分钟执行一次
  22.     type: 'all',
  23.   },
  24. };

在应用程序中，你可以通过 app.config 来获取配置项。例如，获取上述配置中的 myConfig：

  1. // 获取配置项
  2. const myConfig = app.config.myConfig;
  3. console.log(myConfig); // 输出 'value'

2、异步编程与Promise

  • 事件机制

在 JavaScript 中，事件机制是一种用于处理异步操作的机制。它基于观察者模式，通过发布-订阅的方式实现。当某个事件发生时，会通知所有订阅者执行相应的操作。

在 Node.js 中，事件机制是通过 events 模块实现的。这个模块提供了 EventEmitter 类，开发者可以通过继承这个类创建自定义事件。

例如，以下是一个简单的使用事件机制的例子

  1. const EventEmitter = require('events');
  3. // 创建一个事件发射器实例
  4. const emitter = new EventEmitter();
  6. // 订阅事件
  7. emitter.on('customEvent', (data) => {
  8.   console.log('Event occurred with data:', data);
  9. });
  11. // 发布事件
  12. emitter.emit('customEvent', { message: 'Hello, Event!' });

在这个例子中，我们创建了一个 EventEmitter 实例，然后通过 on 方法订阅了名为 customEvent 的事件。当调用 emit 方法发布这个事件时，所有订阅者会执行相应的操作。

  • Promise

Promise 是异步编程的一种解决方案，比传统的解决方案——回调函数和事件——更合理和更强大。它由社区最早提出和实现，ES6 将其写进了语言标准，统一了用法，原生提供了Promise对象。

Promise对象代表一个异步操作，有三种状态：pending（进行中）、fulfilled（已成功）和rejected（已失败）。只有异步操作的结果，可以决定当前是哪一种状态，任何其他操作都无法改变这个状态。这也是Promise这个名字的由来，它的英语意思就是“承诺”，表示其他手段无法改变。
一旦状态改变，就不会再变，任何时候都可以得到这个结果
Promise对象的状态改变，只有两种可能：从pending变为fulfilled和从pending变为rejected。只要这两种情况发生，状态就凝固了，不会再变了，会一直保持这个结果，这时就称为 resolved（已定型）。如果改变已经发生了，你再对Promise对象添加回调函数，也会立即得到这个结果。这与事件（Event）完全不同，事件的特点是，如果你错过了它，再去监听，是得不到结果的。

以下是 Promise 的基本使用示例

  1. // 创建一个 Promise 对象
  2. const promise = new Promise((resolve, reject) => {
  3.   // 异步操作
  4.   setTimeout(() => {
  5.     const success = true; // 模拟异步操作是否成功
  7.     if (success) {
  8.       resolve('Operation succeeded'); // 异步操作成功，调用 resolve
  9.     } else {
  10.       reject('Operation failed'); // 异步操作失败，调用 reject
  11.     }
  12.   }, 2000);
  13. });
  15. // 使用 then 方法处理 Promise 的成功状态
  16. promise.then((result) => {
  17.   console.log('Success:', result);
  18. }).catch((error) => {
  19.   console.error('Error:', error);
  20. });

在这个例子中，Promise 的构造函数接受一个函数作为参数，该函数包含异步操作。在异步操作完成时，可以调用 resolve 方法表示成功，调用 reject 方法表示失败。然后，可以使用 then 方法处理成功状态，使用 catch 方法处理失败状态。

Promise 的优势在于处理异步代码时更加清晰，可以避免回调地狱（Callback Hell）。它提供了链式调用的方式，使代码更加易读和维护。

3、Streams

在Node.js中，Stream（流）是一种非常重要的概念，它可以将数据分成多个块并逐步处理，而不是一次性将数据全部加载到内存中。这样做的好处是可以更快地处理大量数据，减少内存占用等。同时，Node.js中有很多内置的模块可以处理Stream，如fs（文件系统）和http（网络通信）模块等。

  • 应用场景
  1. 读取/写入大量数据

如果数据量特别大，一次性将所有数据放入内存中会使程序崩溃，而Stream可以将数据切分成小块，实现逐步读取或写入，这样就可以高效地处理大量数据。

  1. 网络通信

Node.js中的http、https、Net等模块都支持Stream，使用Stream可以提高网络通信效率，尤其是在处理大量数据时。

  1. 文件处理

Node.js中的fs模块也支持Stream，一些文件操作如文件压缩、文件下载等都可以用Stream实现，减少内存消耗和提高性能。

  1. 数据流处理

Stream还可以用于数据流处理，比如说从一个数据库中读取一个大数据集并逐一将其保存到文件系统中。

  • 用法

Stream是基于事件的，数据被分成一小块一小块的读取和写入，而这些小块被作为事件的形式被传递。举个例子，我们可以通过fs模块中的createReadStream方法来创建一个可读Stream对象，这个可读Stream会从某个文件中读取数据并将其分成块：

  1. const fs = require('fs');
  3. const readStream = fs.createReadStream('bigfile.txt');

接着，我们可以对这个可读Stream对象绑定data事件，监听可读Stream对象的数据，如下所示：

  1. const fs = require('fs');
  3. const readStream = fs.createReadStream('bigfile.txt');
  5. readStream.on('data', (chunk) => {
  6.   console.log(chunk);
  7. });

在上面的代码中，当可读Stream对象读取到数据时，就会触发data事件，这个数据会通过回调函数的参数chunk传递。如果我们要将这个数据进行简单的处理，可以修改回调函数如下：

  1. const fs = require('fs');
  3. const readStream = fs.createReadStream('bigfile.txt');
  5. readStream.on('data', (chunk) => {
  6.   console.log(chunk.toString());
  7. });

在这个例子中，我们将读取到的Buffer对象转换成字符串输出。类似的，在可写Stream对象的write方法中，也可以写入一小块数据。