Socket.io轮询传输错误求助：集成Express会话后问题仍存在

核心问题分析 #

你的代码存在两个关键问题导致polling错误：

1. Session中间件挂载顺序错误：先启动HTTP服务器和Socket.io，再挂载Express Session中间件，导致Socket.io的请求完全没经过Session处理，无法共享会话信息。
2. Socket.io未集成Session中间件：默认情况下Socket.io的请求不会走Express的中间件链，需要手动让其处理Session，否则连接一段时间后Session失效，触发polling请求失败。

具体修复步骤 #

1. 调整Session中间件挂载顺序 #

将Session中间件的挂载移到创建HTTP服务器和Socket.io之前，确保所有请求（包括Socket.io的polling请求）都能经过Session处理。

2. 让Socket.io集成Express Session #

使用Socket.io的中间件机制，将Express Session中间件应用到Socket.io的请求上，实现会话共享。

3. （可选）处理跨域Cookie携带 #

如果前端和后端不在同域，需要配置Socket.io的CORS选项，允许携带凭证（Cookie）。

修改后的完整代码示例 #

const http=require("http");
const express=require("express");
const path = require('path');
const bodyparser=require('body-parser');
const database=require('./database')
const session=require("express-session");
const app=express();
const middleware=require("./middleware");

// 1. 先创建并挂载Session中间件
const sessionMiddleware = session({
    cookie: {
        path    : '/',
        httpOnly: false,
        maxAge  : 24*60*60*1000
    },
    secret:"Rohith",//used to authenticate a session
    saveUninitialized:true,//session is created but not modified
    resave:false,
    unset:'destroy'
})
app.use(sessionMiddleware);

app.set("view engine","pug");
app.set("views","views");

app.use(express.static(path.join(__dirname,"public")));

// 导入路由
const loginrouter=require("./routes/login");
const registerrouter=require("./routes/register");
const comment=require("./routes/comment")
const displayposts=require("./routes/displaypost");
const profilerouter=require("./routes/profileroute");
const uploadsrouter=require("./routes/uploads");
const searchrouter=require("./routes/searchpage");
const chatspage=require("./routes/chatspage");
const postrouter=require("./routes/api/posts");
const commentpostsrouter=require("./routes/api/commentposts");
const getprofiledetails=require("./routes/api/users");
const chatsrouter=require("./routes/api/chats");
const messagesrouter=require("./routes/api/messages");

// 挂载路由
app.use("/api/posts",postrouter);
app.use("/api/commentposts",commentpostsrouter);
app.use("/api/messages",messagesrouter);
app.use("/login",loginrouter);
app.use("/register",registerrouter);
app.use("/api/users",getprofiledetails);
app.use("/api/chat",chatsrouter);
app.use("/comment",comment);
app.use("/posts",middleware.requirelogin,displayposts);
app.use("/profile",profilerouter);
app.use("/uploads",uploadsrouter);
app.use("/search",searchrouter);
app.use("/chats",chatspage);

// 2. 创建服务器和Socket.io，并集成Session中间件
const server=app.listen(3003,()=>{console.log("listening")});
const io=require("socket.io")(server, {
    path: '/socket.io',
    // 3. 跨域场景下添加CORS配置，替换为你的前端域名
    cors: {
        origin: "http://localhost:3000",
        credentials: true
    }
});

// 让Socket.io请求经过Session中间件
io.use((socket, next) => {
    sessionMiddleware(socket.request, socket.request.res || {}, next);
});

io.on("connection",(socket)=>{
    // 从Session获取用户信息，替代客户端传参，更安全
    const user = socket.request.session.user;
    if (!user) {
        // 无有效会话则断开连接
        return socket.disconnect();
    }
    console.log("connected", user._id)
    
    socket.join(user._id)
    socket.emit("connected")

    socket.on('disconnect', () => {
        console.log('user disconnected', user._id);
    });

    socket.on("join room",(chatid)=>{
        socket.join(chatid)
    })
    socket.on("typing",roomid=>socket.in(roomid).emit("typing"));
    socket.on("stop typing", roomid => socket.in(roomid).emit("stop typing"));
    socket.on("new message", message => {
        var room=message.chatid;
        if(!room.users)console.log("users are not populated");
        room.users.forEach(userItem=>{
            if(userItem._id===user._id)return;
            socket.in(userItem._id).emit("message received",message)
        })
    });
})

app.get("/post",(req,res,next)=>{
    const payload={
        user:req.session.user,
        userjs:JSON.stringify(req.session.user)
    }
    res.status(200).render("createpost",payload)
})

app.get("/",middleware.requirelogin,(req,res,next)=>{
    const payload={
        title:"app",
        user:req.session.user,
        userjs:JSON.stringify(req.session.user)
    }
    res.status(200).render("home",payload);
});

额外注意事项 #

• 前端连接Socket.io时需要开启withCredentials：

  const socket = io("http://localhost:3003", {
      withCredentials: true
  });
  

• 避免客户端传递用户信息，直接从Session获取能防止伪造用户身份，提升安全性。
• httpOnly: false的Cookie配置存在XSS风险，生产环境建议改为true，同时确保前端通过Socket.io而非直接操作Cookie。

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