Node.js服务端如何让函数等待Client A返回数据（替代setTimeout）

你的核心问题在于Socket.IO的事件是异步触发的，直接顺序执行代码的话，socketB.emit('sendData')会立刻运行，不会等待Client A返回数据。用setTimeout确实不够灵活，而且容易出现"要么等太久浪费时间，要么等太早拿不到数据"的问题，我们可以用Promise + async/await来实现精准的异步等待，同时还能避免全局变量带来的并发问题。

首先分析你现有代码的隐患 #

你用全局变量storage_data存储Client A返回的数据，这在多客户端并发请求的场景下会出问题：如果有多个Client B同时发起请求，storage_data会被多次覆盖，导致数据混乱。我们需要为每个请求单独处理异步响应，而不是用全局变量共享状态。

解决方案：用Promise包装请求Client A的逻辑 #

我们可以把"向Client A发请求并等待响应"的操作封装成一个Promise，这样就能用await来等待结果，代码结构会更清晰，也更可靠。

步骤1：封装请求Client A的Promise函数 #

// 封装一个向Client A请求数据的函数，返回Promise
function fetchDataFromClientA(socketA, requestPayload) {
  return new Promise((resolve, reject) => {
    // 设置超时保护，避免Promise一直处于pending状态（可选但推荐）
    const timeoutTimer = setTimeout(() => {
      // 超时后移除监听，避免内存泄漏
      socketA.off('getData', handleDataResponse);
      reject(new Error('Request to Client A timed out'));
    }, 5000); // 5秒超时，可根据实际情况调整

    // 定义接收Client A响应的回调函数
    function handleDataResponse(data) {
      // 拿到数据后，清理定时器和监听事件
      clearTimeout(timeoutTimer);
      socketA.off('getData', handleDataResponse);
      // 将数据返回给调用者
      resolve(data);
    }

    // 监听Client A的响应事件
    socketA.on('getData', handleDataResponse);
    // 向Client A发送请求
    socketA.emit('getData', JSON.stringify(requestPayload));
  });
}

步骤2：在处理Client B请求时使用async/await #

当Client B发起请求时，我们用异步函数来等待Client A的响应，拿到数据后再转发给Client B：

// 假设这是Client B触发的请求事件，比如Client B发送了'getClientAData'事件
socketB.on('getClientAData', async (clientBRequest) => {
  try {
    // 这里传入你要发给Client A的请求参数（比如你的json变量）
    const clientAData = await fetchDataFromClientA(socketA, clientBRequest);
    // 拿到数据后，转发给Client B
    socketB.emit('sendData', clientAData);
  } catch (error) {
    // 处理错误情况（比如超时、Client A未响应）
    socketB.emit('requestFailed', error.message);
    console.error('Error fetching data from Client A:', error);
  }
});

为什么这个方案更好？ #

1. 精准等待：只有当Client A返回数据时，代码才会继续执行，完全不需要猜测等待时间。
2. 避免并发问题：每个Client B的请求都会创建独立的Promise和监听回调，不会互相干扰。
3. 错误处理：可以通过try/catch优雅处理超时、Client A未响应等异常情况。
4. 代码可读性：用async/await让异步代码看起来像同步代码，逻辑更清晰。

额外注意事项 #

• 确保socketA是服务端与Client A的有效连接实例，避免使用未初始化或已断开的socket。
• 如果Client A可能发送多次响应，你需要根据业务逻辑调整监听方式（比如用一次性监听once而不是on，不过上面的代码已经用off手动移除了监听，效果和once类似）。

内容的提问来源于stack exchange，提问作者Nam Vi Nguyen