2011-12-31 4 views
3

以下のソケットサーバーは3〜4日間正常に動作しますが、指定したCPU範囲(160)を超えていることがMuninから通知されます。記憶のように私に聞こえる音は自由ではありません:正しく、しかしどこで見つけることができませんか?高CPUを使用しているSocket.ioノードサーバー

var io = require('socket.io').listen(80); 
var Memcached = require('memcached'); 
var md5 = require('MD5'); 
var memcached = new Memcached(['IP']); 
var interval_time = 5000; 

loglevel = process.argv[2]; 
if(loglevel == "") loglevel = 1; 

io.enable('browser client minification'); // send minified client 
io.enable('browser client etag');   // apply etag caching logic based on version number 
io.enable('browser client gzip');   // gzip the file 

io.sockets.on('connection', function (socket) 
{ 
    socket.on('get_notifications', function (data) 
    { 
     // verify authorization 
     if(data.key == 'XXXXXXX') 
     { 
      socket.user_id = data.user_id; 

      setInterval(function() 
      { 
       memcached.get(["ntf_" + socket.user_id, "nnt_" + socket.user_id], function(error, mem_result) 
       { 
        num_orders = mem_result['ntf_' + socket.user_id]; 
        is_searching = mem_result['nnt_' + socket.user_id]; 

        if(typeof(socket.prev_notification)==='undefined') socket.prev_notification = {}; 

        var notification = socket.prev_notification; 
        var have_new_notifications = false; 

        if(is_searching != socket.prev_notification.nnt) 
        { 
         have_new_notifications = true; 
         notification.nnt = is_searching; 
        } 

        if(num_orders != socket.prev_notification.ntf) 
        { 
         have_new_notifications = true; 
         notification.ntf = num_orders; 
        } 

        if(have_new_notifications) 
        { 
         var today=new Date(); 
         var h=today.getHours(); 
         var m=today.getMinutes(); 
         var s=today.getSeconds(); 

         console.log(h+":"+m+":"+s+' - sending notification to ' + data.user_id); 
         console.log(notification); 

         socket.emit('notifications', notification); 
         socket.prev_notification = notification; 
        } 
       }); 
      }, interval_time); // interval 
     } 
    }); 
}); 

答えて

2

私はこの問題は、あなたがget_notificationイベントが起動されるたびにsetInterval解雇ということだと思います。これらの間隔は、開始しても決して機能しなくなります。

特定の条件が満たされたときにこれらの間隔を停止するコードを書く必要があります(タイムアウト?クライアントの切断など)。または、例外がスローされない限り(たとえば、切断されたクライアントにデータを送信できない場合など)、自身を起動するsetIntervalsetTimeoutを変更します。

+0

ああ、私は「時間切れ」に変更して数日後に戻ってきます。ありがとう:) – Christoffer

+0

これは私の問題を解決:) – Christoffer