带有php和socket.io的通知系统

我试图用php和socket.io构建一个通知系统。其想法是，客户端连接到socket.io并等待通知。一个PHP脚本通过另一个端口上的curl连接到socket.io，并发布更新，更新甚至会传递给连接的客户端。客户端通过在连接事件之后在消息中发送的id进行标识。I存储与user_id相关联的套接字变量。一切都很好，但过了一段时间脚本就停止工作了。似乎过了一段时间，存储在数组中的套接字变量。然而，我的服务器代码被张贴在下面

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);