用php和socket.io通知系统

我试图用php和socket.io建立一个通知系统。这个想法是，客户端连接到socket.io并等待通知。 PHP脚本通过另一个端口上的curl连接到socket.io，并将更新发布到连接的客户端。客户端通过他们在连接事件后发送消息的标识进行标识。我存储与user_id关联的套接字变量。一切正常，但一段时间后脚本停止工作。看起来，在一段时间后，存储在数组中的套接字变量。但是我的服务器代码下面贴用php和socket.io通知系统

var notification_port = 8001; 
var oak_port   = 8002; 

var io = require('socket.io').listen(notification_port); 
var clients = new Array(); 

io.sockets.on("connection", function(socket){ 
    socket.on("__identification", function(message){ 
     if (message.id){ 
     console.log("user with session id " + message.id + " connected!"); 
     var sockets = clients[message.id]; 
     if (!sockets){ 
      sockets = new Array(); 
     } 
     sockets.push(socket); 
     clients[message.id] = sockets; 
     } 
    }); 
}); 

var url = require('url'); 
var oakListener = require('http').createServer(function (req, res) { 
    res.writeHead(200, {'Content-Type': 'text/plain'}); 

    var url_parts = url.parse(req.url, true); 
    var query = url_parts.query; 

    var sockets = clients[query.id]; 
    if (sockets){ 
    for (var i = 0; i < sockets.length; i++){ 
     sockets[i].emit("notification", query); 
     } 
     res.end('ok'); 
    } else { 
    res.end('failed'); 
    } 
}).listen(oak_port);

来源

2012-03-07 user1254343

的问题是，该连接丢失大约每分钟。您必须在“断开”功能中收集gargabe并重新初始化“连接”功能中的连接

来源

2012-04-22 14:53:19 user1254343

你必须添加一个处理断开喜欢解释如下：

socket.on('disconnect', function() { 
    //delete socket from sockets; 
});

来源

2012-04-19 00:53:23 Ciprian

用php和socket.io通知系统

回答

相关问题