2017-06-04 169 views
0

我在节点休息api函数接收ajax调用id重新启动url链接....它的作品,当我调用这个Ajax函数5次...我打电话后6它不工作..使用console.log我看到该行停止获取请求,如果我再次调用它,我得到相同的日志...从url(url有效)获取请求...所以我看到请求模块没有返回,甚至任何错误或请求响应代码...这里是我的代码:NodeJS请求模块在6个Ajax请求后停止工作

apiRoutes.post('/restart_stream', function(req, res) { 
/* GET - token */ 
var token = req.headers['x-access-token']; 
    token = decrypt(token); 
    console.log('called.../restart_stream'); 

/* GET - data id */ 
var data  = {}; 
data.id  = req.body.id; 
data.type = req.body.type; 

    /* GET - connection */ 
    pool.getConnection(function(err,connection){ 
     if (err) { 
      connection.release(); 
      res.json({"code" : 100, "status" : "Error in connection database"}); 
      return; 
     } 

     /* GET - stream url */ 
     connection.query("SELECT id, channel, JSON_UNQUOTE(json_extract(stream, '$[0]')) AS stream_url FROM streams WHERE id=?", [data.id],function(err, rows, fields){ 
     console.log('getting request to...'+rows[0].stream_url); 
      /* GET - stream status */ 
      var r = request 
       .get(rows[0].stream_url) 
       .on('response', function(response) { 
        console.log('resoponse received....'+response.statusCode); 
        /* CHECK - stream exists */ 
        if (response.statusCode != 200 && response.statusCode != 302) { 
         r.end(); 
         /* RESET - live&streams info */ 
         res.json({"status": "false", "message": "FAILED to Restart <b>"+rows[0].channel+"</b>!"}); 
        } else { 
         /* RESET - live&streams info */ 
         connection.query("UPDATE streams SET uptime=?, status=? WHERE id=?",['0', '1', data.id], function(err) { 
          /* CHECK - error */ 
          if (err) { 
           res.json({"status": "false", "message": err.message}); 
          } else { 
           /* STOP - url my code here that is not executed after 6 ajax call */ 


           r.end(); 

           res.json({"status": "true", "message": "RESTARTED Successfully!"}); 
          }; 
         }); 
        }; 
       }) 
     }); 
    }); 
} else { 
    res.json({"status": "false", "message": "FAILED"}); 
}; 
}); 

我尝试使用r.end(),以便请求连接,每个响应,但要求模块停止后关闭5阿贾克斯后工作call..any线索我即时工作错了?

这是一个连接到URL,并得到响应码节点请求模块:

https://www.npmjs.com/package/request 
+0

我不知道这是否是这里的问题,但您不要在每个代码路径上调用'r.end',例如发生错误。顺便说一句,这是一个“厄运金字塔”的完美例子,我会考虑重组该计划。 –

+0

你有任何暗示或理论,我需要如何重组计划? – John

+0

您并不总是释放数据库连接,因此在某些时候池中将没有可用的连接,并且将开始等待连接被释放。 – robertklep

回答

0

我是今天的成功和解决问题......问题是,我已经使用旧版本的节点的JS(V0。 10.25)现在升级到v7.10.0和所有工作我做了100个请求,并且工作得很好...我也有巨大的加载页面,之前..所有节点js的新版本来与巨大的性能增加...