与socket.io私密聊天

我在使用我的聊天应用程序时遇到了麻烦，我需要能够将私人消息发送给特定的用户，我可以select特定的用户，但由于某种原因无法弄清楚如何发送私人消息。

下面你会发现我的服务器的代码，请帮助：

var express = require('express'); var app = express(); var PORT = process.env.PORT || 8000; var http = require('http').Server(app); // this is a node server that uses express as the boiler plate var io = require('socket.io')(http); // socket! pass our server as a parameter to it // use express static to expose a folder app.use(express.static(__dirname + '/public')); var users = [], connections = []; var onlineClients = {}; // Register events on socket connection io.on('connection', function(socket){ connections.push(socket); // console.log("connected socket", connections); socket.on("disconnect", function() { users.splice(users.indexOf(socket.username), 1); updateUsernames(); connections.splice(connections.indexOf(socket), 1); console.log("disconnected socket", connections.length) }); socket.on("send message", function(data) { // console.log(data); io.emit("new message", {msg: data, user: socket.username}); }); socket.on("notify user", function(data) { io.emit("notify user", {user: socket.username}) }); socket.on("new user", function(data) { socket.username = data; users.push(socket.username); updateUsernames(); }); function updateUsernames() { io.emit("get users", users); }; socket.on("private", function(data, recipientName) { var recipient = connections.filter(function (recipient) { return recipient.username === recipientName; })[0]; console.log(recipient.id); console.log(data); io.sockets.socket(recipient.id).emit("received private msg", data); }); // socket.on("create room", function(room) { // socket.join(room); // io.sockets.in(room).emit('event', "hey wusup am in this room"); // console.log(socket); // }) }); http.listen(PORT, function(){ console.log('Server started on port ' + PORT); }); 

Answer 1

• 首先在聊天室中添加用户，以便在私人聊天室中轻松find用户

• 您的客户端代码join私人空间

  <input type="text" class="form-control" id="user_email" placeholder="user_email" /> <button text="join room" class="btn btn-primary btn-block" onclick="a();"> Join Room</button>

• 你的JavaScript代码在客户端

  function a(){ io.emit('privatechatrrom', {email:document.getElementById('user_email').value}); }

• 你的服务器端代码添加用户在你的房间

  socket.on('privatechatroom',function(data){ socket.join(data.email); io.emit('res',{mes:"you are added"}) });

现在你可以发送悄悄话给最近join这个房间客户端的那个人

 function b() { io.emit('sendmail',{email:document.getElementById('sender_mail').value,message:document.getElementById('message').value}); $('#message').val(''); } /*serverside code*/socket.on('sendmail',function(data) { io.sockets.in(data.email).emit('new_msg', {msg: data.message}); console.log(data.email); }); 

Answer 2

这是我的问题的明确解决scheme…

发送消息给特定的客户（私人聊天）

我希望它会为你工作起诉..