socket.io手动将用户添加到房间（node.js）

Question

我有一个私人聊天应用程序。我的实现方式是：

1.用户进入另一个用户的个人资料页面并写下一条消息。然后我会为这次对话创建一个房间。

socket.join(data.user);

接收者用户将接收此消息（仅限该用户），但我不知道如何将此接收者用户加入此房间。因此，这基本上是我的问题。我需要手动将此接收者用户添加到我的房间中。通过这种方式，当我向此房间广播消息时，消息将发出给这两个用户（一个是匿名用户，另一个是注册用户）。这将提供我的一些代码。

server
.on('connection', function(socket) {

    server.to(socket.id).emit('yourSocketId',{ socketid : socket.id,connectedDate : Date.now });

    socket.on('AnonymousMessage', function(data) {
        if(data.isanon == true) 
        {
            socket.join(data.user);

            server.to(data.user).emit('AnonymousBroadcast', {
                message: data.message,
                user: data.user,
                isanon : data.isanon,
                date : data.date,
                tabno : data.tabno
            });
        }
        else
        {
            socket.join(****); //-- I need add manually here this registered user to anonymous user room
            server.to(**anonymousroomname**).emit('AnonymousBroadcast', {
                message: data.message,
                user: data.user,
                isanon : data.isanon,
                date : data.date,
                tabno : data.tabno
            });
        }

    });

});

任何建议对我来说都很好。谢谢。

- Fatih Ayyildiz

Answer 1

你在问题中提到的那些非常私密的房间可能是正确的做法。不过，你需要持有用户及其相应套接字的引用。然后，当匿名或其他任何类型的用户向已注册用户发送私人消息时，只需将它们两个加入同一个房间即可。

var io = require('socket.io')(http);
sockets = [];
people = {};

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

    //join the server
    io.on('join', function(name){
      people[socket.id] = {name: name};
    })

    //disconnect from the server
    io.on('disconnect', function(){
      delete people[socket.id];
      sockets.splice(sockets.indexOf(socket), 1);
    });

    //initiate private message
    io.on('initiate private message',function(receiverName, message){
      var receiverSocketId = findUserById(receiverName);
      if(receiverSocketId){
        var receiver = people[receiverSocketId];
        var room = getARoom(people[socket.id], receiver);

        //join the anonymous user
        socket.join(room);
        //join the registered user 
        sockets[receiverSocketId].join(room);

        //notify the client of this
        io.sockets.in(room).emit('private room created', room, message);

        //
      }
    });

    io.on('send private message', function(room, message){
      io.sockets.in(room).emit('private chat message', message);
    });
  }

//you could use e.g. underscore to achieve this (
function findUserByName(name){
  for(socketId in people){
    if(people[socketId].name === name){
      return socketId;
    }
  }
  return false;
}

//generate private room name for two users
function getARoom(user1, user2){
  return 'privateRooom' + user1.name + "And" + user2.name;
}

当然，这是一个非常幼稚和不完整的解决方案！用户需要有id，房间也需要，您还需要检查现有的用户名，很可能还需要保留对房间的引用等等。但你明白了吧？

另一种选择是使用私语（whispers） - 您可以使用以下代码将消息发送到只有一个socket=person：io.sockets.socket(receiverSocketId).emit("whisper", message, extraInfo);。我建议不要这样做，因为这意味着必须实现来回的私语，这可能会变得非常混乱。

- Tadeáš Peták

---

抱歉回复晚了。我会尝试您的解决方案并写下评论。也谢谢您。 - Fatih Ayyildiz

嗨@Tadeas，我尝试了你的解决方案，但是出现了这个错误** Cannot call method 'join' of undefined **。这一行是sockets[receiverSocketId].join(room);。为什么会出错？看起来很合理啊。 - Fatih Ayyildiz

Answer 2

你尝试使用的套接字可能未连接。在尝试加入房间时，您可以使用以下内容：

io.sockets.connected[receiverSocketId].join(room);

- manickam subramanian