Node.js,等待所有 Redis 查询完成,然后再继续执行



我需要遍历一个值数组,在 Redis 中查找日期(查看它是否存在),然后继续。例如:

var to_check = [ 1, 2, 3 ]
var found_elements = []
for (var i = 0; i < to_check.length; i++) {
  redis.EXISTS('namespace:' + to_check.length[i], function(err, value) {
    if (!err && value) {
      found_elements.push(to_check.length[i])
    }
  })
}
console.log(found_elements.join(', '))

我需要在执行发送到 Redis 的所有回调后执行最后一行。解决这个问题的最佳方法是什么?

使用 Promise 处理复杂的异步操作。并行执行就是其中之一。

var to_check = [ 1, 2, 3 ];
var found_elements = [];
Promise.all(to_check.map(function(item){
    return new Promise(function(resolve,reject){
        redis.EXISTS('namespace:' + item, function(err, value) {
            if(err){
                return reject(err);
            }
            if (value) {
                found_elements.push(item);
            }
            resolve();
        })
    });
})).then(function(){
    console.log('All operations are done');
}).catch(function(err){
    console.log(err);
});

我相信还有其他方法。但这应该有效(未测试):

var to_check = [ 1, 2, 3 ]
var found_elements = []
for (var i = 0; i < to_check.length; i++) {
(function(i){
      redis.EXISTS('namespace:' + to_check.length[i], function(err, value) {
              if (!err && value) {
                     found_elements.push(to_check.length[i])
              }
              if(i == (to_check.length-1)){
                   console.log(found_elements.join(', '))
              }
      })
 })(i);
}

最新更新