typora/daliy_note/9月归档/9.26/nodejs_promise.md
2024-12-12 10:48:55 +08:00

3.8 KiB
Raw Permalink Blame History

在 Node.js 中,Promise 是一种用于处理异步操作的方式。它可以帮助你简化嵌套的回调函数(即“回调地狱”),并提供更加直观的代码结构。在本回答中,我将介绍如何在 Node.js 中使用 Promise,包括创建和使用 Promise,以及如何将回调函数转换为 Promise

基本概念

一个 Promise 有三种状态:

  1. Pending初始状态既没有被解决fulfilled也没有被拒绝rejected
  2. Fulfilled:操作成功完成。
  3. Rejected:操作失败。

创建和使用 Promise

创建 Promise

你可以通过 new Promise 来创建一个 Promise 对象。它接收一个执行函数,该函数有两个参数:resolvereject,分别用于表示操作成功和失败。

const myPromise = new Promise((resolve, reject) => {
  // 异步操作
  setTimeout(() => {
    const success = true; // 你可以根据实际情况设置成功或失败

    if (success) {
      resolve('Operation completed successfully!');
    } else {
      reject('Operation failed!');
    }
  }, 1000);
});

使用 Promise

你可以使用 thencatch 方法来处理 Promise 的结果。

myPromise
  .then(result => {
    console.log(result); // 输出: Operation completed successfully!
  })
  .catch(error => {
    console.error(error); // 输出: Operation failed!
  });

将回调函数转换为 Promise

许多 Node.js 核心模块(如 fs)使用回调函数。你可以使用 util.promisify 将这些回调函数转换为返回 Promise 的函数。

使用 util.promisify

const fs = require('fs');
const util = require('util');

const readFile = util.promisify(fs.readFile);

readFile('example.txt', 'utf8')
  .then(data => {
    console.log(data);
  })
  .catch(error => {
    console.error(error);
  });

手动转换回调函数

你也可以手动将回调函数转换为 Promise

const fs = require('fs');

function readFilePromise(filePath, encoding) {
  return new Promise((resolve, reject) => {
    fs.readFile(filePath, encoding, (err, data) => {
      if (err) {
        reject(err);
      } else {
        resolve(data);
      }
    });
  });
}

readFilePromise('example.txt', 'utf8')
  .then(data => {
    console.log(data);
  })
  .catch(error => {
    console.error(error);
  });

使用 async/await

asyncawait 是基于 Promise 的语法糖,可以让你的异步代码看起来像同步代码。它们使得代码更具可读性和可维护性。

const fs = require('fs').promises; // 使用 fs.promises 提供的基于 Promise 的方法

async function readFileAsync(filePath) {
  try {
    const data = await fs.readFile(filePath, 'utf8');
    console.log(data);
  } catch (error) {
    console.error(error);
  }
}

readFileAsync('example.txt');

链式调用和错误处理

你可以通过链式调用来处理多个异步操作,并在最后使用 catch 处理所有可能的错误。

const fs = require('fs').promises;

fs.readFile('example.txt', 'utf8')
  .then(data => {
    console.log('File content:', data);
    return fs.writeFile('example_copy.txt', data);
  })
  .then(() => {
    console.log('File copied successfully');
  })
  .catch(error => {
    console.error('Error:', error);
  });

总结

  • Promise 为异步操作提供了一种更加直观的处理方式。
  • thencatch 方法用于处理 Promise 的结果和错误。
  • util.promisify 可以将回调函数转换为返回 Promise 的函数。
  • async/await 是基于 Promise 的语法糖,使得异步代码更具可读性。

通过这些方法,你可以在 Node.js 中更高效地处理异步操作。