我刚刚开始学习NodeJS和Socket.io。到目前为止,我已经从socket.io官方网站获得了这个演示代码:
http://socket.io/demos/chat/
我能够获得所连接的每个用户(套接字)的唯一客户端ID,但我仍在设法弄清楚,如何使我的代码在某人运行该应用程序时一次只能与1个随机用户连接。我只想像Omegle(http://www.omegle.com/)那样进行随机聊天。
只有两个用户应该随机连接并彼此聊天,直到他们重新运行该应用程序为止;如果他们回来了,他们应该与处于在线队列中的其他人建立连接。
要具有类似的行为,我需要做哪些更改?
添加了客户端站点代码 main.js
$(function() { var FADE_TIME = 150; // ms var TYPING_TIMER_LENGTH = 400; // ms var COLORS = [ '#e21400', '#91580f', '#f8a700', '#f78b00', '#58dc00', '#287b00', '#a8f07a', '#4ae8c4', '#3b88eb', '#3824aa', '#a700ff', '#d300e7' ]; // Initialize variables var $window = $(window); var $usernameInput = $('.usernameInput'); // Input for username var $messages = $('.messages'); // Messages area var $inputMessage = $('.inputMessage'); // Input message input box var $loginPage = $('.login.page'); // The login page var $chatPage = $('.chat.page'); // The chatroom page // Prompt for setting a username var username; var connected = false; var typing = false; var lastTypingTime; var $currentInput = $usernameInput.focus(); //Own Global var room = ''; var socket = io(); function addParticipantsMessage (data) { var message = ''; if (data.numUsers === 1) { // message += "there's 1 participant"; // Status Message message += "Waiting to connect with someone"; } else { // message += "there are " + data.numUsers + " participants"; //Status message update message = "You are connected to a stranger! Say Hey!"; } log(message); } // Sets the client's username function setUsername () { username = cleanInput($usernameInput.val().trim()); // If the username is valid if (username) { $loginPage.fadeOut(); $chatPage.show(); $loginPage.off('click'); $currentInput = $inputMessage.focus(); // Tell the server your username socket.emit('add user', username); // Own socket.emit('login', {'username' : 'Faizan'}); } }
尽管由于过于模糊,我将结束这个问题,但由于过去几年我对websockets的使用过多,因此我有义务向您提供一些见解(尽管与socketio和nodejs的相关性不是很多)。我想一些简单的指南和相关链接可以为您提供帮助。所以首先
您应该已经知道 Socket.io 是 WebSocket 实现。WebSockets(WS)允许服务器在需要时随时发送数据,只要连接仍处于打开状态即可,这与旧方法相反:客户端一直在查询,询问服务器上是否有更新。
您可以想象在聚会结束时一个女人和一个男人:“ 谢谢您,今晚,我很乐意有时再重复一遍。您能给我您的电话号码吗? ”-老人问。“ 恩,你知道吗,最好给我你的,我保证会打电话给你! ”如果女孩要给他她的电话号码,他每天会打几次电话问她是否要去某个地方( d否)。相反,她只有在她想离开而他会离开时才给他打电话。当然可以。我有点不高兴,但你知道了。女人是服务器,男人是客户。
(绝对基础,您应该知道此=>)当客户端连接到服务器时,应该为他提供一个html页面和一些javascript,以建立与WS服务器的连接。在您发布的代码中, Express 用作http服务器。检查此示例以了解应如何为用户提供html&js。
您还将在大多数这些教程中注意到名称空间和房间。这些用于将用户分为子类别。一台服务器可以包含多个名称空间(默认情况下只有一个),每个名称空间可以包含多个房间。您可能不需要打扰命名空间,一个就足以满足您的情况。
接下来的事情,取自您的代码
io.on('connection', function (socket) {
重要的是要知道,这里的 套接字 基本上代表 一个连接的客户端 (在一个名称空间中,但可能在多个房间中)。您可以用它来做各种事情,最著名的是:
socket.on(event, handler(data))
socket.emit(event, data)
socket.broadcast.emit(event, data)
socket.join(room)
socket.leave(room)
您在代码中看到 numUsers 的定义了吗?这是所有客户端共享的全局变量,因为nodejs是 单线程的 。在示例中,它是在事件处理程序之一中递增的。认为我们可以使用类似的东西吗? 是的 。
我们可以定义全局变量,例如队列。如果需要,也可以问Q。关键是,它可以是用于存储 套接字 的数组,或者可以是当前不在聊天室中的客户端的数组。
在本节的最后,我想指出另一件事。 为 io* 对象(WS服务器)上发生的“连接”事件io.on('connection', handler);定义 事件处理程序 。每当客户端与您的WS服务器建立连接时(在您的情况下,是通过客户端浏览器中运行的javascript)触发的。该方法的参数是 套接字 ,在该方法中,您应该为每个客户端添加事件侦听器(您已经在代码中进行了此操作,特别是处理事件“新消息”,“添加用户”,“键入”,“停止键入”和“断开连接”)。 * __
io.on('connection', handler);
这实际上取决于您希望应用程序的复杂程度。我认为,最低要求是(请注意,您可以更改事件名称,但“断开连接”应保持为“断开连接”):
事件名称 ->给定的数据
这只是一个粗略的草图。一路上有多个不同的十字路口,您选择哪种方式主要取决于您对应用程序的想法。如果您想同时打开多个聊天,则需要进行一些修改。如果您想让两个以上的人连接到同一聊天室,也是如此。在这里,我将向大家介绍最简单的情况,一次聊天,无需注册。从您的帖子来看,可能是您想要的。可能是错误的。
用户在其网络浏览器中打开您的页面。您为他们提供html和javascript。javascript将开始与您的websocket服务器的新连接。另外,此时应定义所需事件的处理程序。建立连接后,将发生以下情况:
io.on('connection', handler)将被解雇。仅安装适用于新套接字的处理程序,此时不执行任何其他操作。
io.on('connection', handler)
socket.on('connect', handler)将被解雇。此时,客户端应将用户名存储在某处。如果没有,没问题。连接将在相当长的时间内保持活动状态。连接后,您可以随时调用socket.emit('login', {'username':name)(在下面的示例中,我设置了connected变量,该变量默认为false,但在建立连接后立即设置为true。)
socket.on('connect', handler)
socket.emit('login', {'username':name)
从客户端发送 登录 事件后,服务器将其注册并保存到某处。可能性无穷无尽,在这种情况下,我将创建将socket.id映射到用户名的全局字典。之后,用户套接字应与另一个套接字配对或添加到队列中。因此,如果队列为空,只需将套接字附加到全局变量(它不必是数组,因为我们会将第一个可用的套接字配对在一起,但是您可能想要实现一些用户的历史记录,因此他们不会重新与同一个人建立联系)。如果队列不为空,我们从Q中拉出一个插座,并将其添加到同一房间。房间名称可以是随机的,也可以是您想要的任何名称,我将使用(socket1.id +’#’+ socket2.id(如果您想在一次聊天中拥有更多用户,则必须进行更改)。
将他们都添加完后,您需要通知他们聊天已经开始,并向他们发送对方的名字。您将发出事件“聊天开始”。
客户将赶上活动并打开新窗口。此后,每当用户键入内容并将其发送时,客户端就会发出带有有效负载{‘message’:user_inserted_text}的事件’message’。服务器将在.on('message'处理程序中捕获它,并将其广播到房间。注意:
.on('message'
广播意味着将消息发送到其他人(除了启动该消息的套接字之外)。
注意:我现在对socketio代码真的很困惑。看看这个,告诉我,如果socket.rooms是一个数组还是一个对象(socket.rooms[room] = room;??为什么?)
socket.rooms[room] = room;
为了避免处理这种不简单的代码,让我们创建另一个全局对象,rooms它将为我们存储房间名称。我们将在那里映射socket.id-> roomName。
rooms
因此,当出现消息时,我们可以通过致电获取房间名称rooms[socket.id]。然后我们广播这样的消息:
rooms[socket.id]
socket.broadcast.to(room).emit('message', data);
当 数据 是我们从发送方接收,因此对象{“文”:“一些不错的消息”}。然后您的同伴将收到(您不会)并显示它(发送时应显示它)。
因此,这样的聊天持续了一段时间,然后一个用户决定他要离开/与其他人聊天。他们将关闭窗口,客户将发出事件“离开房间”。服务器将捕获它,并将其发送给其对等方已断开连接的另一方。如果客户端断开连接,也会发生同样的情况。关闭所有内容后,将两个用户都添加到队列中(或一个,如果另一个已与服务器断开连接)。在我的代码中,我无法确保不会再次配对。那是为了OP进行编码(不难)。
因此,如果您读了这么多,应该得到一些实际的代码。尽管我说的是“ 实际” ,但实际上未经测试。但您知道,它应该像这样工作。
var connected = false; var username = 'Faizan'; var room = ''; var socket = io('http://localhost'); socket.on('connect', function (data) { // we are connected, should send our name connected = true; if (username) socket.emit('login', {'username' : username}); }); socket.on('chat start', function(data) { room = data.room; show_chat_window(data.name); // some method which will show chat window }); socket.on('chat end', function(data) { hide_chat_window(); // this will close chat window and alert user that the peer ended chat socket.leave(room); // it's possible to leave from both server and client, hoever it is better to be done by the client in this case room = ''; }); socket.on('disconnect', function(data) { // handle server/connection falling console.log('Connection fell or your browser is closing.'); }); var send_message = function(text) { // method, which you will call when user hits enter in input field if (connected) socket.emit('message', {'text': text}); }; var leave_chat = function() { // call this when user want to end current chat if (connected) { socket.emit('leave room'); socket.leave(room); room = ''; } };
不包括初始要求和html / js服务。仅包括全局定义和主要io处理程序。
var queue = []; // list of sockets waiting for peers var rooms = {}; // map socket.id => room var names = {}; // map socket.id => name var allUsers = {}; // map socket.id => socket var findPeerForLoneSocket = function(socket) { // this is place for possibly some extensive logic // which can involve preventing two people pairing multiple times if (queue) { // somebody is in queue, pair them! var peer = queue.pop(); var room = socket.id + '#' + peer.id; // join them both peer.join(room); socket.join(room); // register rooms to their names rooms[peer.id] = room; rooms[socket.id] = room; // exchange names between the two of them and start the chat peer.emit('chat start', {'name': names[socket.id], 'room':room}); socket.emit('chat start', {'name': names[peer.id], 'room':room}); } else { // queue is empty, add our lone socket queue.push(socket); } } io.on('connection', function (socket) { console.log('User '+socket.id + ' connected'); socket.on('login', function (data) { names[socket.id] = data.username; allUsers[socket.id] = socket; // now check if sb is in queue findPeerForLoneSocket(socket); }); socket.on('message', function (data) { var room = rooms[socket.id]; socket.broadcast.to(room).emit('message', data); }); socket.on('leave room', function () { var room = rooms[socket.id]; socket.broadcast.to(room).emit('chat end'); var peerID = room.split('#'); peerID = peerID[0] === socket.id ? peerID[1] : peerID[0]; // add both current and peer to the queue findPeerForLoneSocket(allUsers[peerID]); findPeerForLoneSocket(socket); }); socket.on('disconnect', function () { var room = rooms[socket.id]; socket.broadcast.to(room).emit('chat end'); var peerID = room.split('#'); peerID = peerID[0] === socket.id ? peerID[1] : peerID[0]; // current socket left, add the other one to the queue findPeerForLoneSocket(allUsers[peerID]); }); });
上面的代码最后有点混乱。可以做得更好,我鼓励您做得比我更好。掌握了这些材料后,请逐步进行操作并尝试理解。我想我评论最多,即使不是全部。祝好运。
我什至都不惊讶。在这里看漫画