16

npm install wsExpress が実行されているのと同じポートでWebSocket を使用しています。

作成されて WebSocket にアップグレードされたばかりの HTTP 接続から、関連する「セッション ID」を取得したいと思います。

// start express listening
server.listen(conf.server.port, conf.server.host);

var WebSocketServer = require('ws').Server
  , wss = new WebSocketServer({server: server});

wss.on('connection', function(ws) {
    var sessionID = // how do I get this?
    ws.on('message', function(message) {
        console.log('received: %s', message);
    });
    ws.send('something');
});

これはどのように行うことができますか?

(私は現在、ページで sessionID を送信することで問題を回避していますが、これは醜いです。)

4

2 に答える 2

16
  1. クッキーを解析する
  2. セッションIDを取得する
  3. セッションデータを取得する

    var express = require('express');
    var parseCookie = express.cookieParser();
    var MemoryStore = express.session.MemoryStore;
    
    var store = new MemoryStore();
    
    app.configure(function() {
        app.use(express.session({ store: store, secret: '123456', key: 'sid' }));
    });
    
    wss.on('connection', function(ws) {
        parseCookie(ws.upgradeReq, null, function(err) {
            var sessionID = ws.upgradeReq.cookies['sid'];
            store.get(sessionID, function(err, session) {
                // session
            });
        }); 
    
        ws.on('message', function(message) {
            console.log('received: %s', message);
        });
        ws.send('something');
    });
    
于 2012-07-18T13:45:15.670 に答える
7

これは悪夢でした。ついに、署名付き Cookie を使用して自分で機能するようになりました!

ストアをセットアップします (メモリ ストアの例):

var MemoryStore = express.session.MemoryStore;
store = new MemoryStore();

app / server js ファイルで、次のように parseCookie をグローバルとして公開します (他のモジュールで必要な場合)。

app.use(parseCookie = express.cookieParser('secret'));

次にソケットをセットアップします。

//this method gets called later
var ensureAuthenticatedSocket = function(handshake, callback) {
    cookie = cookieParser(handshake, null, function(err) {
        var sessionID = handshake.signedCookies['sid'];
        store.get(sessionID, function(err, session) {
            callback(err, session);
        });
    });
};
//listen time
io = io.listen(server);
//configure authentication
io.configure(function() {
    io.set('authorization', function(handshake, callback) {
        //call the method with handshake as parameter, wait for callback
        ensureAuthenticatedSocket(handshake, function(err, session) {
            if (!err && session) {
                //no error + found session = wicked!
                callback(null, true);
            } else {
                callback(null, false);
            }
        });
    });
});
...
//more socket code
于 2013-06-01T18:35:03.873 に答える