Node.js（Express+Mongoose）应用数据库连接的正确处理方案咨询

1. 当前连接方式是否为最佳实践？ #

你的基础连接逻辑是可行的，但可以优化为模块化的单例连接管理，既解耦代码，又能更精准控制连接行为。

优化后的实现可以抽成单独的db.js文件：

// db.js
const mongoose = require('mongoose');

const connectDB = async () => {
  try {
    await mongoose.connect('mongodb://localhost:27017/mydatabase', {
      useNewUrlParser: true,
      useUnifiedTopology: true,
      // 显式配置连接池参数（Mongoose默认启用，自定义更适配业务）
      maxPoolSize: 10,    // 连接池最大连接数
      minPoolSize: 2,     // 连接池最小空闲连接数
      maxIdleTimeMS: 30000 // 空闲连接超时释放时间
    });
    console.log('Connected to MongoDB');
  } catch (err) {
    console.error('MongoDB connection failed:', err.message);
    process.exit(1); // 连接失败直接退出进程，避免无意义运行
  }
};

module.exports = connectDB;

在server.js中引入并调用：

// server.js
const connectDB = require('./db');
const express = require('express');
const app = express();

// 先确保数据库连接成功，再启动服务
(async () => {
  await connectDB();
  app.listen(3000, () => {
    console.log('Server running on port 3000');
  });
})();

这种方式的优势：

• 代码解耦，便于后续维护和修改
• 用异步/await处理连接，逻辑更直观
• 显式配置连接池参数，避免默认值不匹配业务并发需求

2. 服务器停止时是否需要手动关闭连接？ #

需要手动关闭，尤其是在优雅停机场景下，避免数据库残留半开连接或占用资源。

可以通过监听Node.js的系统信号实现：

// server.js中添加优雅停机逻辑
process.on('SIGINT', async () => {
  console.log('\nShutting down gracefully...');
  await mongoose.connection.close();
  console.log('MongoDB connection closed');
  process.exit(0);
});

process.on('SIGTERM', async () => {
  console.log('\nSIGTERM received, shutting down...');
  await mongoose.connection.close();
  console.log('MongoDB connection closed');
  process.exit(0);
});

说明：

• SIGINT对应用户按下Ctrl+C触发的终止信号
• SIGTERM对应容器化部署（如Docker）或进程管理器发送的正常终止信号
• 先关闭数据库连接再退出进程，确保连接被正常释放

3. 连接错误处理与自动重连的最佳实践 #

Mongoose默认内置自动重连机制，但需要配合合理的配置和事件监听，避免无限重试浪费资源。

完善错误监听与重连逻辑 #

在db.js中补充事件监听：

// db.js
const mongoose = require('mongoose');

const connectDB = async () => {
  try {
    const conn = await mongoose.connect('mongodb://localhost:27017/mydatabase', {
      useNewUrlParser: true,
      useUnifiedTopology: true,
      maxPoolSize: 10,
      minPoolSize: 2,
      maxIdleTimeMS: 30000,
      serverSelectionTimeoutMS: 5000, // 服务器响应超时时间
      socketTimeoutMS: 45000 // Socket连接超时时间
    });

    // 监听连接断开事件
    conn.connection.on('disconnected', () => {
      console.log('MongoDB disconnected, waiting for reconnection...');
    });

    // 监听重连成功事件
    conn.connection.on('reconnected', () => {
      console.log('MongoDB reconnected successfully');
    });

    console.log('Connected to MongoDB');
  } catch (err) {
    console.error('MongoDB connection failed:', err.message);
    // 连接失败后延迟5秒重试，避免频繁请求耗尽资源
    setTimeout(connectDB, 5000);
  }
};

module.exports = connectDB;

关键配置说明 #

• serverSelectionTimeoutMS: 指定驱动等待服务器响应的超时时间，超时后触发错误
• socketTimeoutMS: 指定Socket连接的超时时间，避免长时间挂起的无效连接
• 捕获错误后延迟重连，防止短时间内频繁重试导致资源浪费

关于连接池的正确实现 #

Mongoose默认已启用连接池，无需额外复杂操作，只需通过配置参数调整即可：

• maxPoolSize: 根据业务并发量设置最大连接数（默认100）
• minPoolSize: 设置连接池保留的最小空闲连接数，减少连接创建销毁的开销
• maxIdleTimeMS: 设置空闲连接的超时时间，超时自动释放，避免资源占用

你无需手动管理连接的获取和释放，Mongoose会在执行查询、插入等操作时自动从连接池取连接，操作完成后自动归还。

内容的提问来源于stack exchange，提问作者CodebergIT Technology Works