0

是否有任何工作示例存储会话并将该会话用于所有打开的窗口以让一个用户只连接到一个房间一次?

这个应用程序将获取 phpsessions 作为 node.js 会话,但我不知道如何只让一个人访问这个聊天应用程序一次

//define what we need
    var express = require('express'),
        app = express(),
        memcache = require("memcache"),
        http = require('http'),
        server = http.createServer(app),
        io = require('socket.io').listen(server),
        co = require("./cookie.js"),
        php = require('phpjs'),
        codein = require("node-codein");


    // answer all request from users and send them back index.html for root access
    app.get('/', function (req, res) {
      res.sendfile(__dirname + '/index.html');
      var cookieManager = new co.cookie(req.headers.cookie);

      //using memcache as our session store
      var client = new memcache.Client(11211, "localhost");
      //connect to memcache client
      client.connect();
      //get our cookie sessions
        user = client.get("sessions/"+cookieManager.get("sec_session_id"), function(error, result){
                var session = JSON.parse(result);
                            //get just username from sessions(sessions store name and family and chat username in this case)
                user = JSON.parse(session.name);
                user = user.username;
                            //use this function to pass our chat username to our function
                storeUsername(user);
        });

    });

    function storeUsername(user){
    // usernames which are currently connected to the chat

    var usernames = {};
    io.sockets.on('connection', function (socket) {
        usernames[socket.id] = socket;
        // when the client emits 'sendchat', this listens and executes
        socket.on('sendchat', function (data) {
            // we tell the client to execute 'updatechat' with 2 parameters
            io.sockets.emit('updatechat', socket.username, data);
        });

        // when the client emits 'adduser', this listens and executes
        socket.on('adduser', function(username){
            // we store the username in the socket session for this client
            socket.username = user;
            // add the client's username to the global list
            // echo to client they've connected
            if(php.in_array(socket.username,usernames)){
                delete usernames[socket.username];
            }else{
                usernames[user] = user;
                console.log('not exist');
            socket.emit('updatechat', 'SERVER', 'you have connected');
            // echo globally (all clients) that a person has connected
            socket.broadcast.emit('updatechat', 'SERVER', username + ' has connected');
            // update the list of users in chat, client-side
            io.sockets.emit('updateusers', usernames);
            }
        });

        // when the user disconnects.. perform this
        socket.on('disconnect', function(){
            // remove the username from global usernames list
            delete usernames[socket.username];
            // update list of users in chat, client-side
            io.sockets.emit('updateusers', usernames);
            // echo globally that this client has left
            socket.broadcast.emit('updatechat', 'SERVER', socket.username + ' has disconnected');
        });
    });
    }
    server.listen(3000);

一切正常,并且定义了发送数据的用户,但是当我在另一个选项卡中访问此站点时,我将再次连接到 socket.io 服务器

4

2 回答 2

1

您的意思是在浏览器选项卡之间共享 websocket 吗?

跨浏览器选项卡共享 websocket?

但是为什么需要共享套接字呢?我为论坛开发了一个 node.js 聊天,我们不关心用户有多少个套接字。我们只有一个包含套接字列表的“用户”对象。我们不在乎套接字是否来自 Firefox,来自 android 应用程序......这不是问题。当我们需要向用户发送信息时,我们将其发送到每个套接字。

于 2013-01-18T20:07:56.343 回答
1

你可以试试这个。它正在使用 express 和 socket.io https://github.com/gravityonmars/Balloons.IO

于 2013-02-14T18:19:21.730 回答