141 lines
3.8 KiB
Markdown
141 lines
3.8 KiB
Markdown
|
在 Node.js 中，`Promise` 是一种用于处理异步操作的方式。它可以帮助你简化嵌套的回调函数（即“回调地狱”），并提供更加直观的代码结构。在本回答中，我将介绍如何在 Node.js 中使用 `Promise`，包括创建和使用 `Promise`，以及如何将回调函数转换为 `Promise`。
|
|||
|
|
|
|||
|
|
### 基本概念
|
|||
|
|
|
|||
|
|
一个 `Promise` 有三种状态：
|
|||
|
|
|
|||
|
|
1. **Pending**：初始状态，既没有被解决（fulfilled）也没有被拒绝（rejected）。
|
|||
|
|
2. **Fulfilled**：操作成功完成。
|
|||
|
|
3. **Rejected**：操作失败。
|
|||
|
|
|
|||
|
|
### 创建和使用 `Promise`
|
|||
|
|
|
|||
|
|
#### 创建 `Promise`
|
|||
|
|
|
|||
|
|
你可以通过 `new Promise` 来创建一个 `Promise` 对象。它接收一个执行函数，该函数有两个参数：`resolve` 和 `reject`，分别用于表示操作成功和失败。
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
const myPromise = new Promise((resolve, reject) => {
|
|||
|
|
// 异步操作
|
|||
|
|
setTimeout(() => {
|
|||
|
|
const success = true; // 你可以根据实际情况设置成功或失败
|
|||
|
|
|
|||
|
|
if (success) {
|
|||
|
|
resolve('Operation completed successfully!');
|
|||
|
|
} else {
|
|||
|
|
reject('Operation failed!');
|
|||
|
|
}
|
|||
|
|
}, 1000);
|
|||
|
|
});
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
#### 使用 `Promise`
|
|||
|
|
|
|||
|
|
你可以使用 `then` 和 `catch` 方法来处理 `Promise` 的结果。
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
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`
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
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`。
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
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`
|
|||
|
|
|
|||
|
|
`async` 和 `await` 是基于 `Promise` 的语法糖，可以让你的异步代码看起来像同步代码。它们使得代码更具可读性和可维护性。
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
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` 处理所有可能的错误。
|
|||
|
|
|
|||
|
|
```javascript
|
|||
|
|
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` 为异步操作提供了一种更加直观的处理方式。
|
|||
|
|
- `then` 和 `catch` 方法用于处理 `Promise` 的结果和错误。
|
|||
|
|
- `util.promisify` 可以将回调函数转换为返回 `Promise` 的函数。
|
|||
|
|
- `async`/`await` 是基于 `Promise` 的语法糖，使得异步代码更具可读性。
|
|||
|
|
|
|||
|
|
通过这些方法，你可以在 Node.js 中更高效地处理异步操作。
|