多Node.js+SocketIO实例采用Polling传输时的连接异常问题求助

问题背景 #

我们基于Node.js + SocketIO架构搭建服务，因客户端认证需要在请求头传token，必须采用Polling传输类型。当前用Nginx部署4个Socket应用实例，遇到两个核心问题：

• Polling请求升级WebSocket时触发400 Bad Request，原因是第二次请求路由到了其他Socket服务器，被实例拒绝
• WebSocket连接成功后频繁重连，单实例运行无此问题，仅多实例时出现

根源分析 #

两个问题本质都是会话粘滞（Session Sticky）缺失：Socket.IO的Polling升级流程、后续连接维护都要求同一个客户端的请求始终落到同一后端实例，否则实例间无共享会话上下文，会导致认证失败或连接状态异常。

具体解决方案 #

1. 配置Nginx会话粘滞（核心解决步骤） #

修改Nginx反向代理配置，强制同一会话的请求绑定到固定实例，可选两种策略：

配置示例（ip_hash 策略，适合固定IP场景）

upstream socket_nodes {
    server 127.0.0.1:3000;
    server 127.0.0.1:3001;
    server 127.0.0.1:3002;
    server 127.0.0.1:3003;
    # 基于客户端IP绑定实例，简单直接
    ip_hash;
}

server {
    listen 80;
    server_name yourdomain.com;

    location /socket.io/ {
        proxy_pass http://socket_nodes;
        proxy_http_version 1.1;
        # 必须保留的WebSocket升级头
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        proxy_set_header Host $host;
        # 保留客户端token请求头，确保认证正常
        proxy_set_header Authorization $http_authorization;
        # 延长超时时间，避免Nginx主动断开长连接
        proxy_connect_timeout 7d;
        proxy_send_timeout 7d;
        proxy_read_timeout 7d;
    }
}

备选：Cookie-based粘滞策略（适合动态IP场景）

如果客户端是移动网络这类动态IP环境，替换ip_hash为Cookie绑定：

upstream socket_nodes {
    server 127.0.0.1:3000;
    server 127.0.0.1:3001;
    server 127.0.0.1:3002;
    server 127.0.0.1:3003;
    # 生成专属Cookie绑定实例，有效期1小时
    sticky cookie io_session expires=1h domain=.yourdomain.com path=/;
}

2. 多实例会话上下文共享（可选，增强鲁棒性） #

如果需要跨实例广播消息，或者应对偶尔的会话粘滞失效，可配置Socket.IO的Redis适配器，让所有实例共享连接状态：

步骤1：安装依赖

npm install socket.io-redis redis

步骤2：Node.js代码配置

const { Server } = require('socket.io');
const { createAdapter } = require('socket.io-redis');
const { createClient } = require('redis');

// 初始化Socket.IO，强制Polling传输
const io = new Server({
    transports: ['polling'],
    // 自定义token认证逻辑
    allowRequest: (req, callback) => {
        const token = req.headers.authorization?.split(' ')[1];
        if (validateToken(token)) { // 替换成你的token校验函数
            callback(null, true);
        } else {
            callback(new Error('Invalid token'), false);
        }
    }
});

// 连接Redis，共享会话状态
const pubClient = createClient({ url: 'redis://localhost:6379' });
const subClient = pubClient.duplicate();

Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
    io.adapter(createAdapter({ pubClient, subClient }));
});

io.listen(3000);

3. 客户端连接配置优化 #

确保客户端明确指定Polling传输，并在请求头携带token：

import { io } from 'socket.io-client';

const socket = io('http://yourdomain.com', {
    transports: ['polling'],
    extraHeaders: {
        'Authorization': 'Bearer your-client-token'
    }
});

验证流程 #

1. 重启Nginx和所有Socket.IO实例
2. 测试Polling升级WebSocket流程，检查400错误是否消失
3. 持续观察WebSocket连接状态，确认频繁重连问题解决

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