MEAN节点JS请求很多请求的性交

问题描述：

我有一个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

谢谢！

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

@ T.J。抱歉抱歉，更新了代码，谢谢！ – Mihai

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

答

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

缓存

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

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

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

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

MEAN节点JS请求很多请求的性交

相关推荐