[解決済み] ネイティブドライバとExpress.jsでMongoDBを使用する際に「トポロジーが破壊されました」と表示される件

質問

MongoDBからデータを取得する簡単なアプリケーションを実装しています。

const express = require('express')
const app = express()
const port = 3000

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');

const dbConnectionURL = 'mongodb://localhost:27017';
const dbName = 'todo';
const dbClient = new MongoClient(dbConnectionURL);

function findTodos(db, callback) {
    const collection = db.collection('todos');
    collection.find({}).toArray(function (err, todos) {
        assert.equal(err, null);
        console.log("Found the following records");
        console.log(todos)
        callback(todos);
    });
}

app.get('/', (req, res) => {
    dbClient.connect(function (err) {
        assert.equal(null, err);
        console.log("Connected successfully to server");

        const db = dbClient.db(dbName);

        findTodos(db, function(todosArr) {
            var todos = { todos: todosArr }
            res.send(todos)
            dbClient.close()
        });
    });
});

app.listen(port, () => console.log(`Example app listening on port ${port}!`))

基本的にオンラインチュートリアルからコピーペーストしたものです。最初にhttpリクエストで' http://localhost:3000/ は動作します。しかし、二度目は

todo-backend/node_modules/mongodb/lib/utils.js:132
    throw err;
    ^

AssertionError [ERR_ASSERTION]: 'MongoError: Topology was destroyed' == null
    at todo-backend/index.js:15:16
    at err (todo-backend/node_modules/mongodb/lib/utils.js:415:14)
    at executeCallback (todo-backend/node_modules/mongodb/lib/utils.js:404:25)
    at handleCallback (todo-backend/node_modules/mongodb/lib/utils.js:128:55)
    at cursor._endSession.cursor._endSession (todo-backend/node_modules/mongodb/lib/operations/cursor_ops.js:207:38)
    at ClientSession.endSession (todo-backend/node_modules/mongodb-core/lib/sessions.js:129:41)
    at Cursor._endSession (todo-backend/node_modules/mongodb-core/lib/cursor.js:189:13)
    at Cursor._endSession (todo-backend/node_modules/mongodb/lib/cursor.js:226:59)
    at cursor._next (todo-backend/node_modules/mongodb/lib/operations/cursor_ops.js:207:20)
    at initializeCursor (todo-backend/node_modules/mongodb-core/lib/cursor.js:766:16)

ネットで調べると、同じようなエラーが出ていますが、もっと複雑なことをやっている人がいます。私がやったことは、もっと基本的なことのようで、助けになるような変更の余地は見当たりません。

を削除すると dbClient.close() は動作しますが、MongoDBのログを見ると、接続数が常に増えていることがわかります。もちろん、フラグを導入して、すでに接続済みかどうかをチェックすることはできます。しかし、この質問では、根本的な原因を理解したいのです。

解決方法を教えてください。

これは、コードにアンチパターンが含まれているためです。新しいリクエストが来るたびに、新しいデータベース接続を開き、応答が送信された時点でその接続を閉じます。その後、閉じた接続を再利用しようとするため、2回目のリクエストで表示されるエラーメッセージが発生するのです。

必要なのは、グローバルな接続オブジェクトを使用して、アプリケーションの存続期間中に一度だけデータベースに接続し、そのグローバルオブジェクトを使用してデータベース操作を実行することです。

このグローバルオブジェクトを使うと、MongoDB ドライバがデータベースへの接続プールを適切に作成することができます。このプールは MongoDB ドライバが管理し、高価なコネクト/リコネクトパターンを避けることができます。

例えば

// listen on this port
const port = 3000

// global database client object
var client = null

// listen on the configured port once database connection is established
MongoClient.connect('mongodb://localhost:27017', { useNewUrlParser: true }, (err, res) => {
  assert.equal(null, err)
  client = res
  app.listen(port, () => console.log(`Example app listening on port ${port}!`))
})

// use the client global object for database operations
app.get('/', (req, res) => {
  db = req.query.db
  col = req.query.col
  client.db(db).collection(col).find({}).toArray((err, docs) => {
    assert.equal(null, err)
    res.send(JSON.stringify(docs))
  })
})

編集 をクリックすると、コメントにある質問に答えることができます。

毎回接続すると、前の接続を再利用しようとするのはなぜですか？

これは、元のコードでは dbClient はグローバルに定義されていました。そのため dbClient.close() が呼び出されると、グローバルな dbClient が閉じられた。その後、その dbClient オブジェクトが再利用されました。これは connect() は単一の接続ではなく、接続プールを作成し、一回の呼び出しで複数回呼び出されることは想定していませんでした。

を移動させると dbClient 変数がグローバルスコープから app.get() コンテキストで、HTTP エンドポイントを複数回呼び出してもエラーが発生しないことがわかると思います。 dbClient オブジェクトが毎回作成されます。

とはいえ、これはうまくいきますが、推奨されるパターンではありません。上に掲載したサンプルコードのようなパターンを使用する方が良いでしょう。