Node.js Express应用未记录MongoDB连接状态的修复方案

问题分析 #

从你的代码来看，核心问题大概率是MongoDB连接回调未被触发，或者连接请求处于无限等待状态（未设置超时）。虽然你使用了回调式的MongoClient.connect，但MongoDB 6.x版本对连接选项有默认行为，若未设置超时，连接请求可能一直挂起，既不触发成功回调也不输出错误日志。

修复步骤 #

1. 完善连接配置（添加超时选项）

修改config/connection.js，添加连接超时选项，确保连接请求能在超时后触发错误回调，同时优化地址解析：

const { MongoClient } = require('mongodb');
const state = {
    db: null
};

module.exports.connect = function(done) {
    const url = 'mongodb://127.0.0.1:27017'; // 改用127.0.0.1避免localhost解析异常
    const dbname = 'shopsy';
    // 添加6.x版本兼容的连接选项，设置5秒超时
    const options = {
        serverSelectionTimeoutMS: 5000,
        maxPoolSize: 10
    };

    MongoClient.connect(url, options, (err, client) => {
        if (err) {
            console.error('MongoDB连接失败:', err);
            return done(err);
        }
        state.db = client.db(dbname);
        done();
    });
};

module.exports.get = function() {
    return state.db;
};

2. 修正app.js中的日志输出（匹配预期）

更新app.js里的连接回调，输出你预期的文案，并确保错误日志更清晰：

// 连接数据库
db.connect((err) => {
    if (err) {
        console.error('MongoDB连接错误:', err);
    } else {
        console.log("MongoDB connected successfully"); // 匹配你的预期输出
    }
});

3. 额外排查点

• 检查MongoDB端口监听状态：
  • Linux/macOS: netstat -an | grep 27017
  • Windows: netstat -ano | findstr :27017
• 关闭本地防火墙或安全组，确认Node.js进程能访问27017端口
• 手动重启Node应用（或重启nodemon），确保代码修改生效

可选：改用现代的Async/Await方式 #

若想避免回调陷阱，可以改用Promise风格的连接代码，调试更直观：
修改config/connection.js：

const { MongoClient } = require('mongodb');
const state = {
    db: null
};

module.exports.connect = async function() {
    const url = 'mongodb://127.0.0.1:27017';
    const dbname = 'shopsy';
    const options = { serverSelectionTimeoutMS: 5000 };

    try {
        const client = await MongoClient.connect(url, options);
        state.db = client.db(dbname);
        console.log("MongoDB connected successfully");
    } catch (err) {
        console.error('MongoDB连接失败:', err);
        throw err;
    }
};

module.exports.get = function() {
    return state.db;
};

在app.js中调用：

// 连接数据库
(async () => {
    try {
        await db.connect();
    } catch (err) {
        console.error('数据库初始化失败:', err);
    }
})();

内容的提问来源于stack exchange，提问作者prajitha k