检索与 HTTP 请求相关的 socket.io 连接

Posted 2023-03-10

【中文标题】检索与 HTTP 请求相关的 socket.io 连接

【英文标题】：Retrieving socket.io connection that pertains to HTTP request

【发布时间】：2015-09-08 11:39:43

【问题描述】：

我正在使用带有 Express 的 socket.io。

假设用户点击了规范路由 /，请求被路由到：

app.get('/',function(req,res,next)

   var msg =...;
   socket.emit('channel',msg); //how do I find the right socket object that pertains to this HTTP request?

);

使用 socket.io 找到与此 HTTP 请求相关的套接字连接的最佳方法是什么？

我最好的猜测是在套接字连接被验证时用会话 id 标记套接字，然后稍后用相同的会话 id 检索它们（在上面的函数中）？会话 ID 在 Express 中间件中的请求对象上可用。

我还有这个代码将 socket.io 绑定到 Express 服务器：

var server = http.createServer(app).listen(port);
var io = require('socket.io').listen(server);  //we need to bind socket.io to the http server

还有我自己的socketio模块，我这样做：

var cookie = require("cookie");
var connect = require("connect");

var io = null;
var connectedUsers = ; //hash of sockets with socket.id as key and socket as value

var init = function ($io) 

    if (io === null) 

        io = $io;

        io.use(function (socket, next) 
            var handshakeData = socket.request;

            if (handshakeData.headers.cookie && handshakeData.cookie) 

                handshakeData.cookie = cookie.parse(handshakeData.headers.cookie);

                //handshakeData.sessionID = connect.utils.parseSignedCookie(handshakeData.cookie['express.sid'], 'foo'); //pass session secret at end

                handshakeData.sessionID = cookie.parse(handshakeData.cookie['express.sid'], 'foo'); //pass session secret at end

                if (handshakeData.cookie['express.sid'] == handshakeData.sessionID) 
                    return next('Cookie is invalid.', false);
                

             else 
                return next('No cookie transmitted.', false);
            

            console.log('user with socket.id=', socket.id, 'has authenticated successfully.');
            return next(null, true);

        );


        io.on('connection', function (socket) 
            console.log('a user connected - ', socket.id);

            connectedUsers[socket.id] = socket;

            socket.on('chat message', function (msg) 
                console.log(socket.id, 'says', msg);

                socket.emit('chat message', 'hey baby hey - I am '.concat(socket.id));
            );

            socket.on('disconnect', function () 
                console.log('user disconnected -', socket.id);
                connectedUsers[socket.id] = null;
            );
        );
    
    else if ($io != null) 
        throw new Error('tried to re-init socketio.js by passing new value for io in?? what are you doing.')

    
    else 

    


    return 

        addListener: function()

    


;

module.exports = init;

【参考方案1】：

您必须创建一个数组或 json 对象并在连接到服务器时保存套接字对象。就像这样：

var clients = 
io.on("connection", function(socket)
   socket.on("login", function(data)
       clients[data.user] = socket;
   );
);

然后，当您收到 https 请求时，客户端将用户作为参数传递，然后您查看对象客户端：

clients[user].emit(...)