如何用async函数简化异步逻辑

// 模拟一个异步获取数据的函数
function fetchUserData(userId) {
  console.log(`正在获取用户 ${userId} 的数据...`);
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      if (userId === 123) {
        resolve({ id: userId, name: 'Alice', email: 'alice@example.com' });
      } else {
        reject(new Error(`未找到用户 ${userId}`));
      }
    }, 1000);
  });
}

// 模拟一个异步处理数据的函数
function processUserData(userData) {
  console.log(`正在处理用户 ${userData.name} 的数据...`);
  return new Promise(resolve => {
    setTimeout(() => {
      resolve({ processedId: userData.id, processedName: userData.name.toUpperCase() });
    }, 800);
  });
}

// 使用 async/await 简化异步逻辑
async function getUserAndProcess(userId) {
  try {
    // await 会暂停函数执行，直到 fetchUserData Promise 解决
    const userData = await fetchUserData(userId);
    console.log('获取到原始数据:', userData);

    // 接着，await 会暂停函数执行，直到 processUserData Promise 解决
    const processedResult = await processUserData(userData);
    console.log('处理后的数据:', processedResult);
    return processedResult;
  } catch (error) {
    // 任何 await 抛出的错误都会被捕获
    console.error('操作失败:', error.message);
    // 也可以选择在这里重新抛出错误，让上层调用者处理
    throw error;
  }
}

// 调用示例
console.log('--- 尝试获取并处理用户 123 ---');
getUserAndProcess(123)
  .then(result => console.log('最终成功:', result))
  .catch(err => console.log('调用链捕获到错误:', err.message));

console.log('\n--- 尝试获取并处理用户 456 (会失败) ---');
getUserAndProcess(456)
  .then(result => console.log('最终成功:', result))
  .catch(err => console.log('调用链捕获到错误:', err.message));

// 假设 fetchUser 和 fetchPosts 都可以并行执行
async function getDashboardData(userId) {
  console.log('--- 并行获取数据 ---');
  // 错误示范：串行执行，效率低
  // const user = await fetchUserData(userId);
  // const posts = await fetchUserPosts(userId);

  // 最佳实践：使用 Promise.all 并行执行
  const [user, posts] = await Promise.all([
    fetchUserData(userId),
    fetchUserPosts(userId) // 假设有这个函数
  ]);

  console.log('用户数据:', user);
  console.log('用户文章:', posts);
}

// 模拟 fetchUserPosts
function fetchUserPosts(userId) {
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`Fetched posts for user: ${userId}`);
      resolve([`Post A by ${userId}`, `Post B by ${userId}`]);
    }, 700);
  });
}

getDashboardData(123);

async function riskyOperation() {
  console.log('尝试进行一个可能失败的操作...');
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      const success = Math.random() > 0.5; // 50% 几率失败
      if (success) {
        resolve('操作成功！');
      } else {
        reject(new Error('哎呀，操作失败了！'));
      }
    }, 600);
  });
}

async function executeAndHandle() {
  try {
    const result = await riskyOperation(); // 如果 riskyOperation 拒绝，这里会抛出错误
    console.log('执行结果:', result);
  } catch (error) {
    // 捕获到由 await 抛出的错误
    console.error('捕获到错误:', error.message);
  } finally {
    // 无论成功失败，都会执行
    console.log('操作尝试结束。');
  }
}

console.log('--- 第一次尝试 ---');
executeAndHandle();

setTimeout(() => {
  console.log('\n--- 第二次尝试 ---');
  executeAndHandle();
}, 1500); // 间隔一段时间再试一次