Nodejs实现多人同时在线移动鼠标的小游戏分享_node.js

var http = require(&＃39;http&＃39;),

io = require(&＃39;socket.io&＃39;);

var app = http.createServer().listen(9091);

var ws = io.listen(app);

var postiOns= {};

ws.on(&＃39;connection&＃39;, function(client){

// 广播函数

var broadcast = function(msg, cl){

for(var k in ws.sockets.sockets){

if(ws.sockets.sockets.hasOwnProperty(k)){
if(ws.sockets.sockets[k] && ws.sockets.sockets[k].id != cl.id){
ws.sockets.sockets[k].emit(&＃39;position.change&＃39;, msg);
}

}

}

};

console.log(&＃39;\033[92m有新的连接来:\033[39m&＃39;, postions);

// 客户端连接成功之后，就发送其它客户端的坐标信息

client.emit(&＃39;position.change&＃39;, postions);

// 接收客户端发送消息

client.on(&＃39;position.change&＃39;, function(msg){

// 目前客户端的消息就只有坐标消息

postions[client.id] = msg;

// 把消息广播给其它所有的客户端

broadcast({

type: &＃39;position&＃39;,

postion: msg,

id: client.id

}, client);

});

// 接收客户端关闭连接消息

client.on(&＃39;close&＃39;, function(){

console.log(&＃39;close!&＃39;);

// 删除客户端，并通知其它客户端

delete postions[client.id];

// 把消息广播给其它所有的客户端

broadcast({

type: &＃39;disconnect&＃39;,

id: client.id

}, client);

});

// 断开连接

client.on(&＃39;disconnect&＃39;, function(){

console.log(&＃39;disconnect!&＃39;);

// 删除客户端，并通知其它客户端

delete postions[client.id];

// 把消息广播给其它所有的客户端

broadcast({

type: &＃39;disconnect&＃39;,

id: client.id

}, client);

})

// 定义客户端异常处理

client.on(&＃39;error&＃39;, function(err){

console.log(&＃39;error->&＃39;, err);

})

});