socket.io 和会话？

Question

我正在使用快速框架。我想从 socket.io 获取会话数据。我尝试使用 client.listener.server.dynamicViewHelpers 数据表达dynamicHelpers，但我无法获取会话数据。有没有一种简单的方法可以做到这一点？请看代码

app.listen(3000);

var io = require('socket.io');
var io = io.listen(app);

io.on('connection', function(client){
    // I want to use session data here
    client.on('message', function(message){
        // or here
    });
    client.on('disconnect', function(){
        // or here
    }); 
});

Answer 1

这不适用于通过 flashsocket 传输的套接字（它不会向服务器发送所需的 cookie），但它可以可靠地适用于其他所有内容。我只是在代码中禁用 flashsocket 传输。

为了使其工作，在express/connect方面，我显式定义了会话存储，以便我可以在套接字内使用它：

MemoryStore = require('connect/middleware/session/memory'),
var session_store = new MemoryStore();
app.configure(function () {
  app.use(express.session({ store: session_store }));
});

然后在我的套接字代码中，我包含连接框架，以便我可以使用它的cookie解析来检索connect.sid来自饼干。然后，我在会话存储中查找具有 connect.sid 的会话，如下所示：

var connect = require('connect');
io.on('connection', function(socket_client) {
  var cookie_string = socket_client.request.headers.cookie;
  var parsed_cookies = connect.utils.parseCookie(cookie_string);
  var connect_sid = parsed_cookies['connect.sid'];
  if (connect_sid) {
    session_store.get(connect_sid, function (error, session) {
      //HOORAY NOW YOU'VE GOT THE SESSION OBJECT!!!!
    });
  }
});

然后，您可以根据需要使用该会话。

Answer 2

Socket.IO-sessions 模块解决方案通过在客户端（脚本）级别公开会话 ID，使应用程序遭受 XSS 攻击。

请检查此解决方案（适用于 Socket.IO >= v0.7）。请参阅此处的文档。

Answer 3

我建议不要完全重新发明轮子。你需要的工具已经是一个npm包。我想这就是你需要的： session.socket.io
我这几天正在使用它，我想它会很有帮助！将express-session链接到socket.io层将会有很多好处！

Answer 4

编辑：在尝试了一些不起作用的模块之后，我实际上已经编写了自己的库来做到这一点。无耻插件：去看看 https://github.com/aviddiviner/Socket.IO-sessions 。为了历史目的，我将在下面留下我的旧帖子：

---

我非常巧妙地完成了这项工作，而不必按照上面的 pr0zac 解决方案绕过 flashsocket 传输。我还在 Socket.IO 中使用express。方法如下。

首先，将会话 ID 传递给视图：

app.get('/', function(req,res){
  res.render('index.ejs', {
    locals: { 
      connect_sid: req.sessionID
      // ...
    }
  });
});

然后在您的视图中，将其与 Socket.IO 客户端链接：

<script>
  var sid = '<%= connect_sid %>';
  var socket = new io.Socket();
  socket.connect();
</script>
<input type="button" value="Ping" onclick="socket.send({sid:sid, msg:'ping'});"/>

然后在服务器端 Socket.IO 侦听器中，选取它并读取/写入会话数据：

var socket = io.listen(app);
socket.on('connection', function(client){
  client.on('message', function(message){
    session_store.get(message.sid, function(error, session){
      session.pings = session.pings + 1 || 1;
      client.send("You have made " + session.pings + " pings.");
      session_store.set(message.sid, session);  // Save the session
    });
  });
});

在我的案例中，我的 session_store 是 Redis，使用 redis-connect 库。

var RedisStore = require('connect-redis');
var session_store = new RedisStore;
// ...
app.use(express.session({ store: session_store }));

希望这对在谷歌搜索时找到这篇文章的人有所帮助（就像我所做的那样；）

Answer 5

请参阅： Socket.IO 身份验证

我建议不要通过 client 获取任何内容.request... 或 client.listener... 因为它不直接附加到 client 对象，并且始终指向最后登录的用户！

Answer 6

对于未来的读者 - 有一种优雅且简单的方法可以使用express-session 访问socket.io 内的会话。来自socket.io文档：

大多数现有的 Express 中间件模块应该与 Socket.IO 兼容，您只需要一点包装函数即可使方法签名匹配：

 const wrap = middleware => (socket, next) => middleware(socket.request, {}, next);

结束请求-响应周期并且不调用 next() 的中间件函数将不起作用。

快速会话示例：

const session = require("express-session");
io.use(wrap(session({ secret: "cats" })));
io.on("connection", (socket) => {
   const session = socket.request.session; // here you get access to the session :)
});
 

Answer 7

查看 Socket.IO-connect

连接 Socket.IO-node 周围的 WebSocket 中间件包装器
https://github.com/bnoguchi/Socket.IO-connect

这将允许您将 Socket.IO 请求推送到 Express/Connect 中间件堆栈，然后使用 Socket.IO 事件处理程序进行处理，从而使您能够访问会话、cookie 等。不过，我不确定它是否适用于所有 Socket.IO 的传输。

Answer 8

我不确定我做得是否正确。
https://github.com/LearnBoost/socket.io/wiki/Authorizing

通过握手数据，您可以访问 cookie。在 cookie 中，您可以获取 connect.sid，它是每个客户端的会话 ID。然后使用 connect.sid 从数据库获取会话数据（我假设您正在使用 RedisStore）

Answer 9

您可以使用 express-socket.io-session 。

与 socket.io 共享基于 cookie 的快速会话中间件。与快递合作> 4.0.0和socket.io> 1.0.0 并且不会向后兼容。

为我工作！

Answer 10

截至 2022 年 2 月，Socket.IO v4 支持此功能：

https: //socket.io/docs/v4/faq/#usage-with-express-session

const express = require('express');
const session = require('express-session');
const app = express();

const server = require('http').createServer(app);
const io = require('socket.io')(server);

const sessionMiddleware = session({ secret: 'keyboard cat', cookie: { maxAge: 60000 }});
// register middleware in Express
app.use(sessionMiddleware);
// register middleware in Socket.IO
io.use((socket, next) => {
  sessionMiddleware(socket.request, {}, next);
  // sessionMiddleware(socket.request, socket.request.res, next); will not work with websocket-only
  // connections, as 'socket.request.res' will be undefined in that case
});

io.on('connection', (socket) => {
  const session = socket.request.session;
  session.connections++;
  session.save();
});

const port = process.env.PORT || 3000;
server.listen(port, () => console.log('server listening on port ' + port));

Answer 11

您可以看看这个： https://github.com/bmeck/session-web-sockets

或者您可以使用：

io.on('connection', function(client) { 
  var session = client.listener.server.viewHelpers; 
  // use session here 
});

希望这有帮助。