MongoClient connect回调未执行，无法连接MongoDB求助

问题场景 #

学习MongoDB时，使用以下两个模块尝试连接数据库，但connect()方法内的回调函数从未执行，控制台无任何输出，无法触发dbConnection事件启动Express服务。

mongoConnect.js

import { MongoClient} from 'mongodb';
import {EventEmitter} from 'events';
const uri = "<MYCONNSTRING>";
const dbName = "test";

class MongoConnect extends EventEmitter{
    constructor(){
        super();
        this.mongoClient = new MongoClient(uri,{useUnifiedTopology:true});
    }
    connect() {
        this.mongoClient.connect((err,mongodb)=>{
            if(err) throw err;
            console.log('Connection to DB Established');
            MongoConnect.blogDatabase = mongodb.db(dbName);
            this.emit('dbConnection');
        })
    }
};
export default  MongoConnect;

App.js（主模块文件）

import express from 'express';
import MongoConnect from './mongoConnect.js';
const port = process.env.PORT || 3000;
const app = express();
const mongoConnect = new MongoConnect();

mongoConnect.on('dbConnection', ()=> {
    app.listen(port, ()=>{
        console.log(`server listening on port: ${port}`);
    });
});
mongoConnect.connect();

排查与修复步骤 #

1. 捕获并输出连接错误

异步回调中直接throw err会导致错误被静默吞噬（Node.js不会主动打印异步回调的未捕获错误），必须主动捕获并输出错误信息：
修改mongoConnect.js的connect方法：

connect() {
    this.mongoClient.connect((err,mongodb)=>{
        if(err) {
            console.error('数据库连接失败:', err);
            this.emit('dbError', err);
            return;
        }
        console.log('Connection to DB Established');
        MongoConnect.blogDatabase = mongodb.db(dbName);
        this.emit('dbConnection');
    })
}

同时在App.js中添加错误监听，确保能看到问题：

mongoConnect.on('dbError', (err) => {
    console.error('收到数据库连接错误:', err);
});

2. 验证连接字符串正确性

检查<MYCONNSTRING>是否符合要求：

• 本地MongoDB：格式应为mongodb://localhost:27017（默认端口27017）
• 远程集群（如MongoDB Atlas）：需使用mongodb+srv://开头的连接字符串，包含正确的用户名、密码、集群地址与认证参数
• 确认连接字符串中没有多余的空格或未替换的占位符

3. 检查网络与服务状态

• 本地MongoDB：确认服务已启动（可通过mongod命令或系统服务管理工具检查）
• 远程集群：确认你的IP已加入集群白名单，目标端口（27017或集群指定端口）未被防火墙/安全组拦截

4. 调整驱动配置与写法

useUnifiedTopology是MongoDB驱动旧版本的配置项，新版驱动（v4+）已默认启用相关逻辑，可尝试移除该配置，或改用更易调试的async/await写法：

// mongoConnect.js 修改为async/await版本
async connect() {
    try {
        await this.mongoClient.connect();
        console.log('Connection to DB Established');
        MongoConnect.blogDatabase = this.mongoClient.db(dbName);
        this.emit('dbConnection');
    } catch (err) {
        console.error('数据库连接失败:', err);
        this.emit('dbError', err);
    }
}

调用时无需修改App.js，async方法会返回Promise，但不影响事件触发逻辑。

5. 确认事件监听顺序

确保在调用connect()之前已经注册了dbConnection和dbError事件，你的现有代码顺序是正确的（先监听再调用连接），如果顺序颠倒会导致事件触发时没有监听器。

内容的提问来源于stack exchange，提问作者Riccardo De Contardi