2017-10-18 89 views
0

我有一个MEAN应用程序,可以很好地处理单个请求,比如说打电话给/api/products?pid=500。但我最近发现,在“爆发”的请求(我正在更新大约50个产品= 50个请求/api/products?pid=500 *** 550与发布数据),req.body有时得到一个新的即将到来的请求值。MEAN节点JS请求很多请求的性交

前的应用程序,使通话在选择产品的一个foreach:

ds.forEach((d, key) => { 
     this.ApiCall.setData('products', { action: 'send-product', data: d }) 
      .subscribe((result) => { 
       //we have results 
      }); 
     }); 
    //setData makes a http.post().map 

回到应用程序/平均分析后,试着合成代码:

router.route('/') 
.post(function (req, response) { 
    if(req.body.data){ 
     var obj = { id: req.body.data.product_id } 
     if(req.body.data.linked_products){ 
      req.body.data.linked_products.forEach(function(entry) { 
       obj.linked = entry; //more ifs 
      }); 
     } 
     var async = require('async'); 
     async.series({ 
      q2: function(cb){ 
       queryProducts.findOne({id: req.body.data.product_id, null).exec(cb); 
      }, 
      q3: function(cb){ 
       queryCategories.findOne({id: req.body.data.category_id, null).exec(cb); 
      } 
      }, function(err, qResults){ 

      var alreadysent = false; 
      if (qResults.q3) qResults.q3.logs.forEach(function(entry) { 
       if(entry.sent){ 
        alreadysent = true; 
       } 
      }); 
      //more ifs 
      qResults.q3.external_codes.forEach(function(entry) { 
       obj.external_code = entry;//more ifs 
      }); 
      if(req.body.data.price < 0){ 
       response.json({message: "Negative price didn't sent"}); 
       return; 
      } 
      if(qResults.q2.status=="inactive"){ 
       response.json({message: "Inactive didn't sent"}); 
       return; 
      } 
      req.body.data.campaigns(function(entry) { 
       obj.price_offers = entry;//more ifs 
      }); 
      //more ifs and foreach similar 
      queryProducts.update({id: req.body.data.id}, {$push: { synced_products: obj }}, function (err, result) { 
       //HERE I found req.body.data with values of a future request 

       if(!err) 
        response.json({message: "Sent"}); 
       return; 
      }); 
     }); 
    } 
}); 
module.exports = router; 

我明白,发出请求

/api/products?pid=500 
/api/products?pid=501 
/api/products?pid=502 
/api/products?pid=503 
... 

有不同的定时,但是如何可能的是,请求(PID = 501),调用最后一个req.body以获得req.body的新req(pid = 503)的值? 任何想法如何避免?在帖子后发送异步信息或制作一个

var reqbody = req.body 

谢谢!

+2

请用显示问题的[mcve]更新您的问题。引用的代码(如果我们假设在“post”调用中丢失了close paren和semi),应该不会有任何跨请求数据泄露的问题,所以其他地方正在发生某些事情。 –

+0

@ T.J。抱歉抱歉,更新了代码,谢谢! – Mihai

+0

尝试使用'let'而不是'var'。 – Sagar

回答

1

我相信这是由于async模块初始化。从node docs引用:

缓存

模块是他们第一次加载后缓存。这意味着(除其他外)每次调用require('foo')将得到完全相同的对象返回,如果它将解析为相同的文件。

多次调用require('foo')可能不会导致模块代码被多次执行。这是一个重要的功能。通过它,可以返回“部分完成”的对象,从而允许传递依赖被加载,即使它们会导致循环。

要让模块多次执行代码,请导出函数并调用该函数。

当一连串的请求导致重叠执行时,您将有两个(或更多)使用async变量被“并发”修改。我建议使用某种互斥来控制对变量async的访问。