使用Node.js异步请求在Redis中进行循环

Z时代
2024-01-10
分类：问答

我在使用redis和nodejs时遇到问题。我必须遍历电话号码列表，并检查我的Redis数据库中是否存在该号码。这是我的代码：

function getContactList(contacts, callback) {
  var contactList = {};
  for(var i = 0; i < contacts.length; i++) {
    var phoneNumber = contacts[i];
    if(utils.isValidNumber(phoneNumber)) {
      db.client().get(phoneNumber).then(function(reply) {
        console.log("before");
        contactList[phoneNumber] = reply;
      });
    }
  }
  console.log("after");
  callback(contactList);
};

“之后”控制台日志出现在“之前”控制台日志之前，并且回调始终返回一个empty

contactList。这是因为如果我很了解，对redis的请求是异步的。但问题是我不知道如何使它起作用。我能怎么做？

回答：

您有两个主要问题。

您的phoneNumber变量将不是您想要的变量。可以通过更改数组的.forEach()或.map()迭代来解决此问题，因为这将为当前变量创建局部函数作用域。

您已经创建了一种方法来知道所有异步操作何时完成。有很多重复的问题/答案显示了如何执行此操作。您可能要使用Promise.all()。

我建议这种解决方案利用您已经拥有的承诺：

function getContactList(contacts) {
    var contactList = {};
    return Promise.all(contacts.filter(utils.isValidNumber).map(function(phoneNumber) {
        return db.client().get(phoneNumber).then(function(reply) {
            // build custom object
            constactList[phoneNumber] = reply;
        });
    })).then(function() {
        // make contactList be the resolve value
        return contactList;
    });
}
getContactList.then(function(contactList) {
    // use the contactList here
}, funtion(err) {
    // process errors here
});