Node.js中如何将HTTP请求响应存为变量并从异步回调提取返回

你遇到的并非闭包导致的变量无法访问问题——在路由作用域内通过let声明的body变量，在所有内部HTTP事件回调中都可以正常读取、修改。本质问题是异步执行的时序错位：

• 你之前的代码在发起对本地9090端口的内部请求后，没有等待响应数据全部接收完成，就直接执行了res.send()
• 此时内部HTTP接口的响应流还在传输过程中，甚至请求刚发出尚未返回，body变量还是初始的空值
• 你在data事件回调里看到的正确body值，是在res.send已经执行完毕之后才逐块拼接出来的，自然无法影响已经发出去的响应结果

你大概率写的代码结构类似下面这样，问题就出在提前执行的res.send：

app.post('/newreq/:uni', async (req, res) => {
  let body = "";
  // ... 原有数据库查询逻辑
  const internalReq = http.request(/* 接口配置参数 */, (internalRes) => {
    internalRes.on('data', (d) => {
      body += d; // 这里确实能拿到正确的拼接值
    })
  })
  internalReq.end();
  // 这行代码执行时机早于所有data/end事件触发，此时body还是空字符串
  res.send(body);
})

方案1：最小改动适配现有代码逻辑 #

不需要调整原有代码的整体结构，只需要调整响应返回的时机即可：

• 不在路由层提前调用res.send
• 给内部HTTP响应流绑定end事件监听：这个事件触发时，代表所有响应数据已经接收完毕，此时拼接的body就是完整的内部接口响应
• 补充异常处理逻辑，避免内部请求报错时路由永久挂起、无响应返回给前端

调整后的代码结构：

app.post('/newreq/:uni', async (req, res) => {
  let body = "";
  try {
    // 保留原有的数据库查询、conn_id/cred_def_id读取、请求体构造逻辑
    const internalReq = http.request({
      hostname: '127.0.0.1',
      port: 9090,
      path: '/new-request/send-request',
      method: 'POST',
      headers: /* 你原来配置的请求头 */
    }, (internalRes) => {
      // 逐块接收响应数据，拼接进body
      internalRes.on('data', (d) => {
        body += d;
      })
      // 等待所有数据接收完成，再返回给前端
      internalRes.on('end', () => {
        res.send(body);
      })
    })
    // 处理内部请求的异常，避免接口无响应
    internalReq.on('error', (err) => {
      res.status(500).send(`内部服务请求失败：${err.message}`);
    })
    // 发送构造好的请求体
    internalReq.write(/* 你之前构造的请求体内容 */);
    internalReq.end();
  } catch (dbErr) {
    res.status(500).send(`数据库查询失败：${dbErr.message}`);
  }
})

方案2：易维护的Promise封装写法 #

如果不想手动管理事件绑定、时序逻辑，可以把内部HTTP请求封装成Promise对象，配合async/await编写，从根源上避免时序错位问题：

// 封装可复用的内部请求方法
const callInternalService = (options, payload) => {
  return new Promise((resolve, reject) => {
    let resBody = "";
    const req = http.request(options, (res) => {
      res.on('data', (chunk) => resBody += chunk);
      res.on('end', () => resolve(resBody));
    })
    req.on('error', reject);
    req.write(payload);
    req.end();
  })
}

路由里直接通过await获取最终响应，逻辑更清晰：

app.post('/newreq/:uni', async (req, res) => {
  try {
    // 原有数据库查询逻辑保持不变
    // 直接等待内部服务的完整响应
    const internalRespBody = await callInternalService(
      {
        hostname: '127.0.0.1',
        port: 9090,
        path: '/new-request/send-request',
        method: 'POST',
        headers: /* 原有请求头配置 */
      },
      /* 构造好的请求体 */
    );
    // 直接把拿到的完整响应返回给前端
    res.send(internalRespBody);
  } catch (err) {
    res.status(500).send(`请求处理失败：${err.message}`);
  }
})

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