如何让http.createServer的data与end事件同步执行，输出1 2 3 4？

原代码 #

const server = http.createServer(async (request, response) => {
  
  if (request.method === "POST") {
    var data = "";
    request
      .on("data", async (chunk) => {
        console.log("1");
        data += chunk;

        console.log("2");
        await connection.query({sql query});
        console.log("3");

      
      })
      .on("end", async () => {
        console.log("4");   
      });
  }
}

当前执行结果 #

1
4
2
3

问题 #

当前输出顺序不符合预期，请问如何调整代码，让输出顺序变为1 2 3 4？

解决方案 #

问题根源在于：request的data事件是异步触发的，且end事件不会等待data事件内部的异步操作（这里的await connection.query）完成就会执行，导致4提前输出。

方法一：先读取完整请求数据再处理（推荐）

使用Node.js内置的stream/promises模块读取全部请求数据，之后再执行数据库操作，确保流程按顺序执行：

const { readAll } = require('stream/promises');
const server = http.createServer(async (request, response) => {
  if (request.method === "POST") {
    try {
      // 读取所有请求数据
      const data = await readAll(request);
      console.log("1");
      console.log("2");
      // 替换为你的实际SQL查询语句
      await connection.query('你的SQL查询语句');
      console.log("3");
      console.log("4");
      
      // 返回响应
      response.statusCode = 200;
      response.end("处理完成");
    } catch (error) {
      // 错误处理
      response.statusCode = 500;
      response.end(`处理失败：${error.message}`);
    }
  }
});

方法二：等待所有data事件的异步任务完成（适用于逐块处理场景）

如果必须在data事件中处理每个数据块，可收集所有异步任务，在end事件中等待全部任务完成后再输出4：

const server = http.createServer(async (request, response) => {
  if (request.method === "POST") {
    let data = "";
    const asyncTasks = [];

    request
      .on("data", (chunk) => {
        console.log("1");
        data += chunk;
        // 将每个数据块的异步操作包装为Promise存入数组
        asyncTasks.push((async () => {
          console.log("2");
          await connection.query('你的SQL查询语句');
          console.log("3");
        })());
      })
      .on("end", async () => {
        // 等待所有异步任务执行完毕
        await Promise.all(asyncTasks);
        console.log("4");
        
        // 返回响应
        response.statusCode = 200;
        response.end("处理完成");
      });
  }
});

说明：方法一更符合常规业务逻辑，避免多次触发数据库操作；方法二仅适用于确实需要逐块处理数据的场景，需注意大文件上传时的性能问题。

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