2

我们昨晚为我们的一个活动设置了一个实时代码，我们遇到了严重的性能问题。Socket.io 无法为连接到超过 400 到 500 个客户端的 socket.io.js 提供服务。代码很简单，每隔几分钟只有一条消息会广播给所有客户端，所以我认为代码没有太大的改进空间。服务器的硬件不是最好的，但我们在股票代码正常运行期间监控进程，但没有一个是导致问题的原因。

您是否知道如何解决问题，或者至少还有什么可能是导致问题的原因。看起来 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
});
4

1 回答 1

5

很难说你遇到了什么瓶颈。几种可能性供您探索：

您可能已达到进程中打开文件句柄数量的限制。您的 linux 内核编译时配置了每个进程的最大文件句柄数（套接字连接使用文件句柄）。您可以通过运行“ulimit -a”查看（最大）打开文件限制。你可以在运行你的进程之前增加这个数字，只需谷歌“ulimit open files”。

另一个想法......在任何给定时间你最多有多少条消息？您正在执行数据库查询以检索每个新连接的所有这些。因此，如果连接数量急剧增加，您可能会执行相当多的查询来加载初始列表。作为一项实验，您无法执行初始“连接”查询以查看您的缩放比例如何提高。如果这有很大帮助，那么您可以轻松地将查询结果缓存在 javascript 变量中，而不是为每个连接都访问数据库。

一些有趣的阅读...

http://drewww.github.com/socket.io-benchmarking/

于 2012-11-25T13:25:30.137 回答