每一秒都会抛出:MongoError:拓扑被破坏了

问题描述 投票:0回答:1

我正在构建一个REST API,但每次第二次加载我的网站时都会遇到MongoError:拓扑已被破坏。有人可以帮我解决这个问题吗?我觉得异步运行有问题。

const client = new MongoClient(apiconfig.mongoUrl, {
    useNewUrlParser: true
});

app.get("/api/:object", (req, res) => {
    mongodb(req.params["object"], async (collection: Collection) => {
        if (collection !== undefined) {
            let result = await collection.find().toArray();
            res.send(result);
        }
        else {
            res.sendStatus(404);
        }
    });
});

const mongodb = (coll: string, operation: (collection: Collection) => Promise<void>) => {
    client.connect((err) => {
        const db = client.db("VaorraJS");
        db.collections().then((collections) => {
            operation(collections.find((collection) => collection.collectionName === coll)).then(() => {
                client.close();
            });
        }).catch((error) => {
            console.log("ERROR: " + error);
        });
    });
}

app.listen(5000);
javascript node.js mongodb typescript express
1个回答
1
投票

我建议使用Mongoose

您正在为每个请求创建数据库连接,这不是正确的方法

const MongoClient = require('mongodb').MongoClient;
// Connection URL
const url = 'mongodb://localhost:27017';

// Database Name
const dbName = '<some db>';

// Use connect method to connect to the server
let db;
MongoClient.connect(url, function (err, client) {
    assert.equal(null, err);
    console.log("Connected successfully to server");
    db = client.db(dbName);
});


app.get("/api/:object", async(req, res) => {
    const collection = db.collection(req.params["object"]);
    let result = await collection.find().toArray();
    res.send(result);
});
© www.soinside.com 2019 - 2024. All rights reserved.