Node.js+Express中封装requestjs外部请求模块及结果存变量方法

嘿，我来帮你搞定这个痛点！你遇到的核心其实是异步代码的封装问题——外部请求是异步操作，没法像同步代码那样直接把结果赋值给变量就返回，得用Promise或者async/await来处理，这样才能在Express里顺畅调用。

下面给你一套具体的实现方案，用requestjs封装成可复用的模块：

第一步：封装外部请求模块 #

先创建一个专门的模块文件，比如externalApi.js，把request的异步逻辑用Promise包裹起来，这样就能用await来等待结果了。

首先确保你已经安装了request：

npm install request

然后编写模块代码：

const request = require('request');

// 封装通用的外部请求函数，返回Promise
function makeExternalRequest(targetUrl, requestOptions = {}) {
  return new Promise((resolve, reject) => {
    // 发起request请求
    request(targetUrl, requestOptions, (error, response, body) => {
      // 处理请求错误（比如网络问题）
      if (error) {
        return reject(new Error(`请求出错：${error.message}`));
      }

      // 检查响应状态码，只处理成功的响应（2xx范围）
      if (response.statusCode >= 200 && response.statusCode < 300) {
        // 尝试解析JSON格式的响应体，非JSON则返回原始内容
        try {
          const parsedResult = JSON.parse(body);
          resolve(parsedResult);
        } catch (parseErr) {
          resolve(body);
        }
      } else {
        // 状态码异常时，返回错误信息
        reject(new Error(`外部服务响应失败：状态码${response.statusCode}，内容：${body}`));
      }
    });
  });
}

// 导出这个函数，供其他模块调用
module.exports = { makeExternalRequest };

你还可以根据业务需求，封装更具体的请求函数，比如专门调用某个第三方API的接口：

// 比如封装获取用户信息的特定请求
async function fetchUserProfile(userId) {
  const apiUrl = `https://third-party-api.com/users/${userId}`;
  const options = {
    headers: {
      'Authorization': 'Bearer YOUR_API_TOKEN',
      'Content-Type': 'application/json'
    }
  };
  return await makeExternalRequest(apiUrl, options);
}

// 别忘了导出这个特定函数
module.exports = { makeExternalRequest, fetchUserProfile };

第二步：在Express路由中调用模块 #

现在你可以在Express的路由里轻松调用这个模块了，用async/await来处理异步结果，代码会非常清晰：

const express = require('express');
const { makeExternalRequest, fetchUserProfile } = require('./externalApi');
const app = express();

// 示例路由：调用通用请求函数
app.get('/api/external-data', async (req, res) => {
  try {
    // 等待外部请求的结果
    const externalData = await makeExternalRequest('https://example.com/api/data', {
      method: 'GET',
      headers: {
        'Accept': 'application/json'
      }
    });
    // 用拿到的结果生成响应
    res.json({
      success: true,
      data: externalData
    });
  } catch (err) {
    // 捕获错误并返回给客户端
    res.status(500).json({
      success: false,
      error: err.message
    });
  }
});

// 示例路由：调用特定的业务封装函数
app.get('/api/user/:id', async (req, res) => {
  try {
    const userId = req.params.id;
    const userProfile = await fetchUserProfile(userId);
    res.json({
      success: true,
      user: userProfile
    });
  } catch (err) {
    res.status(500).json({
      success: false,
      error: err.message
    });
  }
});

app.listen(3000, () => {
  console.log('服务器运行在端口3000');
});

关键注意点 #

• 错误处理：一定要用try/catch包裹await的代码，否则异步错误会导致服务器崩溃。
• 请求配置：可以在封装函数里加入默认的请求配置（比如超时、默认请求头），减少重复代码。
• request的替代方案：如果后续考虑升级，request已经处于维护状态，你可以换成axios或者node-fetch，它们本身就支持Promise，封装起来更简单，但用request的话上面的方案完全可行。

内容的提问来源于stack exchange，提问作者Sylvain Parent