刚学习nodejs的异步写法，请教一个问题
发布于 5天前 作者 vip1232 318 次浏览 来自 问答

我想执行2条数据库查询操作connection.query(selectSQL, function (err, re) {});，想在得到这两次查询结果后给客户端发送结果。现在的问题是查询方法都是异步的，不知道哪次查询先完成，哪次后完成。那么我需要怎么确认这两次查询都已经执行完，然后合并这两条查询结果再发送出去呢？

10 回复

可以把第二条查询放在第一条查询的回调里，然后在第二条查询的回调中发送查询结果。手机码字，不上代码了。 自豪地采用 CNodeJS ionic

用 async 模块

如果两个操作前后有关联，可以参考@x-web 的回答，简单些；一般可以使用一些库，执行并行或串行操作，并在所有操作完成之后，发送最终结果，比如@leapon 说的async，还有eventproxy啦，q啦，bluebird啦，等等。当然，也可以用简单的计数器实现（维护一个count = 0，两次操作回调都调用count++，如果count === 2，那么表示两次操作都完成，取最终结果即可，单线程，不用担心线程竞争啥的）

async

async.parallel

采用es6原生的promise写法：

    var promise1 = new Promise(function(resolve, reject){
        connection.query(selectSQL, function (err, re) {
            resolve(re);
        });
    });
    var promise2 = new Promise(function(resolve, reject){
        connection.query(selectSQL, function (err, re) {
            resolve(re);
        });
    });
    Promise.all([promise1, promise2]).then(function(result){
        // result[0]:第一个查询的结果
        // result[1]:第二个查询的结果
    });

@huangshaohui 看了下ES6 的新特性确实挺强的！

eventproxy

https://github.com/JacksonTian/eventproxy

其实方法很多。用async库/用6楼提供的方法也可以/用co库也可以。

co库的例子你可以参考下： 链接地址

'use strict';

co(function *() {
  let user = yield User.findOne({_id: id}).populate('posts').exec();
  let post = yield Post.find(user).populate(XXX).exec();
  let video = yield Video.find(post).populate(XXX).exec();

  // 这里你可以处理user,post,video
  res.render({
    user: user,
    post: post,
    video: video
  })
}).catch(function (err) {
  console.error(err.stack);
});
回到顶部