我目前正在尝试为我的 node.js 应用程序设置一个基本的身份验证系统。现在我正在使用 express (3.0.0rc5)、passport (0.1.12) 和 socket.io (0.9.10) 以及 Mongoose 作为会话数据的存储。我也一直在玩
everyauth现状：
通过护照（facebook 策略）的身份验证成功，重定向后客户端上设置了一个
session.sidsocket.iosocket.handshake.headers.cookie如果我正确理解了护照的概念，那么在成功调用
authentication passport.serializeUserpassport.serializeUser(function(user, done) {
done(null, user.email);
});
现在我只能使用 socket.io 事件中的 cookie 信息从会话中提取电子邮件地址。
var connect = require('connect'),
parseSignedCookie = connect.utils.parseSignedCookie,
cookie = require('express/node_modules/cookie');
io.on('connection', function(socket) {
if(socket.handshake.headers.cookie) {
var cookie = cookie.parse(socket.handshake.headers.cookie);
var sessionID = parseSignedCookie(cookie['connect.sid'], 'secret');
}
});
passport.deserializeUser(function(id, done) {
// so, what is supposed to be done here?
});
所以如果我没记错的话，现在的任务是使用
deserializeUser我该怎么做？非常感谢任何指点。
这里是一个使用 Socket.IO 1.0 和 Express 4.0 的解决方案。它在精神上与帕特里克的回答相似。诀窍在于，由于 Socket.IO 1.0 有一个新的中间件 API，我们可以包装 Express 的中间件并将其放入 Socket.IO 管道，而无需深入研究会话存储的低级实现。
// Set up the Session middleware using a MongoDB session store
expressSession = require("express-session");
var sessionMiddleware = expressSession({
name: "COOKIE_NAME_HERE",
secret: "COOKIE_SECRET_HERE",
store: new (require("connect-mongo")(expressSession))({
url: "mongodb://localhost/DATABASE_NAME_HERE"
})
});
// Set up the Express server
var app = require("express")()
.use(sessionMiddleware)
.use(passport.initialize())
.use(passport.session())
// ... more middleware ...
.listen(8000);
// Set up the Socket.IO server
var io = require("socket.io")(app)
.use(function(socket, next){
// Wrap the express middleware
sessionMiddleware(socket.request, {}, next);
})
.on("connection", function(socket){
var userId = socket.request.session.passport.user;
console.log("Your User ID is", userId);
});
变量 sessionMiddleware 是一个旨在直接适合 Express 管道的函数。它只需要三个参数：请求对象、响应对象和回调。
Socket.IO 的管道期望它的中间件只接受两个参数，但是：套接字对象（在 socket.request 包含请求对象）和回调。幸运的是，sessionMiddleware 不需要响应对象来从存储中读取会话，因此我们只需将一个空对象作为第二个参数传递给它。
请注意，下面的一些评论观察到此代码将会话呈现为只读。这是我们因没有使用 Socket.IO 的适当 response 对象而失去的功能。
在上面的示例中，我使用了 MongoDB 会话存储 (connect-mongo)。您可以根据自己的喜好使用任何会话存储。有关会话存储列表，请参阅Connect wiki。
我开始工作了。我必须要做的是访问 sessionStore。这是代码，以防其他人偶然发现这个特定问题：
// # app.js
var express = require('express'),
routes = require('./routes'),
http = require('http'),
path = require('path'),
app = express(),
passport = require('passport'),
SessionMongoose = require("session-mongoose"),
mongooseSessionStore = new SessionMongoose({
url: "mongodb://localhost/login",
interval: 120000
});
var config = require('game/config.js'), // holds my whole server configuration
server = require('game/lib/server.js');
// save sessionStore to config for later access
config.setSessionStore(mongooseSessionStore);
// configure express to use passport and mongooseSessionStore
app.configure(function(){
app.set('port', config.port);
app.set('env', config.environment);
app.set('dbPrefix', config.dbPrefix);
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.favicon());
app.use(express.bodyParser());
app.use(express.cookieParser());
app.use(express.session({secret : 'totallysecret', store : mongooseSessionStore })),
app.use(express.methodOverride());
app.use(passport.initialize());
app.use(passport.session());
app.use(app.router);
app.use(express['static'](path.join(__dirname, 'public')));
});
app.get('/', routes.index);
app.get('/auth/facebook', passport.authenticate('facebook', { scope: 'email' }));
app.get('/auth/facebook/callback',
passport.authenticate('facebook', { successRedirect: '/',
failureRedirect: '/' }));
// #### Init httpserver
var httpServer = http.createServer(app);
httpServer.listen(app.get('port'));
// #### Server startup
server.init(httpServer);
我的序列化函数看起来很简单：
passport.serializeUser(function(user, done) {
// saves user.email to session.passport.user
done(null, user.email);
});
passport.deserializeUser(function(obj, done) {
done(null, obj);
});
最后是 socket.io 实现：
var util = require('util'),
connect = require('connect'),
parseSignedCookie = connect.utils.parseSignedCookie,
cookie = require('express/node_modules/cookie'),
io = require('socket.io').listen(httpServer);
var config = require('../config.js');
io.configure(function () {
io.set('authorization', function (data, callback) {
if(data.headers.cookie) {
// save parsedSessionId to handshakeData
data.cookie = cookie.parse(data.headers.cookie);
data.sessionId = parseSignedCookie(data.cookie['connect.sid'], 'totallysecret');
}
callback(null, true);
});
io.on('connection', function(socket) {
// reference to my initialized sessionStore in app.js
var sessionStore = config.sessionStore;
var sessionId = socket.handshake.sessionId;
sessionStore.get(sessionId, function(err, session) {
if( ! err) {
if(session.passport.user) {
console.log('This is the users email address %s', session.passport.user);
}
});
});
});
使用我有权访问的会话猫鼬模块：
sessionStore.get(sessionId, callback)
sessionStore.set(sessionId, data, callback)
sessionStore.destroy(sessionId, callback)
sessionStore.all(callback) // returns all available sessions
sessionStore.clear(callback) // deletes all session data
sessionStore.length(callback) // returns number of sessions in the
您可以使用express-socket.io-session。您可以使用
socket.handshake.session.passport.user注意：适用于 express > 4.0.0 和 socket.io > 1.0.0，不会向后兼容