对 node.js、connect-mongo 的并行请求、会话被覆盖

在当前的项目（一种商店系统）中，我使用node.js快递JS and 连接 mongo作为会话存储。在客户端，我在启动时使用单个请求来创建一个新会话，然后向 Node.js 服务器发送多个并行请求。 当然，因为这些并行请求会更改会话，所以这些更改似乎会相互覆盖，尽管它们会更改会话的不同对象。

示例（所有 3 个请求同时开始）：

• 请求A将一些产品推送到数组req.session.productHist['abc']
• 请求 B 将产品推送至req.session.productHist['def']
• 请求 C 需要一些时间，但不会更改会话

因为请求 C 在请求 A 和 B 之后完成，但在它们完成之前开始，所以它似乎覆盖了session.productHist其值是请求 C 启动时保存的值 (null)。

我怎样才能解决这个问题？

Update:

一些带有控制台输出的示例代码：

var url = require('url'),
    express = require('express'),
    MongoStore = require('connect-mongo');

var aDay = 24*60*60*1000;

var app = express.createServer();

app.configure(function(){
  app.use(express.cookieParser());
  app.use(express.session({
    secret: "secret",
    store: new MongoStore({ db: 'lmsCache' }),
    maxAge: aDay
    })
  );
  app.use(express.methodOverride());    app.use(express.bodyParser());
  app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
  app.use(app.router);
  app.use(express.logger());
});


function sendStringified(req, res, data) {
    data = JSON.stringify(data);
    if (req.url_query.callback) { data = req.url_query.callback + "(" + data + ");"; }
    res.send(data);
}

function parseParams(req,res,next) {
  req.url_query = url.parse(req.url,true).query;
  next();
}

function doExpensiveStuff(req,res,next) {
  console.log("######################### init start");
  [...]
}


app.get('/init', parseParams, doExpensiveStuff, function(req,res) {
  console.log("init: session.productHist: " + JSON.stringify(req.session.productHist));
  console.log("######################### init end");
  sendStringified(req,res,null);
});


app.get('/products', parseParams, function(req,res) {

  console.log("######################### products "+req.url_query.category+" start");

  if(!req.session.productHist[req.url_query.category])
    req.session.productHist[req.url_query.category] = [];

  for(var i=0;i<2;i++) {
      req.session.productHist[req.url_query.category].push({ "id": new Date().toGMTString() }); 
  } 

  console.log("products: session.productHist: " + JSON.stringify(req.session.productHist));
  console.log("######################### products "+req.url_query.category+" end");
  sendStringified(req,res,[]);
});

app.get('/newSession', parseParams, function(req,res) {
  console.log("######################### newSession");
  req.session.productHist = {};
  sendStringified(req,res,true);
});  

app.listen(8080);  

time = new Date().toGMTString();  

console.log('Server starting at: ' + time);  

控制台日志：

服务器开始时间： 2011 年 12 月 15 日星期四 15:50:37 GMT

################### newSession
################### init start
################### products -1 start

产品：session.productHist：{“-1”：[{“id”：“2011年12月15日星期四15:50:40 GMT”}，{“id”：“2011年12月15日星期四15:50:40 GMT “}]}

################### products -1 end

初始化：session.productHist：{}

################### init end

[...]

################### products -1 start

产品：session.productHist：{“-1”：[{“id”：“2011年12月15日星期四15:50:53 GMT”}，{“id”：“2011年12月15日星期四15:50:53 GMT “}]}

################### products -1 end

我想我已经找到了这个棘手问题的答案。

来自Express.js http://expressjs.com/guide.html#session-support文档：

Properties on req.session are automatically saved on a response

简洁版本

当您设置会话变量时（req.session.my_var = value），它实际上并没有保存（在那个时刻），而是稍后（当您发送响应时，在您的情况下是当您这样做时）res.send）。这导致了你的问题。

长版

那么这到底是什么意思呢？

1. 您发出请求，然后获取会话变量（处于状态 A），然后对其执行某些操作（这需要一些时间）
2. 您发出另一个请求并获取会话变量（仍处于状态 A，因为尚未发送响应）并对其更改一些内容
3. 现在会话处理等已经完成，因此您可以发送 1) 中的响应，从而修改会话变量并将其带入状态 B
4. 在您发送 2) 的回复之后，“有趣”的部分就到了。现在您实际上并没有修改当前会话（已更新为状态 B），因为响应被延迟了，所以您实际上更改的是状态 A 中的会话，将其带入状态 C => 这意味着所有状态 B 的修改丢失了！