什么是在NodeJ中处理Mongodb全局连接的最佳方法

Question

我使用Node-Mongo-Native并尝试设置全局连接变量，但是我对两种可能的解决方案感到困惑。你们可以帮我选哪一个是好人吗？1.解决方案（这很糟糕，因为每个请求都将尝试创建新的连接。）

var express = require('express');  
var app = express();  
var MongoClient = require('mongodb').MongoClient;  
var assert = require('assert');

// Connection URL
var url = '[connectionString]]';

// start server on port 3000
app.listen(3000, '0.0.0.0', function() {  
  // print a message when the server starts listening
  console.log("server starting");
});

// Use connect method to connect to the server when the page is requested
app.get('/', function(request, response) {  
  MongoClient.connect(url, function(err, db) {
    assert.equal(null, err);
    db.listCollections({}).toArray(function(err, collections) {
        assert.equal(null, err);
        collections.forEach(function(collection) {
            console.log(collection);
        });
        db.close();
    })
    response.send('Connected - see console for a list of available collections');
  });
});

1. 解决方案（在应用程序初始化时进行连接并将连接字符串分配给全局变量）。但我认为将连接字符串分配给全局变量不是一个好主意。

var mongodb; var url =’[connectionString]’;
MongoClient.connect（url，function（err，db）{
assert.equal（null，err）; mongodb = db;}）;

我想在应用初始化时创建一个连接，并在整个应用生命周期内使用它。

你们能帮我吗？谢谢。

Answer 1

创建一个Connection类来管理apps数据库连接。

MongoClient不提供单例连接池，因此您不想MongoClient.connect()在应用程序中重复调用。包裹mongo客户端的单例类适用于我见过的大多数应用程序。

const MongoClient = require('mongodb').MongoClient

class Connection {
    static connectToMongo() {
        if ( this.db ) return Promise.resolve(this.db)
        return MongoClient.connect(this.url, this.options)
            .then(db => this.db = db)
    }

    // or in the new async world
    static async connectToMongo() {
        if (this.db) return this.db
        this.db = await MongoClient.connect(this.url, this.options)
        return this.db
    }
}

Connection.db = null
Connection.url = 'mongodb://127.0.0.1:27017/test_db'
Connection.options = {
    bufferMaxEntries:   0,
    reconnectTries:     5000,
    useNewUrlParser:    true,
    useUnifiedTopology: true,
}

module.exports = { Connection }

require('./Connection')该Connection.connectToMongo()方法在您的任何地方都可用，Connection.db如果属性已初始化，则该方法也将可用。

const router = require('express').Router()
const { Connection } = require('../lib/Connection.js')

// Better if this goes in your server setup somewhere and waited for.
Connection.connectToMongo()

router.get('/files', (req, res) => {
   Connection.db.collection('files').find({})
     .then(files => res.json({ files: files })
     .catch(err => res.json({ error: err })
})

module.exports = router