关于mongoose结合promise的问题

问答

Jjimmyyao88发布于 11 年前最后回复 11 年前

13103890

最近被回调地狱弄的有点恶心所以准备用promise来优化一下 mongoose本身的exec方法会返回promise 比如: User.findOne({_id:id}).populate('posts').exec()本身就会返回promise . 但是我在最后的回调中想用到之前所哟回调里拿到的数据该怎么做呢比如：

	promise.then( function(user){
		//这里拿到了user
		return  Post.find(user).populate(XXX).exec( )
	} ).then(function(post){
		//这里拿到了post
		return Video.find(post).populate(XXX).exec()
	}).then(function(video){
	//在这里最后的回调中 想获得前面回调里面得到的user 和post   该怎么做呢？？
	res.render({
			user:user,
			post:post,
			video:video
		})
	})
`` 
最后的回调中 想获得前面回调里面得到的user 和post   该怎么做呢？？
尝试了一下bluebird 但是似乎不能用来写成Post.findAsync(user).populate(XXX).exec( )这种形式
怎么解决呢 求大神支招

查看回复

jimmyyao88#1311 年前

测试自豪地采用 CNodeJS ionic

pentium100#1211 年前

如果还用promise的话, 可以这么干 .

//增加一个result, 来hold住结果.
var result = {};
promise.then( function(user){
        //这里拿到了user
		result.user = user;
        return  Post.find(user).populate(XXX).exec( )
    } ).then(function(post){
        //这里拿到了post
		result.post = post;
        return Video.find(post).populate(XXX).exec()
    }).then(function(video){
    //在这里最后的回调中 想获得前面回调里面得到的user 和post   该怎么做呢？？
	 res.render({
            user:result.user,
            post:result.post,
            video:video
        })
    })

jimmyyao88#1111 年前

引用 hinson0你的代码我这么改造了下，你看看：

@hinson0 thanks!

hinson0#1011 年前

你的代码我这么改造了下，你看看：

'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);
});

```

hinson0#911 年前

一般promise都配合generator使用，会方便很多。如下代码，你参考下: 这里使用co库

'use strict';

let fs = require('fs');
let co = require('co');

function readFile(filename) {
  return new Promise(function (resolve, reject) {
    fs.readFile(filename, 'utf-8', function (err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      }
    });
  });
}

co(function *() {
  let file1 = yield readFile('./1.txt');
  let file2 = yield readFile('./2.txt');
  let file3 = yield readFile('./3.txt');

  // 这里处理file1, file2, file3
  console.log(file1);
  console.log(file2);
  console.log(file3);

}).catch(function (err) {
  console.error(err.stack);
});

自己实现了一个简易的co方法，仅供参考

'use strict';

let fs = require('fs');

function readFile(filename) {
  return new Promise(function (resolve, reject) {
    fs.readFile(filename, 'utf-8', function (err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      }
    });
  });
}

let gen = function *() {
  let file1 = yield readFile('./1.txt');
  let file2 = yield readFile('./2.txt');
  let file3 = yield readFile('./3.txt');

  // 这里处理file1, file2, file3
  console.log(file1);
  console.log(file2);
  console.log(file3);
}

function run(gen) {
  let iterator = gen();

  next(iterator.next());

  function next(result) {
    if (result.done) {
      return result.value;
    }
    return result.value.then(function (value) {
      next(iterator.next(value));
    });
  }
}

run(gen);