Nodejs 在express + socket.io + session 中如何在socket.io里面获取session 求赐教

Nodejs 在express + socket.io + session 中如何在socket.io里面获取session 求赐教

在使用 Express、Socket.io 和 Session 的项目中，经常需要在 WebSocket 连接中访问用户会话信息。这通常涉及到将 Express 的会话信息传递给 Socket.io。以下是如何实现这一功能的步骤。

环境准备

首先，确保你已经安装了必要的依赖包：

npm install express socket.io express-session

示例代码

1. 初始化 Express 和 Socket.io

   const express = require('express');
   const http = require('http');
   const socketIo = require('socket.io');
   const session = require('express-session');
   
   const app = express();
   const server = http.createServer(app);
   const io = socketIo(server);
   
   // 配置 session
   app.use(session({
     secret: 'your_secret_key',
     resave: false,
     saveUninitialized: true,
     cookie: { secure: false } // 如果使用 HTTPS, 设置为 true
   }));
   

2. 设置一个简单的路由来测试 session

   app.get('/', (req, res) => {
     req.session.username = 'exampleUser';
     res.send('Session set, now open a WebSocket connection.');
   });
   

3. 在 Socket.io 中获取 session

   在这里，我们需要创建一个中间件来获取当前用户的 session 并将其传递给 WebSocket 连接。

   const RedisStore = require('connect-redis')(session);
   
   // 使用 Redis 存储 session (可选)
   app.use(session({
     store: new RedisStore(),
     secret: 'your_secret_key',
     resave: false,
     saveUninitialized: true,
     cookie: { secure: false }
   }));
   
   // 创建一个中间件来获取 session
   function getSessionFromSocket(socket, next) {
     const sessionId = socket.handshake.query.sessionId;
     if (!sessionId) return next(new Error('No session ID provided'));
   
     // 假设你使用 Redis 存储 session
     req.sessionStore.get(sessionId, (err, session) => {
       if (err || !session) return next(err || new Error('Session not found'));
       socket.request.session = session;
       next();
     });
   }
   
   // 将中间件应用到所有连接
   io.use(getSessionFromSocket);
   
   // 监听连接事件
   io.on('connection', (socket) => {
     console.log('A user connected with session:', socket.request.session.username);
     socket.on('disconnect', () => {
       console.log('User disconnected');
     });
   });
   
   server.listen(3000, () => {
     console.log('Server listening on port 3000');
   });
   

4. 客户端发送 session ID

   在客户端，你需要在 WebSocket 连接时传递 session ID：

   let socket = io({
     query: { sessionId: 'your_session_id_here' }
   });
   

通过以上步骤，你可以在 Socket.io 连接中访问 Express 的会话信息。注意，这里的 sessionId 需要在客户端请求时从服务器获取并传递过来。

呵呵，我也同样的问题，几乎同样的代码，求大神。表示写rails的自学node.js很有压力

可以参考 http://blog.cloudfoundry.com/2013/01/24/scaling-real-time-apps-on-cloud-foundry-using-node-js-and-redis/