Node.js模块中异步请求数据的全局变量更新问题

嘿，我懂你这种纠结——异步操作的回调确实容易让人摸不着头脑，尤其是要在模块启动时一次性拉取数据，还要让后续的API能顺畅用上这些数据。咱们来一步步把这个问题捋清楚，给你一个靠谱的解决方案：

核心思路 #

首先，咱们需要把原来的回调式request调用转换成Promise风格，这样用async/await就能更清晰地处理异步流程；其次，要确保数据只在服务器启动时加载一次，并且在数据加载完成前，API不会返回未准备好的状态；最后，把模块的初始化和API调用分离开，保证全局数据的可靠性。

具体实现代码 #

第一步：重构你的模块（比如命名为dataModule.js）

const request = require('request');
// 如果你想换更现代的库，推荐用axios或node-fetch，后面会提

// 模块级全局变量，用来存储拉取到的JSON数据
let json_data = null;
// 用一个Promise变量来跟踪初始化状态，避免重复请求
let initPromise = null;

// 把request包装成Promise，方便用async/await处理
function requestJson(url) {
  return new Promise((resolve, reject) => {
    request(url, (error, response, body) => {
      // 处理请求错误
      if (error) {
        return reject(new Error(`请求失败：${error.message}`));
      }
      // 处理HTTP状态码错误
      if (response.statusCode !== 200) {
        return reject(new Error(`HTTP错误，状态码：${response.statusCode}`));
      }
      // 解析JSON数据
      try {
        const parsedData = JSON.parse(body);
        resolve(parsedData);
      } catch (parseErr) {
        reject(new Error(`JSON解析失败：${parseErr.message}`));
      }
    });
  });
}

// 初始化函数：仅调用一次拉取数据
async function initData(jsonUrl) {
  // 如果数据已经加载完成，直接返回
  if (json_data) return json_data;
  // 如果正在初始化，返回同一个Promise，避免重复请求
  if (initPromise) return initPromise;

  // 发起请求并存储数据
  initPromise = requestJson(jsonUrl)
    .then(data => {
      json_data = data;
      console.log('外部JSON数据加载成功！');
      return json_data;
    })
    .catch(err => {
      console.error('加载JSON数据失败：', err);
      // 初始化失败的话，可以选择抛出错误终止服务器启动，或者根据需求重试
      throw err;
    });

  return initPromise;
}

// 暴露的API函数1
function apicall1() {
  if (!json_data) {
    throw new Error('数据尚未初始化，请先调用initData！');
  }
  // 根据你的业务逻辑返回对应的数据，比如取json_data的某个字段
  return json_data.someField1;
}

// 暴露的API函数2
function apicall2() {
  if (!json_data) {
    throw new Error('数据尚未初始化，请先调用initData！');
  }
  return json_data.someField2;
}

// 导出模块接口
module.exports = {
  initData,
  apicall1,
  apicall2
};

第二步：在服务器启动文件中使用模块

const express = require('express');
const dataModule = require('./dataModule');
const app = express();

// 服务器启动前先完成数据初始化
async function startServer() {
  try {
    // 替换成你的外部JSON文件URL
    await dataModule.initData('https://example.com/your-external-data.json');
    
    // 定义API路由
    app.get('/api/data1', (req, res) => {
      try {
        const data = dataModule.apicall1();
        res.json({ success: true, data });
      } catch (err) {
        res.status(500).json({ success: false, error: err.message });
      }
    });

    app.get('/api/data2', (req, res) => {
      try {
        const data = dataModule.apicall2();
        res.json({ success: true, data });
      } catch (err) {
        res.status(500).json({ success: false, error: err.message });
      }
    });

    // 启动服务器
    app.listen(3000, () => {
      console.log('服务器运行在 http://localhost:3000');
    });
  } catch (err) {
    console.error('数据初始化失败，无法启动服务器：', err);
    process.exit(1);
  }
}

// 启动服务器
startServer();

额外优化建议 #

• 替换废弃的request库：request已经被官方标记为废弃，推荐使用axios或node-fetch，用axios的话，requestJson可以简化成更简洁的异步函数：

  const axios = require('axios');
  
  async function requestJson(url) {
    const response = await axios.get(url);
    return response.data;
  }
  

• 异步API选项：如果不想让API抛出错误，也可以把apicall1和apicall2改成async函数，内部自动等待初始化完成（不过这样所有API调用都要异步处理）：

  async function apicall1() {
    await initData('https://example.com/your-external-data.json'); // 这里可以把URL配置到模块外部
    return json_data.someField1;
  }
  

这样处理后，你就能确保服务器启动时只拉取一次外部JSON数据，并且所有暴露的API都能安全地使用这份全局数据啦！

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