在node.js中正确放置具有多个异步redis调用的回调

Nathan 发表于 Dev

内森

我正在使用node.js和redis构建作业队列系统，并试图找出如何最好地将回调实现到此函数中。

在代码中，我只是为了强调我所谈论的redis调用而将cb（）调用了3次。

显然，我可以嵌套三个调用（rpush-> sadd-> sadd），但是鉴于它们不相互依赖，这会破坏异步处理的目的，不是吗？

Queue.prototype.pushJob = function(job, cb) {
    var that = this;
    cb = cb || function(err, res) {};
    if (job.name) {
        that.Database.incr("id:jobs", function(id) { //Increment redis variable id:jobs
            that.Database.client.hmset('job:' + id, { //Callback of incr, set the hash of job:incr
                "name": job.name,
                "status": job.status,
                "payload": job.payload,
                "priority": job.priority
            }, function() { //Callback of hmset, add incr to jobs list
                that.Database.client.rpush('jobs', id, function(err, res) { //Add id to jobs array
                    cb(err, res); //Callback
                });

                that.Database.client.sadd('jobs.status.' + job.status, id, function(err, res) { //Add status to type array
                    cb(err, res); //Callback
                });

                that.Database.client.sadd('jobs.name.' + job.name, id, function(err, res) { //Add status to type array
                    cb(err, res); //Callback
                });
            });
        });
        return true;
    }
    console.log("Invalid data passed to Job");
    cb(null);
    return false;
};

真正的原因是这是我第一次使用redis，并且仍在努力使我的大脑围绕其某些功能。

为了让hmset，rpush和sadd函数知道它们要推送到哪个ID，它们必须位于incr调用的回调中，但是在那之后，我不确定构造代码的最佳方法是。任何帮助将不胜感激！

罗伯特克莱普

我认为最简单的方法是使用一个Multi对象：

that.Database.incr("id:jobs", function(id) { 
  var multi = that.Database.client.multi();
  multi.hmset('job:' + id, { ... });
  multi.rpush('jobs', id);
  multi.sadd('jobs.status.' + job.status, id);
  multi.sadd('jobs.name.' + job.name, id);
  multi.exec(cb);
  // or a bit less explicit:
  //
  // that.Database.client.multi()
  //                     .hmset('job:' + id, { ... })
  //                     .rpush('jobs', id)
  //                     .sadd('jobs.status.' + job.status, id)
  //                     .sadd('jobs.name.' + job.name, id)
  //                     .exec(cb);
});