如何在 Express API 中正确调用并返回异步 fetch 数据-js教程-PHP中文网

如何在 Express API 中正确调用并返回异步 fetch 数据

本文详解为何 res.json(getPhones) 不返回实际数据，以及如何正确调用异步函数、统一使用 async/await 或 Promise 链，并避免常见陷阱。

本文详解为何 `res.json(getphones)` 不返回实际数据，以及如何正确调用异步函数、统一使用 `async/await` 或 promise 链，并避免常见陷阱。

在 Express 中暴露异步数据接口时，一个高频错误是：将异步函数本身（而非其执行结果）直接传给 res.json()。你定义的 getPhones 是一个 async 函数，它返回的是一个 Promise，而非解析后的数组数据。因此，若写成：

res.status(200).json(getPhones) // ❌ 错误：传入的是函数引用，不是数据

响应体实际为 {"name":"getPhones","length":0,...}（函数对象的字符串化），而非期望的手机列表 JSON。

✅ 正确做法是：调用该函数并等待其 Promise 解析完成。有两种推荐方式：

方式一：使用 `async/await`（推荐，语义清晰）

export const phonesData = async (req, res) => {
  try {
    const data = await getPhones(); // ✅ 调用并等待结果
    res.status(200).json(data);
  } catch (error) {
    console.error('API failed:', error);
    res.status(500).json({ error: 'Failed to fetch phone data' });
  }
};

同时，请重构 getPhones，避免混用 await 和 .then() —— 这易导致未捕获的 Promise 拒绝或静默失败：

const getPhones = async () => {
  try {
    const response = await fetch(url, requestOptions);
    if (!response.ok) throw new Error(`HTTP ${response.status}`);

    const XMLdata = await response.text();
    const parser = new XMLParser();
    const jObj = parser.parse(XMLdata);

    // 安全访问嵌套属性（建议添加存在性检查）
    const phones = jObj?.['soapenv:Envelope']?.['soapenv:Body']?.['ns:listPhoneResponse']?.return?.phone;

    if (!Array.isArray(phones)) {
      throw new Error('Unexpected XML structure: "phone" array not found');
    }

    console.log('Fetched phones:', phones);
    return phones;
  } catch (error) {
    console.error('getPhones error:', error);
    throw error; // 重新抛出，使上层 catch 可捕获
  }
};

方式二：纯 Promise 链（兼容旧代码风格）

const getPhones = () => {
  return fetch(url, requestOptions)
    .then(response => {
      if (!response.ok) throw new Error(`HTTP ${response.status}`);
      return response.text();
    })
    .then(XMLdata => {
      const parser = new XMLParser();
      const jObj = parser.parse(XMLdata);
      const phones = jObj?.['soapenv:Envelope']?.['soapenv:Body']?.['ns:listPhoneResponse']?.return?.phone;
      if (!Array.isArray(phones)) throw new Error('Invalid phone data format');
      console.log('Fetched phones:', phones);
      return phones;
    })
    .catch(error => {
      console.error('getPhones error:', error);
      throw error;
    });
};

// 对应的路由处理器（无需 async）
export const phonesData = (req, res) => {
  getPhones()
    .then(data => res.status(200).json(data))
    .catch(error => {
      console.error('API error:', error);
      res.status(500).json({ error: 'Internal server error' });
    });
};