实现 node.js 回调以获取结果

Question

我是 node.js 的初学者，所以如果我的问题很愚蠢，请原谅。实际上我正在尝试从 mongodb 获取一些结果并打印它们，但我无法获得所需的输出。

代码：

MongoClient.connect(url,function(err,db){
               if(err) throw err;

            var list=()=>{
                var arr=[]
                var blQ={blocked_user:data.tag_search_mail} 

                 db.collection("block_list").find(blQ,{"_id":0}).toArray((err,res)=>{

                         for(let i=0;i<res.length;i++){
                             arr.push(res[i]["blocker"])
                         }

                   });  
                 return arr  
            }
            var showList=(callback)=>{
               callback()
            }
            console.log(showList(list))//It's giving undefined
          // I wonder how can I print the returned array

建议后我尝试了什么：

var list = (callback) => {
                var arr=[]

                    var blQ={blocked_user:data.tag_search_mail} 

                      db.collection("block_list").find(blQ,{"_id":0}).toArray((err,res)=>{

                              for(let i=0;i<res.length;i++){
                                  arr.push(res[i]["blocker"])
                              }
                              callback(arr);    
                        });  

            }

            list((arr) => {
                console.log(arr);
            })

Answer 1

建议您使用the node.js native interface for mongodb 内置的promise 接口，而不是手动回调。

如果您想将其放入一个函数中并返回结果并在完成后关闭数据库，那么您可以执行以下操作并从您的函数中返回一个调用者将使用的承诺。

function getBlocked(data) {
    let openDb;

    close() {
        if (openDb) {
            openDb.close().catch(err => {
                console.log("Error closing db: ", err);
            })
        }
    }

    return MongoClient.connect(url).then(db => {
        openDb = db;
        const blQ = {blocked_user:data.tag_search_mail};
        return db.collection("block_list").find(blQ,{"_id":0}).toArray();
    }).then(results => {
        let blocked = results.map(item => item.blocker);
        close();
        return blocked;     // make this the resolved value of the promise
    }).catch(err => {
        close();
        throw err;          // rethrow to keep the promise rejected
    })
}

// usage
getBlocked(data).then(blocked => {
    // use blocked array here
}).catch(err => {
    // handle error here
});

Answer 2

我建议使用 Mongoose，这是一个可以与 MongoDB 顺畅交互的 Node 模块。如果您有兴趣，这里是文档：http://mongoosejs.com/

但是，要回答您的问题...

您的代码目前的问题是showList 函数实际上并没有返回任何内容。这是你想要的：

var list = (callback) => {
    // query mongodb here
    callback(arr);
}

list((arr) => {
    console.log(arr);
});

list 接受一个函数，最终在完成对 MongoDB 的查询时调用该函数。它将传入arr 对象。因此，当您稍后调用list 时，您传入一个接收arr 对象的函数，然后调用console.log(arr) 来打印结果。祝你好运！

Answer 3

var list =() => {
let arr =[];
for(let a =0 ; a< 20; a++)
arr.push(a);
return arr;
}

var show = (callback) => {
return callback()}

console.log("123",show(list));

输出：：123 (20) [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16、17、18、19]

尝试在调用回调函数之前只添加一个return语句，并将列表函数的return语句添加到数据库块中。这可能会解决您的问题。

MongoClient.connect(url,function(err,db){
           if(err) throw err;

        var list=(done)=>{
            var arr=[]
            var blQ={blocked_user:data.tag_search_mail} 

             db.collection("block_list").find(blQ,{"_id":0}).toArray((err,res)=>{

                     for(let i=0;i<res.length;i++){
                         arr.push(res[i]["blocker"])
                     }
                if(err) done(err);
                else done(null,arr);
               });  

        }
        var showList=(callback)=>{
           callback((err, result) => {
            if(err) console.log(err);
            else console.log(result):
})
        }
        showList(list);