node.js：如何返回回调函数的值？

Question

我有以下代码（不能按预期工作）：

var express = require('express')
var app = express()
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/interviews';

app.get('/', function(req, res){
    var result = get_document(res);
    res.send( result // show the results of get document in the browser //)
    console.log("end");
});

app.listen(3000, function(req, res) {
    console.log("Listening on port 3000");
});

function get_document() {
  MongoClient.connect(url, function(err, db) {
    var col = db.collection('myinterviews');
    var data = col.find().toArray(function(err, docs) {
      db.close();
      return docs[0].name.toString(); // returns to the function that calls the callback
    });
  });
}

函数“get_document”应该返回存储在“myinterviews”集合中的文档。问题是'return docs [0] ...'行返回到col.find（这是调用回调的函数）而不是app.get（...）中的变量'result'。

你知道如何让文档返回'result'变量吗？

Answer 1

你应该看看promise api。

“get_document”函数应该返回一个新的承诺，带有解决和拒绝函数回调（成功/失败）。

所以，它应该看起来有点像这样：

var express = require('express')
var app = express()
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/interviews';

app.get('/', function(req, res){
var result = get_document(res).then(function (doc) {
  res.send( doc);
});
 // show the results of get document in the browser //)
console.log("end");
});

app.listen(3000, function(req, res) {
    console.log("Listening on port 3000");
});

function get_document() {

  return new Promise(

     function (resolve, reject)
       MongoClient.connect(url, function(err, db) {
       var col = db.collection('myinterviews');
       var data = col.find().toArray(function(err, docs) {
        db.close();
        resolve(docs[0].name.toString()); // returns to the function that calls the callback
    });
  });
  );
}

Answer 2

您的get_document 函数异步运行。对MongoClient.connect() 的调用可能需要一些时间，因此无法立即返回。要从数据库调用中返回您所追求的值，您必须将回调传递给 get_document 函数。所以它应该看起来像这样：

var express = require('express')
var app = express()
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/interviews';

app.get('/', function(req, res){
    var result = get_document(function(result) {
        res.send(result);
        console.log("end");
    });
});

app.listen(3000, function(req, res) {
    console.log("Listening on port 3000");
});

function get_document(done) {
  MongoClient.connect(url, function(err, db) {
    var col = db.collection('myinterviews');
    var data = col.find().toArray(function(err, docs) {
      db.close();
      done(docs[0].name.toString()); // returns to the function that calls the callback
    });
  });
}