2012-01-03 40 views
1

我正在实施一个node.js服务器,它使用socket.io(版本:0.8.7)管理用户之间的双向连接。我使用一个存储尚未有聊天伙伴的用户的数组。当用户请求新的合作伙伴时,应用程序将挑选该阵列中的用户,然后检查用户是否仍然连接。这是我的问题:如何获取用户的套接字客户端?

即使用户仍然连接,我无法为用户获取套接字客户端。下面是我的代码片段:

// An array of users that do not have a chat partner 
var soloUsers = []; 

var io = sio.listen(app); 

io.sockets.on('connection', function (socket) { 


    socket.on('sessionStart', function (message) 
    {  
     // Parse the incoming event 
     switch (message.event) { 

      // User requested initialization data 
      case 'initial': 
       ... 

     // User requested next partner 
     case 'next': 

     // Create a "user" data object for me 
     var me = { 
      sessionId: message.data.sessionId, 
      clientId: socket.sessionid 
     }; 

     var partner; 
     var partnerClient; 

     // Look for a user to partner with in the list of solo users 
     for (var i = 0; i < soloUsers.length; i++) 
     { 
      var tmpUser = soloUsers[i]; 

      // Make sure our last partner is not our new partner 
      if (socket.partner != tmpUser) 
      { 
       // Get the socket client for this user 
       partnerClient = io.sockets.clientsIndex[tmpUser.clientId]; 

       // Remove the partner we found from the list of solo users 
       soloUsers.splice(i, 1); 

       // If the user we found exists... 
       if (partnerClient) 
       { 
        // Set as our partner and quit the loop today 
        partner = tmpUser; 
        break; 
       } 
      } 
     } 

     ... 

我得到以下错误:

partnerClient = io.sockets.clientsIndex[clientId]; 
            ^
TypeError: Cannot read property 'undefined' of undefined 

我做的clientId的输出(执行console.log),它肯定是indefined。此外,我认为API可能在socket.io版本0.8中发生了变化,您不能再使用“clientsIndex”方法。有谁知道更换?

谢谢!

+0

您试图用partnerClient实现的目标是什么? – alessioalex 2012-01-03 21:55:48

+0

我想确保合作伙伴在将其分配给用户之前仍处于连接状态。 – 2012-01-03 22:01:29

+0

我在编辑帖子时添加了一个答案。顺便说一下,循环遍历一系列客户端并不是那么好,想象一下,如果您有10,000个客户端,那么这将会有多慢。这会阻止Node.js事件循环。 – alessioalex 2012-01-03 22:04:35

回答

7

要做的最好的事情是跟踪对象中连接的客户端。以下是我会做到这一点:

var clients = {}; 

io.sockets.on('connection', function (socket) { 
    // remember the client by associating the socket.id with the socket 
    clients[socket.id] = socket; 
    socket.on('sessionStart', function (message) { 
    // get the socket.id of the partner on each message 
    var partner = message.from; 
    if (clients[partner]) { 
     // check if the partner exists and send a message to the user 
     clients[socket.id].emit('message', { from: partner, msg: message }); 
    } 
    } 

    socket.on('disconnect', function() { 
    delete clients[socket.id]; // delete the client from the list 
    }); 
} 

注:在实际生产应用中,你通常会检查会话数据,并且每个客户端提供用户名和socket.id关联。