Node js，等待，直到从 MongoDB 获取所有数据

Question

我在 Node js 中遇到了异步函数和回调的问题。我需要获取我朋友的所有帖子并显示它。但是如果我在没有 setTimeout() 的情况下这样做，它只会返回部分数据。我如何在不设置 setTimeout 的情况下解决这个问题？当然，等待 5-6 或 10 秒来获取所有数据是很荒谬的。我也尝试过 Promises，但再次响应不完整。请问有人可以帮助我吗？

//Sending request with axios to Controller
axios.post(packages.proxy+'users/getFriendsPosts',{id: user_id},config)
    .then(res => {
        // Code for displaying result
    })


//User Controller
router.post("/getFriendsPosts", getFriendsPosts);


//Send request body to userService.js
function getFriendsPosts(req, res, next) {
    userService.getFriendsPosts(req.body, function(posts, user){
        res.json({posts,user});
    })
        .catch(err => next(err));
}


//userService.js
module.exports = {
    getFriendsPosts,
};


async function getFriendsPosts(user,callback){
    var arr = [];
    var array = [];
    MongoClient.connect(url, async function(errr, db) {
        if (errr) throw errr;
        var dbo = db.db("drone-x");
        //Find user
        dbo.collection("users").find({_id: ObjectId(user.id)}).toArray(async function(err, result) {
            if (err) throw err;
            result.forEach(async function(element, index) {
                if(element.friends.length != 0){
                    element.friends.forEach(async function(elem) {
                        //Find user's friends
                        dbo.collection("users").find({_id: ObjectId(elem.id)}).toArray(async function(error, res) {
                            if (error) throw error;
                            //push user's friends to arr
                            arr.push(res);
                            res.forEach(async function(elements) {
                                //Find user's friends posts
                                dbo.collection("posts").find({userId: elements._id.toString()}).toArray(async function(errors, results) {
                                    if (errors) throw errors;
                                    //push user's friends posts to array
                                    array.push(results);
                                    //callback results through setTimeout
                                    setTimeout(async function(){ await callback(array, arr); db.close(); }, 2000);

                                });
                            });

                        });
                    });
                }
                else
                {
                    await callback("0");
                }
            });
        });

    });
}

如果我不使用 setTimeout 函数，它只会返回 2-3 个数据，但使用 setTimeout，它会返回所有数据。如果数据会增加，那么我需要增加 setTimeout 时间。但这当然不是好主意。有人可以帮助我吗？

Answer 1

你应该在这段代码中使用 try catch

getFriendsPosts = async (user,callback) => {
    const arr = [];
    const array = [];
    const db = await MongoClient.connect(url);
    const dbo = db.db("drone-x");
    const results = await dbo.collection("users").find({_id: ObjectId(user.id)})
    const resultPromise =  _.map(results, async element => {
        const friends = _.get(element, 'friends', [])
        if(friends.length != 0) {
        const friendPromise =  _.map(friends, async friend => {
            const ress = await dbo.collection("users").find({_id: ObjectId(friend.id)})
            arr.push(ress);
            const resPromise = _.map(ress, async res => {
             const posts = await dbo.collection("posts").find({userId: res._id.toString()})
                const postPromise =  _.map(posts, post => {
                    array.push(post);
                })
              await Promise.all(postPromise)
            })
           await Promise.all(resPromise)
        })
       await Promise.all(friendPromise)
        } 
    })
   await Promise.all(resultPromise)
    return { arr , array }
}

我不建议这样做需要太多时间。对于长查询，您应该使用 mongoose 并使用聚合。