Node.js中MongoDB Find函数无响应问题求助

尝试使用Node.js从MongoDB集合中查询数据，但功能完全无法运行：既无报错信息，也无错误结果，没有任何响应。已确认所有变量值均正确，当前集合为空，但根据MongoDB文档，此时应返回空数组。

原代码：

const mongo = require("mongodb").MongoClient
const mongoURL = "mongodb://127.0.0.1:27017"

module.exports = function (app) {
    app.route("/fetchplayer").get(fetchPlayer)
}

async function fetchPlayer(request, response) {
    const mongoClient = await mongo.connect(mongoURL)
    const project = request.query.project
    const id = request.query.id

    const playersDB = mongoClient.db("RopePlayers")
    const playersCollection = playersDB.collection(project)

    const query = { "player" : id}

    playersCollection.find(query).toArray(function (error, result) {
        if (error) throw error

        console.log(result)
    })

}

问题根源 #

• 未返回HTTP响应：处理完数据库查询后，没有调用response.send()或response.json()等方法，客户端一直处于等待状态，因此看不到任何反馈。
• 混合异步风格：外层用了async/await，但toArray用了回调函数，回调内的throw error无法被外层捕获，出现错误时程序崩溃但客户端收不到提示。
• 未关闭数据库连接：查询完成后未关闭MongoDB客户端，会造成连接泄漏。
• 缺少连接错误处理：await mongo.connect(mongoURL)未包裹在错误捕获块中，连接失败时会直接抛出未捕获错误，导致服务崩溃且无日志提示。

修复后的代码 #

const mongo = require("mongodb").MongoClient
const mongoURL = "mongodb://127.0.0.1:27017"

module.exports = function (app) {
    app.route("/fetchplayer").get(fetchPlayer)
}

async function fetchPlayer(request, response) {
    let mongoClient;
    try {
        // 建立连接并捕获连接错误
        mongoClient = await mongo.connect(mongoURL)
        const project = request.query.project
        const id = request.query.id

        const playersDB = mongoClient.db("RopePlayers")
        const playersCollection = playersDB.collection(project)

        const query = { "player": id }

        // 使用await替代回调，保持异步风格统一
        const result = await playersCollection.find(query).toArray()
        console.log(result)
        // 向客户端返回结果，空集合时返回空数组
        response.json(result)
    } catch (error) {
        // 捕获所有错误并返回给客户端
        console.error("查询失败:", error)
        response.status(500).json({ error: error.message })
    } finally {
        // 无论成败，关闭数据库连接
        if (mongoClient) {
            await mongoClient.close()
        }
    }
}

修复说明 #

• 添加HTTP响应：通过response.json(result)返回查询结果，空集合时会返回[]，客户端能立即收到反馈；错误场景下返回500状态码和错误信息。
• 统一异步处理：用await替代toArray的回调，让所有异步操作的错误都能被try/catch捕获，代码逻辑更连贯。
• 错误捕获与处理：用try/catch包裹所有可能出错的异步操作，避免程序无提示崩溃，同时向客户端明确反馈错误原因。
• 关闭数据库连接：在finally块中关闭客户端连接，防止连接资源泄漏。

内容的提问来源于stack exchange，提问作者Crann Moroney