如何与Socket.IO1.x和Express 4.x共享会话？

Question

如何与Socket.IO1.x和Express 4.x共享会话？如何与Socket.io 1.0和Express 4.x共享会话？我使用Redis商店，但我相信这不重要。我知道我必须使用中间件来查看cookie和获取会话，但不知道如何使用。我找了找，却找不到工作。    var RedisStore = connectRedis(expressSession);     var session = expressSession({         store: new RedisStore({             client: redisClient        }),         secret: mysecret,         saveUninitialized: true,         resave: true     });     app.use(session);     io.use(function(socket, next) {         var handshake = socket.handshake;         if (handshake.headers.cookie) {             var str = handshake.headers.cookie;             next();         } else {             next(new Error('Missing Cookies'));         }     });

Answer 1

就在一个半月前，我处理了同样的问题，后来写了一篇广泛的文章。博客帖子在这个问题上，它与一个充分发挥作用的问题结合在一起演示应用程序托管在GitHub上。解决方案依赖于特快会议, cookie解析器和连红节点模块来连接所有的东西。它允许您访问和修改来自REST和Socket上下文的会话，这是非常有用的。

中间件设置是两个关键部分：

app.use(cookieParser(config.sessionSecret));app.use(session({
    store: redisStore,
    key: config.sessionCookieKey,
    secret: config.sessionSecret,
    resave: true,
    saveUninitialized: true}));

.和SocketIO服务器设置：

ioServer.use(function (socket, next) {
    var parseCookie = cookieParser(config.sessionSecret);
    var handshake = socket.request;

    parseCookie(handshake, null, function (err, data) {
        sessionService.get(handshake, function (err, session) {
            if (err)
                next(new Error(err.message));
            if (!session)
                next(new Error("Not authorized"));

            handshake.session = session;
            next();
        });
    });});

它们与我创建的一个简单的sessionService模块一起使用，它允许您对会话执行一些基本操作，代码如下所示：

var config = require('../config');var redisClient = null;var redisStore = null;var self = module.exports = {
    initializeRedis: function (client, store) {
        redisClient = client;
        redisStore = store;
    },
    getSessionId: function (handshake) {
        return handshake.signedCookies[config.sessionCookieKey];
    },
    get: function (handshake, callback) {
        var sessionId = self.getSessionId(handshake);

        self.getSessionBySessionID(sessionId, function (err, session) {
            if (err) callback(err);
            if (callback != undefined)
                callback(null, session);
        });
    },
    getSessionBySessionID: function (sessionId, callback) {
        redisStore.load(sessionId, function (err, session) {
            if (err) callback(err);
            if (callback != undefined)
                callback(null, session);
        });
    },
    getUserName: function (handshake, callback) {
        self.get(handshake, function (err, session) {
            if (err) callback(err);
            if (session)
                callback(null, session.userName);
            else
                callback(null);
        });
    },
    updateSession: function (session, callback) {
        try {
            session.reload(function () {
                session.touch().save();
                callback(null, session);
            });
        }
        catch (err) {
            callback(err);
        }
    },
    setSessionProperty: function (session, propertyName, propertyValue, callback) {
        session[propertyName] = propertyValue;
        self.updateSession(session, callback);
    }};

因为整个过程中有更多的代码(比如初始化模块，在客户机和服务器端使用套接字和REST调用)，所以我不会在这里粘贴所有的代码，您可以在GitHub上查看它，您可以使用它做任何事。