如何实现Node.js串行处理客户端请求，防止响应顺序错乱？

问题分析 #

你的Node.js服务器当前默认并发处理所有请求，当客户端每秒发送多个请求时，每个请求转发到第三方TCP服务器的耗时存在差异，会导致先发起的请求后返回，最终响应顺序混乱。要解决这个问题，需要将请求处理串行化——同一时间只处理一个请求，其他请求排队等待。

实现方案 #

通过维护一个请求队列和处理状态标记，让服务器按请求到达的顺序逐一处理，确保响应顺序和请求顺序完全匹配。

修改后的完整代码 #

const http = require('http');

// 存储待处理的请求队列，每个元素包含请求和响应对象
const requestQueue = [];
// 标记当前是否正在处理请求
let isProcessing = false;

// 处理队列中的下一个请求
function processNextRequest() {
  // 如果正在处理或队列为空，直接返回
  if (isProcessing || requestQueue.length === 0) {
    return;
  }

  isProcessing = true;
  // 取出队列头部的请求
  const { req, res } = requestQueue.shift();

  let requestData = '';
  req.on('data', chunk => {
    requestData += chunk;
  });

  req.on('end', async () => {
    try {
      // --------------------------
      // 替换为你的实际业务逻辑：
      // 将HTTP请求转换为TCP消息发送给第三方服务器，获取响应
      // --------------------------
      const thirdPartyResponse = await sendRequestToThirdParty(requestData);

      // 将第三方响应返回给Angular客户端
      res.writeHead(200, { 'Content-Type': 'application/json' });
      res.end(thirdPartyResponse);
    } catch (error) {
      // 处理请求错误
      res.writeHead(500);
      res.end('Failed to process request');
      console.error('Request processing error:', error);
    } finally {
      // 处理完成，重置状态并继续处理下一个请求
      isProcessing = false;
      processNextRequest();
    }
  });

  // 处理请求本身的错误（如连接中断）
  req.on('error', error => {
    console.error('Request error:', error);
    res.writeHead(400);
    res.end('Invalid request');
    isProcessing = false;
    processNextRequest();
  });
}

// 示例：模拟向第三方TCP服务器发送请求的异步函数（需根据实际情况实现）
function sendRequestToThirdParty(data) {
  return new Promise((resolve, reject) => {
    // 这里实现你的TCP客户端逻辑：连接服务器、发送数据、接收响应
    // 以下为模拟代码，替换为真实逻辑
    setTimeout(() => {
      resolve(JSON.stringify({ result: `Processed data: ${data}` }));
    }, Math.random() * 1000); // 模拟随机处理耗时，用于验证顺序正确性
  });
}

// 创建HTTP服务器，所有请求先加入队列
http.createServer((req, res) => {
  requestQueue.push({ req, res });
  // 尝试处理队列中的请求
  processNextRequest();
}).listen(8000, () => {
  console.log('Server running on port 8000');
});

核心逻辑说明 #

• 请求队列：requestQueue存储所有待处理的请求，确保请求严格按到达顺序排队
• 处理状态标记：isProcessing防止同时处理多个请求，保证同一时间只有一个请求在执行
• 串行处理：每次处理完一个请求后，在finally块中重置状态并调用processNextRequest，自动处理队列中的下一个请求
• 错误处理：无论请求成功或失败，都要确保状态被重置，避免队列阻塞导致后续请求无法处理

注意事项 #

这种全局串行处理会降低服务器的并发能力，如果客户端请求量较大，会导致响应延迟增加。如果你的场景允许，可以考虑按客户端标识（如IP、会话ID）单独串行处理，而非全局串行，这样既保证单个客户端的请求顺序，又不影响其他客户端的并发处理。

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