Node.js后端音乐播放器/explore/albums接口实现问题求助

问题根源 #

1. Array.map中使用async函数时，会返回一个Promise数组，而非处理完成的专辑对象数组。原代码直接将这个Promise数组返回给前端，此时所有异步查询还未完成，导致返回结果不符合预期（空数组或Promise对象）。
2. 字段名拼写错误：numberOfSongse应为numberOfSongs。
3. 用find().length统计歌曲数量效率低下，应改用countDocuments直接统计，减少数据传输开销。

基础修复方案（适合小数据量场景） #

通过Promise.all等待所有异步统计操作完成，确保返回的是处理后的完整数据：

Router.route("/explore/albums")
    .get(async (req, res) => {
        try {
            // 获取所有专辑的普通JS对象（lean()避免Mongoose文档对象限制）
            const albums = await _Albums.find().lean();
            
            // 等待所有歌曲数量统计完成，生成带数量的专辑数组
            const albumsWithSongCount = await Promise.all(albums.map(async (album) => {
                // 直接统计对应专辑的歌曲数量，比find后取length更高效
                const numberOfSongs = await _Songs.countDocuments({ album: album.name });
                // 返回包含歌曲数量的新对象，避免修改原数据
                return {
                    ...album,
                    numberOfSongs
                };
            }));
            
            res.json(albumsWithSongCount);
        } catch (e) {
            console.error(e);
            // 给前端返回错误状态码和信息，避免无响应
            res.status(500).json({ error: '服务器内部错误' });
        }
    })

高性能优化方案（适合大数据量场景） #

使用MongoDB聚合查询，通过$lookup关联专辑与歌曲集合，一次数据库请求完成所有数据查询和统计，大幅减少IO开销：

Router.route("/explore/albums")
    .get(async (req, res) => {
        try {
            const albumsWithSongCount = await _Albums.aggregate([
                // 关联歌曲集合，匹配专辑名称对应的所有歌曲
                {
                    $lookup: {
                        from: 'songs', // 注意这里是MongoDB中的歌曲集合名称（非模型名）
                        localField: 'name', // 专辑集合的关联字段
                        foreignField: 'album', // 歌曲集合的关联字段
                        as: 'tempSongs' // 临时存储匹配到的歌曲数组
                    }
                },
                // 添加歌曲数字段，计算临时数组的长度
                {
                    $addFields: {
                        numberOfSongs: { $size: '$tempSongs' }
                    }
                },
                // 移除临时歌曲数组，只保留需要的字段
                {
                    $project: {
                        tempSongs: 0
                    }
                }
            ]);
            
            res.json(albumsWithSongCount);
        } catch (e) {
            console.error(e);
            res.status(500).json({ error: '服务器内部错误' });
        }
    })

方案对比 #

• 基础方案逻辑简单、易维护，适合专辑数量较少的场景。
• 聚合查询方案性能更优，仅需一次数据库请求，适合数据量较大的生产环境。

内容的提问来源于stack exchange，提问作者ali fallah