Node.js 当请求会话更改时,socket.io会话不更新

Node.js 当请求会话更改时,socket.io会话不更新,node.js,sockets,session,express,socket.io,Node.js,Sockets,Session,Express,Socket.io,我目前正在开发一个基本应用程序,其中用户需要进行身份验证(使用passportJS),然后使用socket.io向我的服务器发送消息。以下是nodeJS代码: var express = require('express'); var path = require('path'); var favicon = require('serve-favicon'); var logger = require('morgan'); var cookieParser = require('cookie-p

我目前正在开发一个基本应用程序,其中用户需要进行身份验证(使用passportJS),然后使用socket.io向我的服务器发送消息。以下是nodeJS代码:

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var expressSession = require('express-session');
var mongoose = require('mongoose');
var passport = require('passport');
var LocalStrategy = require('passport-local').Strategy;

var routes = require('./routes/index');
var api = require('./api/index');
var auth = require('./routes/auth');

var session = expressSession({secret: 'mySecret', resave: true, saveUninitialized: true});
var port = normalizePort(process.env.PORT || '3000');

var app = express();
var server = require('http').createServer(app);
var io = require('socket.io')(server);
var sharedsession = require('express-socket.io-session');

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
app.set('port', port);

//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(session);
app.use(passport.initialize());
app.use(passport.session());
app.use(express.static(path.join(__dirname, 'public')));
app.use('/bower_components', express.static(path.join(__dirname, 'bower_components')));

app.use('/', routes);
app.use('/api', api);
app.use('/auth', auth);

// passport config
var User = require('./models/user');
passport.use(new LocalStrategy({
    usernameField: 'email'
}, User.authenticate()));
passport.use(require('./strategies/facebook'));
passport.use(require('./strategies/google'));
passport.serializeUser(function(user, done) {
    done(null, { id: user._id });
});
passport.deserializeUser(function(obj, done) {
    done(null, obj);
});

io.use(sharedsession(session, {
    autoSave:true
}));

io.on('connection', function(socket) {
    console.log('user connected');
    console.log(socket.handshake.session);
    socket.on('message-new', function(data) {
        console.log('receiving message to create');
        console.log(socket.handshake.session);
    });

    socket.on('disconnect', function() {
        console.log('user disconnected');
    });
});

server.listen(port);
如您所见,我使用express-socket.io-session来访问套接字中的会话,它应该与req.session相同。因此,首先,当用户连接到socket.io(但未经过身份验证)时,他的socket.handshake.session等于req.session,因此:

Session {
cookie: 
{ path: '/',
 _expires: null,
 originalMaxAge: null,
 httpOnly: true } }
一旦他进行了身份验证,req.session将变为:

cookie: 
 { path: '/',
 _expires: null,
 originalMaxAge: null,
 httpOnly: true },
passport: { user: { id: 56a13e58150f42fc29b44b7a } } }
但当我从客户端发出一条新消息并显示socket.handshake.session时,它仍然等于

Session {
cookie: 
{ path: '/',
 _expires: null,
 originalMaxAge: null,
 httpOnly: true } }

因此,当req.session被更新时,套接字的会话没有被更新。我怎样才能改变这种行为?我需要能够在我的套接字中知道用户是否已连接…

在事件侦听器的“新消息”中,您可以告诉会话重新加载,文档没有明确说明这一点,但它与
快速会话共享一些相同的方法


在事件侦听器中,您可以告诉会话重新加载

socket.handshake.session.reload(function(err) {
    // this will give you the update session info
}

使用“
express session”
您可以使用与文档中相同的方法

您是否能够解决此问题?我也有同样的问题。我有点用三轮车来让它工作。我第一次看到,即使在我第一次连接套接字时没有使用会话信息完成,但如果我刷新页面,它也会得到满足(因为服务器现在使用已经存在的会话创建套接字)。所以我所做的是,在连接之后,我强制重新加载页面,它工作正常。希望有帮助!非常感谢你!我试了很多次,这是唯一有效的方法。