昨夜のイベントの1つにライブティッカーを設定しましたが、深刻なパフォーマンスの問題が発生しました。Socket.ioは、400〜500を超えるクライアントが接続されているsocket.io.jsを提供できませんでした。ティッカーは非常にシンプルで、数分ごとに1つのメッセージがすべてのクライアントにブロードキャストされるため、コードに改善の余地はあまりないと思います。サーバーのハードウェアは最適ではありませんが、ティッカーの稼働時間中にプロセスを監視しており、いずれも問題を引き起こしていませんでした。
問題を解決する方法、または少なくとも他に何が原因である可能性があるかについて、何か考えがありますか。socket.ioは苦労していたようですが、ハードウェアの能力が不足しているためではありません。
サーバー構造
var io = require('socket.io').listen(443);
io.set('log level', 9);
//SQL CONNECTION
io.sockets.on('connection', function (socket) {
var sql_items = 'SELECT * FROM entries ORDER BY tstamp DESC';
db_query(sql_items , function(res_items) {
socket.emit('init', res_items);
});
socket.on('new_entry', function (data) {
//SECURE
if(!checkedSocketUsers[socket.id]) return false;
var currentTime = new Date();
if(currentTime.getMinutes() < 10);
var minutes = currentTime.getMinutes();
if(minutes < 10) minutes = "0" + minutes;
var hours = currentTime.getHours();
if(hours < 10) hours = "0" + hours;
var tstamp = currentTime.getTime() / 1000;
var time = hours + ":" + minutes;
sqli = "INSERT INTO entries (uid, tstamp, text, type) VALUES (null, "+tstamp+", '"+data.text+"', '"+data.type+"')";
client.query(sqli, function(err, info) {
var br_data = {};
br_data.time = time;
br_data.text = data.text;
br_data.uid = info.insertId;
br_data.type = data.type;
socket.broadcast.emit('broadcast_entry', br_data);
socket.emit('broadcast_entry', br_data);
});
});
socket.on('update_entry', function(data) {
//SECURE
if(!checkedSocketUsers[socket.id]) return false;
sqlu = "UPDATE entries SET text = '"+data.text+"' WHERE uid = "+data.uid;
client.query(sqlu, function(err, info) {
br_data = data;
socket.broadcast.emit('broadcast_update_entry', br_data);
});
});
socket.on('remove_entry', function(data) {
//SECURE
if(!checkedSocketUsers[socket.id]) return false;
var uid = data.uid;
sqld = "DELETE FROM entries WHERE uid = "+uid;
client.query(sqld, function(err, info) {
var br_data = {};
br_data.uid = uid;
socket.broadcast.emit('broadcast_remove_entry', br_data);
socket.emit('broadcast_remove_entry', br_data);
});
});
});
クライアントの構造
socket = io.connect("http://localhost:443");
socket.on('init', function(data) {
//DOM Manipulation
});
socket.on('broadcast_entry', function(data) {
//DOM Manipulation
});
socket.on('broadcast_remove_entry', function(data) {
//DOM Manipulation
});
socket.on('broadcast_update_entry', function(data) {
//DOM Manipulation
});