Node.js中如何操作错误？

try...catch

.catch()

async/await

try...catch

'error'

try...catch

try...catch

try...catch

try...catch

try {
  fs.readFile('/path/to/nonexistent.txt', (err, data) => {
    if (err) throw err; // 这个throw不会被外面的try...catch捕获
  });
} catch (e) {
  console.error("同步捕获失败:", e.message); // 这行代码不会执行
}

fs.readFile

try...catch

.catch()

async/await

try...catch

try...catch

function parseUserInput(jsonString) {
  try {
    const data = JSON.parse(jsonString);
    // ... 对data进行操作
    return data;
  } catch (error) {
    console.error("解析JSON失败:", error.message);
    // 可以选择返回一个默认值，或者重新抛出自定义错误
    throw new Error("无效的输入格式");
  }
}

// 示例调用
try {
  const validData = parseUserInput('{"name": "Alice"}');
  console.log("有效数据:", validData);

  const invalidData = parseUserInput('this is not json');
  console.log("无效数据:", invalidData); // 这行不会执行，因为上面抛出了错误
} catch (e) {
  console.error("外部捕获到错误:", e.message);
}

JSON.parse

try...catch

async/await

async

await

await

try...catch

async function fetchData(url) {
  try {
    const response = await fetch(url); // fetch返回Promise
    if (!response.ok) {
      throw new Error(`HTTP error! status: ${response.status}`);
    }
    const data = await response.json(); // .json()也返回Promise
    return data;
  } catch (error) {
    console.error(`请求或处理数据时出错: ${error.message}`);
    // 这里可以进行错误恢复，比如返回一个空对象，或者重新抛出更具体的错误
    throw new Error("无法获取或解析数据");
  }
}

// 调用示例
(async () => {
  try {
    const user = await fetchData('https://api.example.com/users/1');
    console.log("获取到用户数据:", user);

    const invalidUser = await fetchData('https://api.example.com/nonexistent');
    console.log("这行不会执行:", invalidUser);
  } catch (e) {
    console.error("在调用层捕获到错误:", e.message);
  }
})();

try...catch

try...catch

async/await

.catch()

.catch()

.catch()

function stepOne() {
  return Promise.resolve(1)
    .then(result => {
      console.log('Step 1:', result);
      return result + 1;
    });
}

function stepTwo(value) {
  if (value === 2) {
    return Promise.reject(new Error('Step Two failed intentionally!')); // 故意制造一个拒绝
  }
  return Promise.resolve(value + 1);
}

function stepThree(value) {
  console.log('Step 3:', value);
  return Promise.resolve(value + 1);
}

stepOne()
  .then(stepTwo)
  .then(stepThree)
  .then(finalResult => {
    console.log('All steps completed:', finalResult);
  })
  .catch(error => { // 这个catch会捕获上面任何一个then中发生的错误
    console.error('Promise链中捕获到错误:', error.message);
    // 这里可以进行错误日志记录、用户通知或优雅降级
  });

// 另一个例子，如果一个then中抛出同步错误，也会被catch捕获
Promise.resolve(1)
  .then(value => {
    throw new Error('Sync error in then block!'); // 同步错误也会导致Promise拒绝
  })
  .catch(error => {
    console.error('同步错误被Promise.catch捕获:', error.message);
  });

.finally()

async/await

try...catch

async

try...catch

async

async function processData() {
  try {
    const user = await getUserFromDB(); // 假设这个函数返回一个Promise
    const posts = await getPostsForUser(user.id); // 假设这个函数返回一个Promise
    const analytics = await sendToAnalytics(posts); // 假设这个函数返回一个Promise
    console.log("数据处理完成，分析结果:", analytics);
  } catch (error) {
    console.error("处理数据时发生错误:", error.message);
    // 根据错误类型进行不同的处理
    if (error.message.includes('DB connection')) {
      // 尝试重连或通知运维
    } else {
      // 返回一个错误响应给客户端
    }
    throw error; // 重新抛出，让上层调用者也能感知到错误
  }
}

// 调用processData
(async () => {
  try {
    await processData();
  } catch (e) {
    console.error("顶层捕获到processData的错误:", e.message);
  }
})();

Promise.allSettled()

Promise.all()

Promise.allSettled()

async function fetchMultipleResources(urls) {
  const promises = urls.map(url =>
    fetch(url).then(res => res.json()).catch(error => ({ status: 'rejected', reason: error.message }))
  );
  const results = await Promise.allSettled(promises); // 不会因为某个失败而中断
  results.forEach((result, index) => {
    if (result.status === 'fulfilled') {
      console.log(`URL ${urls[index]} 成功:`, result.value);
    } else {
      console.error(`URL ${urls[index]} 失败:`, result.reason);
    }
  });
  return results;
}

fetchMultipleResources([
  'https://jsonplaceholder.typicode.com/todos/1',
  'https://jsonplaceholder.typicode.com/nonexistent', // 这个会失败
  'https://jsonplaceholder.typicode.com/posts/1'
]);