当node.js应用连接mongodb时，即使`mongod`显示“waiting for connections”，`client.connect()`可能看似无响应。这是因为现代node.js mongodb驱动的`connect`方法返回一个promise，而非接受回调函数。正确的方法是使用`async/await`或`.then()`来异步处理连接结果，确保连接成功并执行后续数据库操作。
mongodb服务启动与监听
在node.js应用尝试连接MongoDB之前，确保MongoDB数据库服务本身已正确启动并运行。通常，这通过在命令行执行mongod命令来完成。当mongod输出“waiting for connections on port 27017”或类似信息时，表示MongoDB服务已成功启动，并在默认端口（通常是27017）监听客户端连接。
示例：启动MongoDB服务
mongod
此命令将启动MongoDB数据库进程。请注意，mongod的“waiting for connections”状态仅表明服务已准备好接受连接，并不意味着客户端已成功连接。
node.js MongoDB驱动的连接机制
在Node.js环境中，我们使用官方的mongodb驱动程序来与MongoDB数据库进行交互。首先，确保已通过npm安装了该驱动：
npm install mongodb
在较新版本的mongodb Node.js驱动中（例如v4.x及更高版本，特别是v6.x），MongoClient.connect()方法不再接受回调函数作为参数。相反，它返回一个Promise对象。这意味着连接操作是异步的，并且结果（成功或失败）将通过这个Promise来传递。如果不对这个Promise进行处理，Node.js应用程序会继续执行后续代码，导致连接操作看起来“没有反应”或“卡住”。
正确建立MongoDB连接
为了正确处理MongoClient.connect()返回的Promise，我们可以采用两种主要的异步编程模式：async/await或.then()链式调用。
1. 使用 async/await (推荐)
async/await是现代javaScript中处理Promise的首选方式，它使异步代码看起来更像同步代码，提高了可读性和可维护性。
示例代码：使用 async/await 连接MongoDB
const { MongoClient } = require('mongodb'); // MongoDB连接URI，根据实际情况修改 const uri = 'mongodb://localhost:27017'; const client = new MongoClient(uri); // 创建MongoClient实例 const dbName = 'myDatabase'; // 替换为你的目标数据库名称 async function connectToMongoDB() { try { // 等待连接Promise解决 await client.connect(); console.log('? 成功连接到MongoDB！'); // 连接成功后，可以获取数据库实例并执行操作 const db = client.db(dbName); console.log(`已连接到数据库: ${dbName}`); // 示例：插入一条数据 const Collection = db.collection('users'); const result = await collection.insertOne({ name: 'Alice', age: 30 }); console.log('数据插入成功:', result.insertedId); // 示例：查询数据 const users = await collection.find({}).toArray(); console.log('所有用户:', users); } catch (error) { // 捕获连接或操作过程中的任何错误 console.error('❌ 连接MongoDB或执行操作失败:', error); } finally { // 确保在操作完成后或应用关闭时关闭连接 // 在生产环境中，通常会保持连接活跃，直到应用关闭 // client.close(); // console.log('MongoDB连接已关闭。'); } } // 调用异步函数启动连接过程 connectToMongoDB();
在这个例子中，await client.connect()会暂停函数的执行，直到MongoDB连接成功建立。一旦连接成功，控制台将输出“成功连接到MongoDB！”。
2. 使用 .then() 链式调用
如果你更熟悉Promise的链式调用，或者在不支持async/await的环境中，可以使用.then()和.catch()来处理Promise。
示例代码：使用 .then() 连接MongoDB
const { MongoClient } = require('mongodb'); const uri = 'mongodb://localhost:27017'; const client = new MongoClient(uri); const dbName = 'myDatabase'; client.connect() .then(() => { console.log('? 成功连接到MongoDB！'); const db = client.db(dbName); console.log(`已连接到数据库: ${dbName}`); // 在这里可以继续执行数据库操作，这些操作也返回Promise return db.collection('products').insertOne({ name: 'Laptop', price: 1200 }); }) .then(result => { console.log('产品插入成功:', result.insertedId); return client.db(dbName).collection('products').find({}).toArray(); }) .then(products => { console.log('所有产品:', products); }) .catch(error => { console.error('❌ 连接MongoDB或执行操作失败:', error); }) .finally(() => { // 同样，在应用生命周期结束时关闭连接 // client.close(); // console.log('MongoDB连接已关闭。'); });
这种方式通过.then()处理成功的连接和后续操作，通过.catch()统一处理任何错误。
后续数据库操作与连接管理
一旦client.connect()成功，你就可以通过client.db(dbName)方法获取到特定的数据库实例，然后通过db.collection(‘collectionName’)获取集合实例，进而执行各种增删改查操作。
重要提示： 所有的数据库操作（如insertOne, find, updateOne, deleteOne等）也都是异步的，并且同样返回Promise。因此，在执行这些操作时，也需要使用await或.then()来处理它们的异步结果。
注意事项
- 驱动版本兼容性：MongoDB Node.js驱动的API在不同版本之间可能存在差异。本教程基于较新版本（如v4.x及更高版本）。如果你使用的是旧版本，请查阅对应版本的官方文档。
- 错误处理：任何异步操作都可能失败。务必使用try…catch（对于async/await）或.catch()（对于.then()）来捕获并处理连接或操作过程中可能发生的错误，这对于构建健壮的应用程序至关重要。
- 连接字符串（URI）：确保你的MongoDB连接URI (mongodb://localhost:27017等) 是正确的。如果MongoDB服务运行在不同的主机或端口，或者需要认证，请相应地修改URI。
- 连接池管理：MongoClient默认实现了连接池。在大多数应用中，你只需要在应用程序启动时调用client.connect()一次，然后复用这个client实例进行所有数据库操作。频繁地建立和关闭连接会带来性能开销。
- 关闭连接：在应用程序优雅退出时，务必调用client.close()来释放数据库连接资源，防止资源泄露。
总结
当Node.js应用程序连接MongoDB时，如果遇到client.connect()看似无响应的情况，核心原因在于现代mongodb驱动的connect方法返回的是一个Promise。为了正确处理连接结果并执行后续数据库操作，必须采用异步编程模式，如async/await或.then()。理解并正确运用这些模式，是确保Node.js应用与MongoDB稳定、高效交互的关键。通过适当的错误处理和连接管理，可以构建出可靠的数据库驱动应用。