阵列在拼接后不会改变它的数据.范围问题
Array wont change it's data after splice. Scope problems?
我有一个tcp服务器，我将所有客户端数据存储在客户端数组中。因此，当有人断开连接时，我只是将它们拼接起来。
clients.splice(clients.indexOf(socket), 1);
我有一个显示所有在线用户的功能。它只是从该客户端数组中获取数据并将其显示给我。
function showOnline(){
console.log("Show user list");
console.log("clients.length = " + clients.length);
}
客户端阵列在应用程序.js文件顶部公布
var clients = []; <- here it is
var http = require('http');
var net = require('net');
所以现在当客户端断开连接时，我会拼接他并收到这样的日志。
console.log("clients.indexOf(socket) = " + clients.indexOf(socket));
console.log("clients.length = " + clients.length);
clients.splice(clients.indexOf(socket), 1);
console.log("after splice clients.length = " + clients.length);
LOG
2016-03-04 22:06:33
clients.length = 2
after splice clients.length = 1
所以客户端阵列上只有 1 个用户。然后我使用我的显示在线用户功能，它给了我这样的日志
LOG
2016-03-04 22:06:41 - Show user list
clients.length = 2
它显示有 2 个用户。这怎么可能？这是范围问题吗？或者它能是什么？感谢您的任何回复。
源。我想我在插座上做错了什么。这段代码有效，但它运行的时间越长，我在客户端阵列上保持的幻像客户端就越多。
var clients = [];
var packetReg = /(ART'D'd{4}(.*?)'DAND)/g;
var serverUrl = "http://localhost:4000/"
// Exit packet
var p = {
exit: true
};
var ePacket = 'ART|' + randomNumber(1000, 9000) + JSON.stringify(p) + '|AND';
var fs = require('fs');
var http = require('http');
var https = require('https');
var net = require('net');
var url = require('url');
http.createServer(function (req, res) {
var queryData = url.parse(req.url, true).query;
res.writeHead(200, {"Content-Type": "text/html; charset=utf-8"});
if (queryData.clean) {
kick();
} else if (queryData.expel) {
kick();
} else if (queryData.list) {
showUserList();
}
else {
res.writeHead(302, {'Location': 'https://localhost'});
res.end();
}
function kick(all){
if (queryData.expel){
LOG("Expel user " + queryData.expel + " cmd");
}
else LOG("Kick all cmd");
clients.forEach(function (client) {
if (queryData.expel){
if (client.key != queryData.expel) return;
}
client.write(ePacket);
});
if (queryData.expel){
res.end("done");
}
else {
cleanOnline();
res.end("disconnected - " + clients.length);
}
}
function showUserList(){
LOG("Show user list");
var temp = 'Clients: ' + clients.length + generateButton('?clean=1', 'Kick all') + '<br>';
clients.forEach(function (client) {
temp += 'User: ' + client.name + ' Key: ' + client.key + generateButton('?expel=' + client.key, 'Kick') + '<br>';
});
console.log("clients.length = " + clients.length);
res.end(temp);
}
function generateButton(link, text){
return ' <a href="' + serverUrl + link + '" target="_blank" onClick="window.location.reload()"><button>' + text + '</button></a> ';
}
}).listen(4000, function(){
console.log('listening http on port 4000');
});
var tcpSocket = net.createServer();
tcpSocket.on('connection', function (socket) {
socket.setNoDelay(true);
socket.banned = false;
socket.isAdmin = false;
socket.isModerator = false;
socket.name = 'newUser'
socket.key = ''
socket.armbuf = '';
clients.push(socket);
LOG("New connection #" + clients.length);
// Exit packet that close opened software
socket.on('doExit', function () {
LOG("Send exit packet");
var p = {
exit: true
};
socket.write('ART|' + randomNumber(1000, 9000) + JSON.stringify(p) + '|AND');
socket.destroy();
});
// Init packet
socket.on('init', function (newData) {
LOG("Init packet");
//newData.data = packet with key from my program
//I find out if users start my program few times then they will be added few times at clients array.
//So i want to prevent that with that function. It finds sockets with same key and just disconnect them except for the last socket.
//
FindAndCleanDuplicateSockets(newData.data, socket);
var tempSocket = findSocket(socket);
tempSocket.socket.key = newData.data;
LOG("Send request to localhost about key " + tempSocket.socket.key);
https.get('https://localhost/tgo/api/?apiRequest&key=' + tempSocket.socket.key, (res) => {
var initData = '';
res.on('data', function (chunk) {
initData += chunk;
});
res.on('end', function() {
LOG("Receive answer from localhost - " + initData.toString());
var a = JSON.parse(initData.toString());
if (a.data = "OK"){
tempSocket.socket.name = a.name;
tempSocket.socket.banned = !Boolean(a.chatBan);
if (a.type == "admin")
tempSocket.socket.isAdmin = true;
else if (a.type == "moderator")
tempSocket.socket.isModerator = true;
updateSocket(tempSocket);
broadcast(packetMaker(tempSocket.socket.name, 'start'), socket);
}
else socket.emit('doExit');
});
}).on('error', (e) => {
socket.emit('doExit');
});
});
//When user send ping packet
socket.on('ping', function (newData) {
//LOG("Ping packet");
var p = {
currentTime: currentTime()
};
socket.write('ART|' + randomNumber(1000, 9000) + JSON.stringify(p) + '|AND');
});
// When user change his name
socket.on('newName', function (newData) {
LOG("User change name from " + socket.name + " to " + newData.data);
var tempSocket = findSocket(socket);
tempSocket.socket.name = newData.data;
updateSocket(tempSocket);
});
//When user send new message packet
socket.on('newMsg', function (newData) {
LOG("newMsg packet");
var tempSocket = findSocket(socket);
if (tempSocket.socket.banned) {
LOG('User ' + tempSocket.socket.key + ' chat is banned');
return;
}
var type = 'msg';
if (tempSocket.socket.isAdmin)
type = 'admin';
else if (tempSocket.socket.isModerator)
type = 'moderator';
broadcast(packetMaker(tempSocket.socket.name, type, String(newData.data)), socket);
});
// Handle incoming messages from clients.
socket.on('data', function (newData) {
var d = String(newData);
//LOG('Received data: ' + d);
// I find that socket bacause i use buffer to store data. If i won't do that it will give me "is not defined" error
var tempSocket = findSocket(socket);
tempSocket.socket.armbuf += d;
var dataArray = tempSocket.socket.armbuf.match(packetReg);
if (dataArray != null && dataArray.length > 0){
dataArray.forEach(function (match) {
tempSocket.socket.armbuf = tempSocket.socket.armbuf.replace(match, "");
if (match.startsWith('ART|') && match.endsWith('|AND')) {
var j = JSON.parse(cleanPacket(match));
switch (j.type) {
case 'init':
socket.emit('init', j);
break;
case 'ping':
socket.emit('ping', j);
break;
case 'newName':
socket.emit('newName', j);
break;
case 'newMsg':
socket.emit('newMsg', j);
break;
default:
break;
}
}
else console.log('Bad packet: ' + match);
//LOG("armbuf.length = " + tempSocket.socket.armbuf.length);
});
}
updateSocket(tempSocket);
});
socket.on('error',function(error) {
socket.end();
});
socket.on('close',function() {
var tempSocket = findSocket(socket);
LOG("Send logout notification to localhost - " + tempSocket.socket.key);
// Send info to api that user logout
https.get('https://localhost/tgo/api/?logout&key=' + tempSocket.socket.key);
// Broadcast data to all users that client is logout
broadcast(packetMaker(tempSocket.socket.name, 'exit'), socket);
console.log("clients.indexOf(socket) = " + clients.indexOf(socket));
console.log("clients.length = " + clients.length);
// Delete user from clients array
clients.splice(clients.indexOf(socket), 1);
console.log("after splice clients.length = " + clients.length);
LOG("Close from API - " + tempSocket.socket.key);
socket.destroy();
});
function cleanPacket(packet){
packet = packet.replace("ART|", "");
packet = packet.replace("|AND", "");
return packet.substring(4);
}
function findSocket(socket){
var socketData = {
'id': clients.indexOf(socket),
'socket': clients[clients.indexOf(socket)]
};
return socketData;
}
function FindAndCleanDuplicateSockets(key, exclude){
clients.forEach(function (client) {
if (client == exclude && client.key != key) return;
LOG("User already exist in array. Delete old socket");
client.emit('doExit');
});
}
function findAllSocketsByKey(key, excludeSocket){
var sockets = [];
clients.forEach(function (client) {
if (client == excludeSocket && client.key != key) return;
sockets.push(client);
});
return sockets;
}
function updateSocket(tempSocket){
clients[tempSocket.id] = tempSocket.socket;
}
// Send a message to all clients
function broadcast(message, sender) {
if (clients.length <= 0) return;
LOG('broadcast ' + message);
clients.forEach(function (client) {
// Don't want to send it to sender
if (client === sender) return;
client.write(message);
});
}
function packetMaker(userName, packetType, userMsg){
var p = {
currentTime: currentTime(),
chat: {
user: userName,
type: packetType
}
};
if (typeof userMsg != 'undefined')
p['chat']['msg'] = userMsg;
return 'ART|' + randomNumber(1000, 9000) + JSON.stringify(p) + '|AND';
}
});
tcpSocket.listen(5000, function(){
console.log('listening tcpSocket on port 5000');
cleanOnline();
});
function cleanOnline(){
console.log('Clean DB online');
//https.get('https://localhost/tgo/api/?apiCleanOnline');
}
function LOG(data){
console.log(currentTime() + " - " + data);
}
function randomNumber(min, max)
{
return Math.floor(Math.random() * (max - min + 1)) + min;
}
function currentTime() {
var date = new Date();
var hour = date.getHours();
hour = (hour < 10 ? "0" : "") + hour;
var min = date.getMinutes();
min = (min < 10 ? "0" : "") + min;
var sec = date.getSeconds();
sec = (sec < 10 ? "0" : "") + sec;
var year = date.getFullYear();
var month = date.getMonth() + 1;
month = (month < 10 ? "0" : "") + month;
var day = date.getDate();
day = (day < 10 ? "0" : "") + day;
return year + "-" + month + "-" + day + " " + hour + ":" + min + ":" + sec;
}
这是你的罪魁祸首：
function findSocket(socket){
var socketData = {
'id': clients.indexOf(socket),
'socket': clients[clients.indexOf(socket)]
};
return socketData;
}
我看到您使用此函数获取数组中的套接字索引（由属性 id 引用）以供以后使用。
问题来了。
想象一下应用中的以下事件序列：
此时，您有 2 个连接。
现在接收新连接您刚刚将第三个套接字推入客户端阵列tempSocket 现在的 id 为 2
应用调用 api 以获取密钥
现有套接字收到断开连接事件该应用程序从客户端阵列中删除现有套接字，您就剩下 2 个套接字了。 它有两个，因为我们已经在项目符号 #1 中添加了新套接字
项目符号 #2 中的 api 调用与密钥一起返回现在你调用updateStocket（tempSocket）来更新它。问题是 tempSocket.id 指向索引 2，但数组中只有 2 个元素。
我的服务：
我。 将客户端数组更改为对象集合ii. 当您获得新的套接字连接时，请使用 UUID.js 等库获取唯一的十六进制并将其分配给新的套接字属性iii. 使用十六进制 ID 向客户端对象添加新套接字
如果决定进行上述更改，则必须更新迭代方法。 我建议使用 lodash 来帮助你迭代数组和对象。 真的很方便。 否则，您必须获取对象键并循环访问它们。
祝你好运。
相关文章：
- 如何在D3.js中绘制地图投影上的点，并使用范围滑块过滤数据
- 对于使用传递的数据计算的局部范围变量，角度绑定在自定义指令中不起作用
- 用Javascript编辑范围数据(时间序列）
- 基于范围数据更改指令模板中的元素
- 如果指令包含在另一个指令中，我如何在隔离范围内添加双向数据绑定属性
- $http AngularJS 后不更新的数据范围
- 阵列在拼接后不会改变它的数据.范围问题
- 将数组从文档属性与数据范围进行比较不起作用
- AmChart:如何缩小数据范围
- regex在模式数据范围中查找匹配项
- Highchart不显示数据范围，即使有数据
- Rails数据范围选择器
- 在 React 中限定数据范围
- 如何避免不良行为缩放到数据范围以外的区域
- 在数组中的数据范围之间填充日期
- Highcharts -在列范围图表中使用标志使数据范围不可见并显示消息
- 我如何在树图高图中选择数据范围
- 在高图中单独着色的数据范围
- 高库存-设置超出数据范围的极端值
- 如何在rails中使用数据范围选择器有任何可用的选项
