在nodejs中存储数据库查询（使用socket.io）

Question

我的代码有一个（可能是哑巴）问题。我有这样的事情：

io.sockets.on('connection', function(socket) 
{ 
    var list = {}; 

    socket.on('event', function(data){ 
     if(!list[data.field_name]){ 
      list[data.field_name] = []; 
      // db and collection already defined 
      var collection = new mongodb.Collection(db, coll); 
      collection.find({ 
       field: data.field_name, 
      }).toArray(function(err, results){ 
       list[data.field_name] = results[results.length-1]; 
       socket.emit('another-event',{ 
        list:list[data.field_name]; 
       }); 
      }); 
     } else { 
      socket.emit('another-event',{ 
       list:list[data.field_name]; 
      }); 
     } 

    }); 
} 

基本上，我想缓存在列表中的DB的结果，并直接发送（不分贝查询），如果它已经从数据库中检索较早。

我遇到的问题是，作业list[data.field_name] = results[results.length-1]不起作用。因此，如果之前尝试检索数据，则list[data.field_name]已初始化为[]，但它不包含之后分配给它的数据。

要清楚的是，它确实从数据库中检索数据，并在从数据库检索到数据时第一次将数据发送到客户端。当我尝试发送问题出现的缓存副本时 - 没有缓存副本。

我知道这是与nodejs（和mongodb查询）是异步的，但我似乎无法弄清楚如何使这项工作。任何帮助将不胜感激。

Answer 1

在对集合的查询完成之前，您正在发出another-event。如果在发射another-event时尚未检索到数据，则list[data.field_name]仍将为空。尝试像这样：

io.sockets.on('connection', function(socket) 
{ 
    var list = {}; 

    socket.on('event', function(data){ 
     var anotherEvent = function() { 
      socket.emit('another-event',{ 
       list:list[data.field_name]; 
      }); 
     }; 

     if(!list[data.field_name]){ 
      list[data.field_name] = []; 
      // db and collection already defined 
      var collection = new mongodb.Collection(db, coll); 
      collection.find({ 
       field: data.field_name, 
      }).toArray(function(err, results){ 
       list[data.field_name] = results[results.length-1]; 
       anotherEvent(); 
      }); 
     } else { 
      anotherEvent(); 
     } 
    }); 
}