使用 Promise 将异步函数的结果作为“变量”返回

Question

我在 NodeJS 中的异步执行时遇到问题。特别是，我有很多用例，我想在我的代码中稍后使用异步请求的结果，并且不想将整个内容包装在另一个缩进级别中，例如async.parallel。

我知道解决此问题的方法是使用 Promise，但我正在努力正确实施，而且我尝试过的资源没有帮助。

我目前的问题是： 我需要在插入 MongoDB 文档时立即获取它的_id。我已经从使用 MongoJS 切换到使用官方 MongoDB 驱动程序，因为我知道 MongoJS 不支持 Promise。任何人都可以通过提供如何使用承诺返回此值的基本示例来提供帮助吗？

再次感谢。

Answer 1

你可以使用 Promise.then() 的传统方法，或者如果你可以使用 ES6，尝试生成器函数（生成器直接包含在 Node 中，不需要运行时标志）。这样，您可以简单地编写以下代码：

//You can use yield only in generator functions
function*() {
    const newDocument = new Document({firstArg, SecondArg});
    const savedDocument = yield newDocument.save();
    //savedDocument contains the response from MongoDB

}

您可以阅读有关函数的更多信息* here

Answer 2

使用 node.js 驱动程序，使用集合的 insert() 方法，该方法返回一个承诺。以下示例演示了这一点：

var Db = require('mongodb').Db,
    MongoClient = require('mongodb').MongoClient,
    Server = require('mongodb').Server;   

var db = new Db('test', new Server('localhost', 27017));

// Fetch a collection to insert document into
db.open(function(err, db) {
    var collection = db.collection("post");

    // Create a function to return a promise
    function getPostPromise(post){
        return collection.insert(post);
    }

    // Create post to insert
    var post = { "title": "This is a test" },
        promise = getPostPromise(post); // Get the promise by calling the function

    // Use the promise to log the _id   
    promise.then(function(posts){
        console.log("Post added with _id " + posts[0]._id);    
    }).error(function(error){
        console.log(error);
    }).finally(function() {
        db.close();
    }); 
});

您还可以使用 Mongoose 的 save() 方法，因为它返回 Promise。一个基本的例子来证明这一点：

// test.js
var mongoose = require('mongoose'),
    Schema = mongoose.Schema;

// Establish a connection
mongoose.connect('mongodb://localhost/test', function(err) {
    if (err) { console.log(err) }
});

var postSchema = new Schema({
    "title": String
});

mongoose.model('Post', postSchema);

var Post = mongoose.model('Post');

function getPostPromise(postTitle){
    var p = new Post();
    p.title = postTitle;
    return p.save();
}

var promise = getPostPromise("This is a test");
promise.then(function(post){
    console.log("Post added with _id " + post._id);  
}).error(function(error){
    console.log(error);
});

运行应用程序

$ node test.js
Post added with _id 5696db8a049c1bb2ecaaa10f
$