mongodb 连接如何处理 NodeJS express 服务器中的并发请求?

use*_*751 5 mongoose mongodb node.js express mean-stack

我是 mongoDB 的新手,目前正在使用 Node express 服务器进行设置。我想知道如何使用 mongoose 驱动程序模块管理对 mongodb 的并发请求以读取集合数据。

例如:

如果一次有 100 个用户访问我的服务器(http://xxxxxx.com/showusers),那么 express 服务器中的 mongodb 连接将如何工作?它是单个连接还是拆分为 100 个连接,每个请求一个连接?

操作后如何高效关闭mongodb中的连接对象?或者我们可以像下面的代码一样将连接保留在快速服务器中吗?

下面是我的代码..

服务器.js

var express = require('express');

var app = express();
app.set('port', config.port);



  app.get('/users',storeusersapi.showUsers);

  app.get('/storeUser',storeusersapi._insertUserDetails);

  app.get('/findUser/:email',storeusersapi._findUser);

app.listen(app.get('port'),function(){
   log.info('Express app started on port ' + app.get('port'));
});
Run Code Online (Sandbox Code Playgroud)

storeusersapi.js

    var mongoose = require('mongoose');
    var log = require('../config/logger');

// Mongoose connection to MongoDB (ted/ted is readonly)
mongoose.connect('mongodb://localhost/mydb', function (error) {
if (error) {
    log.error("MongoDB Connection failure - " +error);
}else{
    log.info('MongoDB is connected Successfully!!!');
}
});

// Mongoose Schema definition
var Schema = mongoose.Schema;
var UserSchema = new Schema({
first_name: String,
last_name: String,
email: String
});

// Mongoose Model definition
var User = mongoose.model('users', UserSchema);

exports.showUsers = function(req,res){
User.find({}, function (err, docs) {
    res.json(docs);
});
};

exports._insertUserDetails = function(req,res){
   var object = new User({first_name:'bob',last_name:'sel',email:'sel@xxxxx.com'});

object.save(function (err) {
    if (err) {
        log.error('Insertion error - '+ err);
    }
    else {
        log.info("User Stored into database!!!");
    }
});




};

exports._findUser = function(req,res){
User.find({ email: req.params.email }, function (err, docs) {
    res.json(docs);
});

};
Run Code Online (Sandbox Code Playgroud)

tni*_*ada 0

我已经分别回答了你的两个问题。

1. Express服务器中的mongodb连接如何工作?

一旦创建了与 mongodb 数据库的连接(使用 mongoose 或任何其他框架),它将创建一个连接池。(Mongoose 默认池大小为 5,在 python 中为 100)创建的连接池由驱动程序维护,因此当需要连接到数据库时可以重用这些连接。

最佳实践是为整个应用程序仅创建一次新连接。创建连接后,连接对象将用作单例。当您使用 mongoose 模型连接到数据库时,将从创建的连接池中分配单独的连接。

如果您每次都创建一个新连接,那么它将导致连接流失。

2. 操作完成后如何高效关闭mongodb中的连接对象?

我对这个答案并不确定100%。我的建议是当express应用程序退出时断开连接。

var db = mongoose.connect('mongodb://localhost:27017/database');    
db.disconnect();
Run Code Online (Sandbox Code Playgroud)

据我所知,您在代码中所做的事情是正确的。您仅创建了一次新连接。由于连接池是用它创建的,因此您不需要创建更多连接。

请通过此链接清楚地了解连接池及其用法。 https://dzone.com/articles/deep-dive-connection-pooling