Node.js Express带数据POST请求提前触发request close事件原因及解决

问题原因 #

这个req.close事件立即触发的问题，核心原因是**express.json()中间件的行为**：

• 当POST请求携带JSON数据时，express.json()会自动读取并解析整个请求体，此时请求流的所有数据已被消费。客户端（比如你用的curl）在发送完请求体后，会关闭发送端的连接（仅停止发送数据，仍保持接收响应的通道），这会触发req的close事件。
• 当POST请求不带数据时，请求体为空，express.json()没有数据可读取，请求流处于未结束状态，因此close事件不会被触发。

本质上是close事件被误触发了——它不是客户端主动关闭整个请求连接，而是请求体接收完毕后发送通道关闭导致的。

解决方案 #

要让连接关闭相关的事件仅在客户端实际断开请求时触发，有两种可行方案：

方案1：替换监听事件为req.aborted+res.close

req.aborted是专门监听客户端主动断开请求连接的事件，而res.close可以覆盖响应流层面的连接关闭场景，双重保障避免内存泄漏。修改代码如下：

const express = require("express");
const app = express();

app.use(express.json());

app.post("/stream-post", (req, res) => {
  res.setHeader("Content-Type", "text/plain");
  res.setHeader("Transfer-Encoding", "chunked");

  const intervalId = setInterval(() => {
    res.write("This is a chunk of streaming data.\n");
  }, 1000);

  // 监听客户端主动断开请求
  req.on("aborted", () => {
    clearInterval(intervalId);
    res.end();
  });

  // 监听响应流关闭，覆盖其他连接关闭场景
  res.on("close", () => {
    clearInterval(intervalId);
  });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server listening on port ${PORT}`);
});

方案2：移除express.json()中间件（按需选择）

如果这个POST端点不需要解析请求体，可以直接去掉app.use(express.json())，这样请求流不会被提前消费，req.close事件只会在客户端主动断开时触发：

const express = require("express");
const app = express();

// 移除express.json()中间件
// app.use(express.json());

app.post("/stream-post", (req, res) => {
  res.setHeader("Content-Type", "text/plain");
  res.setHeader("Transfer-Encoding", "chunked");

  const intervalId = setInterval(() => {
    res.write("This is a chunk of streaming data.\n");
  }, 1000);

  req.on("close", () => {
    clearInterval(intervalId);
    res.end();
  });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server listening on port ${PORT}`);
});

如果确实需要解析请求体，可以手动流式读取请求体，避免一次性消费整个流：

app.post("/stream-post", (req, res) => {
  res.setHeader("Content-Type", "text/plain");
  res.setHeader("Transfer-Encoding", "chunked");

  // 手动流式读取请求体
  let body = "";
  req.on("data", (chunk) => {
    body += chunk.toString();
    // 可在这里处理部分请求体数据
  });

  const intervalId = setInterval(() => {
    res.write("This is a chunk of streaming data.\n");
  }, 1000);

  req.on("close", () => {
    clearInterval(intervalId);
    res.end();
  });
});

验证测试 #

用你原来的curl命令测试：

curl -i --no-buffer -X POST http://localhost:3000/stream-post \
  -H "Content-Type: application/json" \
  -d '{
    "this is a test": "value"
  }'

此时服务器会持续发送数据块，直到你手动终止curl（比如按Ctrl+C），对应的断开事件才会触发，停止定时任务。

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