0

我使用 node.js 和 socket.io。

我的mysql表中有这个数据结构：

TABLE USERS:
    Id: 1, Name: 'ABC1', ToUserId: 1
    Id: 2, Name: 'ABC2', ToUserId: 1
    Id: 3, Name: 'ABC3', ToUserId: 1
    Id: 4, Name: 'ABC4', ToUserId: 2
    Id: 5, Name: 'ABC5', ToUserId: 2
    Id: 6, Name: 'ABC6', ToUserId: 2
    Id: 7, Name: 'ABC7', ToUserId: 3

我想将行（ID1 - ID3）作为集合发送给 UserId 1 的用户，将行（ID4 - ID6）发送给 UserId 2 的用户，将行（ID7）发送给 UserId 3 的用户。

如何创建集合并将集合发送给用户？

我读取数据如下：

getUsers: function(callback)
    {

        client.query(
            'SELECT * FROM users',
            function select(err, results, fields) {
                if (err) {
                    throw err;
                }

                var userslist = {};


                if (results.length > 0) {

                    for (var i = 0; i < results.length; i++) {
                        var row = results[i];                        

                    //Create colletion in object userslist
                    //Emit to specific user ------v                        
                    //io.sockets.socket(USER_ID).emit('sendusers', userslist ) 
                    }

                }
        else
                {
                    userslist = {}; 
                } 

                callback(userslist);
            }
            );
    }
4

1 回答 1

2

您将需要存储套接字 ID 和用户 ID 之间的关联。

在您的客户端上，您需要发出当前用户的 USER_ID。

就像是

socket= io.connect();
socket.on('connect', function(data){
    socket.emit('init', user_id);
});

并且在您的服务器上需要设置 user_id。你可以做类似的事情

io.sockets.on('connection', function(socket) {
    socket.on('init', function(data) {
        socket.set('user_id', data, function(){
            console.log('user_id', data);
        });
    });
});

然后在您的控制器中，您可以检索所有套接字并循环它们。

//to get all connections
var sockets = io.sockets.clients();

//to get the user_id associated with the socket
socket.get('user_id', function(err, user_id){
    //do whatever you want!
    //ex: if(user_id == ...){ socket.emit('channel', 'value'); }
});

希望有帮助！

于 2012-07-12T18:14:01.013 回答