javascript - 使用 nodejs 和 redis 调用的多阶段自动完成。如何确保在完成所有操作后返回

Question

我正在研究一个自动完成的原型(prototype)。我看过网络上的几个自动完成简单列表的示例。我的业务案例是多步骤的，因为自动完成必须处理姓名相同但出生年份不同的人。

例子

用户类型:Geor

返回可能的完成:

• 乔治 1976 年 - 父亲:老乔治母亲:凯伦
• George 1980 - 父亲:Jack 母亲:Pam
• 乔治亚娜 1972 年 - 父亲:大卫 母亲:卡罗尔

所以我的 redis 调用有四个步骤:

• zrank 前缀 'GEOR'
  • > 4
• zrange 前缀 4 20
  • >格奥尔格
  • >乔治*
  • >格奥尔基
  • >格鲁吉亚
  • >格鲁吉亚
  • >乔治亚娜*
• (对于每个以 * 结尾的名称)
  • smembers "compnam:GEORGE"
    • > 'personid:10'
    • > 'personid:15'
  • smembers "compnam:GEORGIANA"
    • > 'personid:53'
• (每个人)
  • hgetall 'personid:10'
  • hgetall 'personid:15'
  • hgetall 'personid:53'

希望这足够清楚。

我正在尝试创建与此类似的输出:

 [ { name: 'George', yob: '1976', parentstr: 'Father: George Sr. Mother: Karen'},
 { name: 'George', yob: '1980', parentstr: 'Father: Jack Mother: Pam'},
 { name: 'Georgiana', yob: '1972', parentstr: 'Father: David Mother: Carol'}]

这是我的 nodejs 代码。

var app = express();
var client = redis.createClient();

app.get('/names/:name', function(req,res) {
  var name_search = req.params.name;

  client.zrank('prefix',name_search, function (err, obj){
    client.zrange('prefix',obj+1,20, function(err,obj){
      var returnNames = [];
      async.each(obj,function(item){
        if(item.slice(item.length-1)==='*'){
          client.smembers('compnam:'+item.slice(0,item.length-1),function(err,obj){
            async.each(obj,function(item){
              client.hgetall(item,function(err,obj) {
                Array.prototype.push.call(returnNames,obj);
                console.log(returnNames);
              })
            },
            function(err) {
              console.log("error with redis1:"+err);
            });
          });
        }
      }, function(err) {
           console.log("error with redis2");
      });
      console.log("Executed here before names added");
    });
  });
});

我对 Node.js 还是很陌生，所以我意识到我没有针对 Node.js 的异步特性正确地构建我的代码。任何帮助将不胜感激。

-edit- 抱歉不够清晰。是的，console.log("Executed here before names are added") 在其余工作完成之前执行。最终这将更改为 res.send(returnNames)。我需要一些帮助来重组代码，以便一切都在最后一个 console.log 之前完成，或者如果我需要将我的最后一个 console.log 放在其他地方的不同回调中。

Answer 1

您可以使用 promise ，一些伪代码 promise/A+ :

doSomethingAsynch().then(
  function(data){      //onfultill (when the asynch is done)
    doSometingElseAsynch();
  },
  function(error){//<--onreject this is optional
  }
 ).then(....

或者如果您只想一次“试一试”就可以得到所有东西

doSomethingAsynch(//<--error here "Illegal input"
  function(data){
   anotherAsynchThing();//<--this one isn't called because there is an error
  } //<-- no reject method specified
 ).then(
   function(data){//<--this one not called there WAS an error, (it propagates)
   anotherAsynchThing();
  } 
 ).then(
   function(data){//<--not called
   anotherAsynchThing();
  } 
 ).then(
   function(data){<--not called
   anotherAsynchThing();
  },
  function(error){//<--this one called with error"Illegal input"
    //handle error
  }
);

上述伪代码的好处在于，如果第一个方法会产生错误，那么除了最后一个方法之外，不会调用任何其他方法，因为它有一个拒绝方法。因此，如果第一个方法因“非法输入”而失败，并且因为只有最后一个 then 有一个失败方法；调用此方法时会出现错误“非法输入”。当您指定多个拒绝方法时，它们都会被调用，但会出现相同的错误。

不确定什么是 Node 的好 promise 库，但here是关于 promises 的一个很好的解释，也许是一个图书馆的建议。