js节点-socket.io聊天修改
Posted
技术标签:
【中文标题】js节点-socket.io聊天修改【英文标题】:Js node - socket.io chat modificaion 【发布时间】:2012-05-22 09:33:11 【问题描述】:这是一个简单的聊天示例。如何修改脚本以便:
前5s,第一个用户可以发消息,接下来的5s,用户不能发消息 在接下来的 5s 内(当第一个用户无法发送消息时),第二个用户可以发送消息,第一个用户得到一个 div (apIdv1) 来显示 index.html:
<script src="/socket.io/socket.io.js"></script>
<script src="https://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
<script>
var socket = io.connect('http://localhost:8080');
// on connection to server, ask for user's name with an anonymous callback
socket.on('connect', function()
// call the server-side function 'adduser' and send one parameter (value of prompt)
socket.emit('adduser', prompt("What's your name?"));
);
// listener, whenever the server emits 'updatechat', this updates the chat body
socket.on('updatechat', function (username, data)
$('#conversation').append('<b>'+username + ':</b> ' + data + '<br>');
);
// listener, whenever the server emits 'updaterooms', this updates the room the client is in
socket.on('updaterooms', function(rooms, current_room)
$('#rooms').empty();
$.each(rooms, function(key, value)
if(value == current_room)
$('#rooms').append('<div>' + value + '</div>');
else
$('#rooms').append('<div><a href="#" onclick="switchRoom(\''+value+'\')">' + value + '</a></div>');
);
);
function switchRoom(room)
socket.emit('switchRoom', room);
// on load of page
$(function()
// when the client clicks SEND
$('#datasend').click( function()
var message = $('#data').val();
$('#data').val('');
// tell server to execute 'sendchat' and send along one parameter
socket.emit('sendchat', message);
);
// when the client hits ENTER on their keyboard
$('#data').keypress(function(e)
if(e.which == 13)
$(this).blur();
$('#datasend').focus().click();
);
);
</script>
<style type="text/css">
#apDiv1
position:absolute;
width:200px;
height:115px;
z-index:1;
left: 150px;
top: 20px;
background-color: #FF9900;
display:none;
</style>
<div style="float:left;width:100px;border-right:1px solid black;height:300px;padding:10px;overflow:scroll-y;">
<b>ROOMS</b>
<div id="rooms"></div>
</div>
<div style="float:left;width:300px;height:250px;overflow:scroll-y;padding:10px;">
<div id="conversation"></div>
<input id="data" style="width:200px;" />
<input type="button" id="datasend" value="send" />
</div>
<div id="apDiv1"></div>
app.js
var app = require('express').createServer()
var io = require('socket.io').listen(app);
app.listen(8080);
// routing
app.get('/', function (req, res)
res.sendfile(__dirname + '/index.html');
);
// usernames which are currently connected to the chat
var usernames = ;
// rooms which are currently available in chat
var rooms = ['room1','room2','room3'];
io.sockets.on('connection', function (socket)
// when the client emits 'adduser', this listens and executes
socket.on('adduser', function(username)
// store the username in the socket session for this client
socket.username = username;
// store the room name in the socket session for this client
socket.room = 'room1';
// add the client's username to the global list
usernames[username] = username;
// send client to room 1
socket.join('room1');
// echo to client they've connected
socket.emit('updatechat', 'SERVER', 'you have connected to room1');
// echo to room 1 that a person has connected to their room
socket.broadcast.to('room1').emit('updatechat', 'SERVER', username + ' has connected to this room');
socket.emit('updaterooms', rooms, 'room1');
);
// when the client emits 'sendchat', this listens and executes
socket.on('sendchat', function (data)
// we tell the client to execute 'updatechat' with 2 parameters
io.sockets.in(socket.room).emit('updatechat', socket.username, data);
);
socket.on('switchRoom', function(newroom)
// leave the current room (stored in session)
socket.leave(socket.room);
// join new room, received as function parameter
socket.join(newroom);
socket.emit('updatechat', 'SERVER', 'you have connected to '+ newroom);
// sent message to OLD room
socket.broadcast.to(socket.room).emit('updatechat', 'SERVER', socket.username+' has left this room');
// update socket session room title
socket.room = newroom;
socket.broadcast.to(newroom).emit('updatechat', 'SERVER', socket.username+' has joined this room');
socket.emit('updaterooms', rooms, newroom);
);
// when the user disconnects.. perform this
socket.on('disconnect', function()
// remove the username from global usernames list
delete usernames[socket.username];
// update list of users in chat, client-side
io.sockets.emit('updateusers', usernames);
// echo globally that this client has left
socket.broadcast.emit('updatechat', 'SERVER', socket.username + ' has disconnected');
socket.leave(socket.room);
);
);
如何将前 5 秒的 apDiv1 显示给一个用户,然后让它消失,反之亦然给第二个用户?
更新答案:
为什么这现在不起作用?
app.js
var app = require('express').createServer()
var io = require('socket.io').listen(app);
app.listen(8080);
// routing
app.get('/', function (req, res)
res.sendfile(__dirname + '/index.html');
);
// usernames which are currently connected to the chat
var usernames = ;
// rooms which are currently available in chat
var rooms = ['room1','room2','room3'];
io.sockets.on('connection', function (socket)
// when the client emits 'adduser', this listens and executes
socket.on('adduser', function(username)
// store the username in the socket session for this client
socket.username = username;
// store the room name in the socket session for this client
socket.room = 'room1';
// add the client's username to the global list
usernames[username] = username;
// send client to room 1
socket.join('room1');
// echo to client they've connected
socket.emit('updatechat', 'SERVER', 'you have connected to room1');
// echo to room 1 that a person has connected to their room
socket.broadcast.to('room1').emit('updatechat', 'SERVER', username + ' has connected to this room');
socket.emit('updaterooms', rooms, 'room1');
);
// when the client emits 'sendchat', this listens and executes
socket.on('sendchat', function (data)
// we tell the client to execute 'updatechat' with 2 parameters
io.sockets.in(socket.room).emit('updatechat', socket.username, data);
);
socket.on('switchRoom', function(newroom)
// leave the current room (stored in session)
socket.leave(socket.room);
// join new room, received as function parameter
socket.join(newroom);
socket.emit('updatechat', 'SERVER', 'you have connected to '+ newroom);
// sent message to OLD room
socket.broadcast.to(socket.room).emit('updatechat', 'SERVER', socket.username+' has left this room');
// update socket session room title
socket.room = newroom;
socket.broadcast.to(newroom).emit('updatechat', 'SERVER', socket.username+' has joined this room');
socket.emit('updaterooms', rooms, newroom);
);
function redLightGreenLight()
socket1.emit('redLight');
socket2.emit('greenLight');
setTimer('redLightGreenLight()', 5000);
// when the user disconnects.. perform this
socket.on('disconnect', function()
// remove the username from global usernames list
delete usernames[socket.username];
// update list of users in chat, client-side
io.sockets.emit('updateusers', usernames);
// echo globally that this client has left
socket.broadcast.emit('updatechat', 'SERVER', socket.username + ' has disconnected');
socket.leave(socket.room);
);
);
index.html
<script src="/socket.io/socket.io.js"></script>
<script src="https://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
<script>
var socket = io.connect('http://localhost:8080');
// on connection to server, ask for user's name with an anonymous callback
socket.on('connect', function()
// call the server-side function 'adduser' and send one parameter (value of prompt)
socket.emit('adduser', prompt("What's your name?"));
);
// listener, whenever the server emits 'updatechat', this updates the chat body
socket.on('updatechat', function (username, data)
$('#conversation').append('<b>'+username + ':</b> ' + data + '<br>');
);
// listener, whenever the server emits 'updaterooms', this updates the room the client is in
socket.on('updaterooms', function(rooms, current_room)
$('#rooms').empty();
$.each(rooms, function(key, value)
if(value == current_room)
$('#rooms').append('<div>' + value + '</div>');
else
$('#rooms').append('<div><a href="#" onclick="switchRoom(\''+value+'\')">' + value + '</a></div>');
);
);
function switchRoom(room)
socket.emit('switchRoom', room);
*socket.on('greenLight', function (data)
// change div to enable sending a message
);
socket.on('redLight', function (data)
// change div to index.html*
);
// on load of page
$(function()
// when the client clicks SEND
$('#datasend').click( function()
var message = $('#data').val();
$('#data').val('');
// tell server to execute 'sendchat' and send along one parameter
socket.emit('sendchat', message);
);
// when the client hits ENTER on their keyboard
$('#data').keypress(function(e)
if(e.which == 13)
$(this).blur();
$('#datasend').focus().click();
);
);
</script>
<style type="text/css">
#greenLight
position:absolute;
width:200px;
height:115px;
z-index:1;
left: 150px;
top: 20px;
background-color: #FF9900;
display:none;
</style>
<div style="float:left;width:100px;border-right:1px solid black;height:300px;padding:10px;overflow:scroll-y;">
<b>ROOMS</b>
<div id="rooms"></div>
</div>
<div style="float:left;width:300px;height:250px;overflow:scroll-y;padding:10px;">
<div id="conversation"></div>
<input id="data" style="width:200px;" />
<input type="button" id="datasend" value="send" />
</div>
***<div id="greenLight"></div>***
【问题讨论】:
那么当计数器 > 0 时我如何阻止用户 【参考方案1】:Quoth beginerplus,“也许让服务器更好地完成工作......如何更改我的脚本来做到这一点?请在答案上写作为示例”:
在服务器上:
function redLightGreenLight()
socket1.emit('redLight');
socket2.emit('greenLight');
setTimer('redLightGreenLight()', 5000);
在客户端:
socket.on('greenLight', function (data)
// change div to enable sending a message
);
socket.on('redLight', function (data)
// change div to index.html
);
【讨论】:
我用你建议的代码更新了我的问题,但错误在哪里? 我正在添加您为我编写的代码,但问题出在哪里? 只是连接丢失,没有消息在按钮单击时从客户端发送到服务器...尝试使用我发布为更新问题的代码 更好的是:我需要把你写的代码放在哪里?也许我把那个代码放在了错误的地方? 我无法为您调试代码,但我可以给您一个提示:您需要将 socket1 和 socket2 设置为客户端连接到服务器时获得的实际套接字。【参考方案2】:有两种方式:
-
服务器在 5 秒后向每个客户端发送一条消息,使用 setTimer(或 setInterval,以防您需要重复):客户端 #1 不能再发送消息,而客户端 #2 可以。然后每个客户端通过更改 div 内容来处理消息。
每个客户端都单独使用 setTimer 或 setInterval;根据您的用例,这可能具有一些优点,但可能具有计时器不会在完全相同的时间启动的缺点。
【讨论】:
由于网络延迟的差异,这两个事件可能无论如何都不会完美同步。 没错,但对于 #1 来说,时机通常不会那么错误,而且我猜这对于我假设他正在尝试做的事情来说已经足够接近了。学校里没有人告诉我作为一名工程师我会做多少假设和猜测。 #1 可能是一个足够好的解决方案。但如果不是,您的实时要求是什么?不同的时钟需要多接近? 排名第一的解决方案可能更好 我需要最好的同步以上是关于js节点-socket.io聊天修改的主要内容,如果未能解决你的问题,请参考以下文章
需要在节点js,socket.io,express js,ionic 3的实时聊天应用程序中提供建议
在 PHP 中使用 Node.js、Socket.io、Redis 的私人聊天消息
在已经在wampserver上运行的网站上运行socket.io聊天应用程序