根据 url 为特定组设置 socket.io 房间。 Node.js、Express、Angluarjs

Question

我有一个使用 express、angular、mongodb 和 socket.io 在用户属于组的节点上运行的 Web 应用程序。在这些组中，我需要设置一个聊天套接字，只有属于该组的人才能看到特定于该组的消息，并且只向该组中的其他用户发送消息。目前，我已经设法根据他们网站上的指南设置了 socket.io 聊天室，但发送的消息对所有其他组都是可见的。我读到我需要设置某些房间，但我不知道如何设置它以使房间特定于该组。

组在域中：例如... www.mydomain.com/groups/groupId/room

groupId 是由 MongoDB 生成的唯一 ID。我在客户端使用 Angularjs，并且有一个组控制器。如果有人对如何实现这一点有任何想法或可以指出正确的方向，我将不胜感激。

我当前的服务器端代码：

var io = require('socket.io').listen(server);

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

    socket.on('connectToServer', function (data) {
        var name = data.name;
        io.sockets.emit('user-join', name + " has connected to the group");
    });

    socket.on('send msg', function (data) {
        io.sockets.emit('get msg', data);
    });

});

以及我在 groupController 中的客户端代码，其中我访问了一个存储当前用户详细信息的全局服务，如下所示：

var socket = io.connect();

$scope.msgs = [];

$scope.sendMsg = function () {
    socket.emit('send msg', $scope.msg.text);
    $scope.msg.text = "";
}

socket.on('get msg', function (data){
    $scope.msgs.push(data);
});

var currentUser = Global.currentUser();
var name = currentUser.username;

socket.emit('connectToServer', {name: name});

socket.on('user-join', function (data) {
    $scope.msgs.push(data);
});

Answer 1

我建议为您聊天的每个房间设置命名空间。我在自己的代码中做了类似的事情。注意：在 socket.io 本身中，房间和命名空间有点不同（socket.io 两者都有：http://socket.io/docs/rooms-and-namespaces/）。

在服务器代码中：

我在socket.on('connection')下有一个方法，类似于

socket.on('groupConnect', function(group){
    var groupNsp = io.of('/' + group);
}

这实质上确保命名空间存在于所需命名空间的名称下。再次调用时不会弄乱或重置命名空间。

然后用于接收消息：

socket.on('message', function(data){
    var msg = data.msg;
    var nsp = data.nsp;
    io.of(nsp).emit('message', msg);
}

您也可以将 nsp 添加到您已有的数据中，然后再次将数据发送给客户端。

然后，在客户端代码中：

var socketOut = io.connect('http://yourdomain:1337/');
var someGroupOrMethodToGetGroup;
socketOut.emit('groupConnect', someGroupOrMethodToGetGroup);
var nsp;
setTimeout(function(){
    socket = io.connect('http://yourdomain:1377/' + someGroupOrMethodToGetGroup);
    socket.on('message', function(msg){
        displayMessage(msg);
    }
    nsp = '/' + someGroupOrMethodToGetGroup;
}, 1500);

然后在我的 displayMessage 代码中我有：

socketOut.emit('message', { msg: desiredMessage, nsp: nsp });