Node.js Cluster模式下Express请求体数据丢失问题求助

核心解决方案 #

1. 调整socket.io-sticky的缓冲区配置 #

如果你的集群依赖socket.io-sticky做请求转发，需增大其默认的readBufferSize参数，确保能容纳大体积请求体的分块数据：

const cluster = require('cluster');
const http = require('http');
const { setupMaster, setupWorker } = require('@socket.io/sticky');
const express = require('express');
const bodyParser = require('body-parser');

if (cluster.isPrimary) {
  const server = http.createServer();
  // 设置足够大的缓冲区，适配大请求体
  setupMaster(server, {
    readBufferSize: 1024 * 1024 // 1MB，可根据实际请求体大小调整
  });
  // 启动Worker进程逻辑...
} else {
  const app = express();
  // 配置body-parser支持大请求体
  app.use(bodyParser.json({ limit: '5mb' }));
  app.use(bodyParser.urlencoded({ extended: true, limit: '5mb' }));
  // 业务路由定义...
  const server = http.createServer(app);
  setupWorker(server);
}

2. 替换集群请求分发方案 #

若socket.io-sticky的问题无法快速解决，可改用其他无缓冲区限制的集群方案：

• 使用Node.js原生Cluster轮询：移除socket.io-sticky依赖，直接用原生Cluster模块的默认轮询分发请求，避免中间转发的缓冲区限制。
• 使用PM2集群模式：通过PM2管理集群，它会自动处理请求分发，无需手动配置转发逻辑，示例配置文件ecosystem.config.js：

module.exports = {
  apps: [{
    name: 'express-cluster-app',
    script: './app.js',
    instances: 'max',
    exec_mode: 'cluster'
  }]
};

启动命令：pm2 start ecosystem.config.js

3. 验证body-parser参数配置 #

确保body-parser的limit参数覆盖你的最大请求体尺寸，避免自身截断数据：

// 示例：支持最大10MB的JSON请求体
app.use(bodyParser.json({ limit: '10mb' }));
// 支持最大10MB的URL编码请求体
app.use(bodyParser.urlencoded({ extended: true, limit: '10mb' }));

问题原因说明 #

该问题仅在Cluster模式下触发，是因为socket.io-sticky默认的读取缓冲区大小有限，无法完整转发大体积的请求体分块（尤其是base64格式的图片，体积比原文件大30%左右）。非Cluster模式下请求直接到达Worker进程，没有中间转发的缓冲区限制，因此不会出现数据截断问题。

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