如何在 express.js 中保存 session 数据并在 socket.io 事件中访问它？

我正在使用 express.js v4、socket.io v1 和基本 express-session 开发一个网络应用程序中间件。

我花了几个小时试图解决这个问题，但 Stack Overflow 上的所有当前答案仅适用于 express v3 和 socket.io v0.9。不幸的是，我不能使用 express.io，因为它只是一个也使用那些旧版本的包装器。

我目前的解决方案完全是黑客攻击:

app.get('/auth', function(req, res) {
    if(verified(req.query)) {
        authed[req.sessionID] = true;
    }
});

io.sockets.on('connection', function(websocket) {
    var cookies = cookie.parse(websocket.handshake.headers.cookie);
    var decrypted = cookieParser.signedCookies(cookies, random);
    var sessionID = decrypted['connect.sid'];

    websocket.on('input', function(input) {
        if(authed[sessionID]) {
            // Do stuff...
        }
    });
});

我将我的“ session 数据”保存在一个对象中，作为基于 session ID 的键/值存储。这对于单进程应用程序来说效果很好，但它确实不是一个好的解决方案。它实际上并没有让我访问 req.session 中保存的任何内容，如果进程结束，我保存的所有数据都将丢失。

最重要的是，我需要加载第 3 方 cookie用于解析来自 socket.io 的 cookie 字符串的包。好像是新版的cookie-parser取消了它从字符串中解析 cookie 的功能。至少，它没有记录在案。

必须有更好的方法!

编辑:最后决定使用express redis，在socket.io中写了一个函数，根据session ID从redis中获取信息。

最佳答案

您可以将 session 存储在 Memcached 或 Redis 中。然后您可以从这些商店中的任何一个获取 session 数据。

memcache 和 redis 包都适用于 nodejs。

另请注意，您可以在 socket.io 中使用中间件进行身份验证。这样您就不必将身份验证逻辑放入连接事件处理程序中。

var authorization = require('./socket/authorization')(app);
io.use(authorization.authorize);

例如这个 memcached auth 东西，在我们的例子中是读取我们的 php 存储的 cookie。

var memcached = require('memcached'),
    cookie = require('cookie),
    debug = require('debug')('socket.io:authorization');

module.exports = function(app) {
    var authorize = function(socket, next) {
        var handshakeData = socket.request;
        if (handshakeData.headers.cookie) {
            handshakeData.cookie = cookie.parse(handshakeData.headers.cookie);
            if (typeof handshakeData.cookie['node'] === 'undefined') {
                next(new Error('No cookie transmitted.'));
            } else {
                var loginEndIndex = handshakeData.cookie['node'].indexOf(',');
                handshakeData.node = handshakeData.cookie['node'].slice(0, loginEndIndex);

                var memcached = new Memcached(app.config.memcached.server, app.config.memcached.options);
                memcached.on('failure', function(details) {
                    debug('Server: %s went down due to %s', details.server, details.messages.join(' '));
                });
                memcached.on('reconnecting', function(details) {
                    debug('Total downtime caused by server %s: %sms', details.server, details.totalDownTime);
                });

                memcached.get(handshakeData.cookie['PHPSESSID'], function(err, result) {
                    if (!err && result !== false) {
                        var pipeIndex = result.indexOf('|'),
                            phpData = result.slice(pipeIndex + 1),
                            obj = php.unserialize(phpData);

                        if (handshakeData.node === obj.userLogin) {
                            debug('coockie-accepted: %s, %s', handshakeData.node, obj.userLogin);
                            next();
                        } else {
                            debug('cookie-revoked; %s, %s', handshakeData.node, obj.userLogin);
                            next(new Error('Cookie is invalid.'));
                        }
                    } else {
                        debug('error: %s', err);
                        next(new Error('Cookie is invalid.'));
                    }
                    memcached.end();
                });
            }
        } else {
            debug('error: No cookie transmitted.');
            next(new Error('No cookie transmitted.'));
        }
    };

    return {
        authorize: authorize
    };
};

关于javascript - 使用 Express.js v4 和 Socket.io v1 的 session ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/25109888/