使用 promise 包装回调错误时，核心做法是将传统的 node.js 风格回调函数（error-first callback）封装在 new promise 构造函数中，并在异步操作完成时通过调用 resolve 或 reject 来传递结果或错误。具体实现通常是在回调中判断第一个参数是否为错误对象，若有错则调用 reject(err)，否则调用 resolve(data)。这样可以将基于回调的异步代码转换为基于 promise 的链式调用或 async/await 语法，从而简化错误处理逻辑并避免回调地狱。
如何将 fs.readFile 的回调转换为 Promise
将 fs.readFile 的回调转换为 Promise 的具体做法是创建一个返回 Promise 对象的函数，在该函数内部调用 fs.readFile，并将原始回调包裹在 Promise 的执行器中。当文件读取成功时，Promise 状态变为 fulfilled 并返回数据；当发生错误时，Promise 状态变为 rejected 并抛出错误。这种转换使得后续可以使用 .then() 和 .catch() 来处理结果和异常。
const fs = require('fs');
function readFileAsync(filePath) {
return new Promise((resolve, reject) => {
fs.readFile(filePath, 'utf8', (err, data) => {
if (err) {
reject(err);
} else {
resolve(data);
}
});
});
}
// 使用示例
readFileAsync('./test.txt')
.then(data => console.log('Success:', data))
.catch(err => console.error('Error:', err));
上述代码定义了一个 readFileAsync 函数，它接收文件路径作为参数，并返回一个 Promise。在 Promise 执行器中，我们调用了 fs.readFile，并传入了一个回调函数。如果 err 存在，说明读取失败，我们调用 reject(err) 来拒绝 Promise；如果 err 不存在，说明读取成功，我们调用 resolve(data) 来解析 Promise 并返回文件内容。在使用时，我们可以通过 .then() 捕获成功的数据，或通过 .catch() 捕获发生的错误。
如何统一处理多个异步操作的错误
统一处理多个异步操作的错误可以通过 Promise.all 或 Promise.allSettled 来实现。当使用 Promise.all 时，只要有一个 Promise 被拒绝，整个 Promise 就会立即被拒绝，并且可以在 .catch() 中统一处理所有错误。而 Promise.allSettled 则会等待所有 Promise 都完成，无论成功或失败，然后返回一个包含每个 Promise 结果的数组，允许我们逐个检查每个操作的状态并处理相应的错误。
const fs = require('fs');
function readFileAsync(filePath) {
return new Promise((resolve, reject) => {
fs.readFile(filePath, 'utf8', (err, data) => {
if (err) {
reject(err);
} else {
resolve(data);
}
});
});
}
const files = ['./file1.txt', './file2.txt', './file3.txt'];
Promise.all(files.map(readFileAsync))
.then(results => console.log('All Success:', results))
.catch(err => console.error('One or more failed:', err));
// 或者使用 Promise.allSettled
Promise.allSettled(files.map(readFileAsync))
.then(results => {
results.forEach((result, index) => {
if (result.status === 'fulfilled') {
console.log(`File ${index} succeeded:`, result.value);
} else {
console.error(`File ${index} failed:`, result.reason);
}
});
});
在上述代码中，我们首先定义了 readFileAsync 函数，用于将 fs.readFile 转换为 Promise。然后，我们创建了一个文件路径数组 files，并使用 map 方法将其转换为 Promise 数组。接着，我们分别使用了 Promise.all 和 Promise.allSettled 来处理这些 Promise。Promise.all 会在任何一个 Promise 失败时立即拒绝，并在 .catch() 中捕获错误。而 Promise.allSettled 则会等待所有 Promise 完成，并返回一个结果数组，我们可以遍历该数组来检查每个操作的成功或失败状态，并分别处理。
当回调函数抛出未捕获异常时会发生什么
当回调函数内部抛出未捕获异常时，Promise 的状态会变为 rejected，并且错误会被传递给 .catch() 或 async/await 中的 try...catch 块。这是因为 Promise 执行器中的任何未捕获异常都会自动导致 Promise 被拒绝。因此，在封装回调时，确保回调函数内部的异常能够被正确捕获并传递给 reject 是非常重要的。
const fs = require('fs');
function readFileAsync(filePath) {
return new Promise((resolve, reject) => {
try {
fs.readFile(filePath, 'utf8', (err, data) => {
if (err) {
reject(err);
} else {
resolve(data);
}
});
} catch (e) {
reject(e);
}
});
}
readFileAsync('./nonexistent.txt')
.then(data => console.log('Success:', data))
.catch(err => console.error('Error:', err.message));
在上述代码中，我们在 Promise 执行器中添加了 try...catch 块，以捕获可能抛出的同步异常。如果 fs.readFile 或其回调函数内部抛出异常，catch 块会捕获该异常并调用 reject(e)，从而将错误传递给 Promise 的拒绝处理程序。这样可以确保即使发生未预期的异常，Promise 也能正确地处理错误，而不是导致程序崩溃或未处理的拒绝。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
