Boa tarde pessoal! Estou com problemas em uma api que esta abrindo muitas conexoes no mongoDB quando tem muitos acessos...Eu conecto atraves do mongoose quando a api sobe...Entao deveria "em teoria" abrir so uma conexao (ou 5 no maximo, que é o que esta configurado no parametro poolsize )... No meu ultimo teste de stress, coloquei em uma ferramenta chamada "jemiter" para simular varias conexoes...E abriu mais de 250 conexoes no mongo... Queria saber se tem algo a fazer pois esse numero esta bem alto.. Esse é o jeito que eu conecto...
let config = require('./config');
const mongoose = require('mongoose');
class mongoConnection {
async connect() {
return new Promise(function (resolve, reject) {
if (!config)
throw new Error('Unable to get database Config');
mongoose.config = config;
mongoose.Promise = global.Promise;
mongoose.connect(config, { poolSize: 5, useNewUrlParser: true, useUnifiedTopology: true, appname: "api1" });
let db = mongoose.connection;
db.on('error', function () {
reject(new CustomException('Não foi possivel conectar no Banco de Dados Mongo em: ' + config));
});
db.on('connected', function () {
console.log(`Conexão com o BD realizada com sucesso! Conexoes ativas: ${mongoose.connections.length}`);
resolve(mongoose);
});
process.on('SIGINT', function () {
mongoose.connection.close(function () {
process.exit(0);
});
});
});
}
async disconnect() {
console.log("Conexão com o BD fechada!");
mongoose.disconnect();
}
}
module.exports = mongoConnection;
e no index eu faço:
let conexao = new (require("./config/connection"));
moment = require('moment');
request = require('request');
const cors = require('cors');
const express = require("express");
const bodyParser = require('body-parser');
app = express();
require('dotenv').config({});
const jwtUtil = require("./utils/jwt");
//Middlewares
app.use(cors())
app.use(bodyParser.json());
let mongooseConn = conexao.connect()
.then(retornoBD => {
var SERVER_PORT = process.env.SERVER_PORT || 8080;
app.listen(SERVER_PORT, () => {
console.log(`Serviço iniciado: http://localhost:${SERVER_PORT}`);
});
})
.catch(erro => {
console.log(erro);
});
agradeço a ajuda!
Rafael