Node.js处理无限长HTTP请求的响应异常问题排查

核心原因 #

Node.js 的http.IncomingMessage（请求流）初始处于暂停模式：

• 直接调用req.pause()时，流本来就是暂停状态，这个调用没有实际效果。此时客户端持续发送的分块数据会填满服务器的TCP接收缓冲区，触发TCP流量控制，客户端暂停发送但保持连接。服务器的响应数据因TCP缓冲区被请求数据占据，无法及时传递给客户端，导致客户端收不到响应。
• 当监听data事件时，流会自动切换到流动模式，开始读取请求体数据。此时调用req.pause()会停止流的读取，但服务器已经接收了部分请求数据，TCP滑动窗口被更新，客户端能收到ACK，服务器的响应可顺利通过TCP连接发送，客户端因此能收到响应。另外，Node.js的HTTP模块在发送响应后，会自动处理剩余的请求体（即使流被暂停），避免缓冲区堆积影响响应传输。

可行解决方案 #

方式1：手动启动流后立即暂停 #

先调用req.resume()切换到流动模式，再暂停流：

const http = require('http');

const server = http.createServer((req, res) => {
  console.log('req received');

  req.resume(); // 启动流切换到流动模式
  req.pause();  // 立即暂停

  res.statusCode = 200;
  res.end();
});

server.listen(3000, () => console.log('ready'));

方式2：直接销毁请求流（推荐） #

如果完全不需要请求体数据，直接销毁流可快速释放资源并发送响应：

const http = require('http');

const server = http.createServer((req, res) => {
  console.log('req received');

  req.destroy(); // 销毁请求流，忽略剩余数据

  res.statusCode = 200;
  res.end();
});

server.listen(3000, () => console.log('ready'));

方式3：监听data事件并暂停 #

就是你发现的有效方式，通过监听data事件触发流模式切换后暂停：

const http = require('http');

const server = http.createServer((req, res) => {
  console.log('req received');

  req.on('data', () => req.pause());

  res.statusCode = 200;
  res.end();
});

server.listen(3000, () => console.log('ready'));

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