当mongodb服务器显示“waiting for connections”，但node.js应用无响应时，通常是因为mongodb node.js驱动的`connect`方法返回promise。本文将详细讲解如何使用`.then()`或`async/await`正确处理异步连接，确保应用能成功连接并操作mongodb数据库，并提供完整的代码示例和最佳实践，帮助开发者解决常见的连接阻塞问题。
深入理解node.js mongodb连接机制
在开发node.js应用程序与MongoDB交互时，一个常见的困惑是：即使MongoDB服务器已启动并显示“waiting for connections”，但Node.js脚本执行后却没有预期的输出，仿佛连接从未建立。这通常不是MongoDB服务器的问题，而是Node.js应用程序中处理异步连接的方式不正确。
核心问题：MongoDB驱动的异步连接
MongoDB Node.js驱动的MongoClient.connect()方法在最新版本中不再接受回调函数，而是返回一个Promise对象。这意味着连接操作是异步的，并且结果（连接成功或失败）将在未来的某个时间点通过这个Promise对象来通知。如果不对这个Promise进行处理，Node.js脚本会继续执行后续代码，而不会等待连接建立，从而导致看起来“无响应”的现象。
解决方案一：使用Promise的.then()方法
Promise的.then()方法允许我们注册一个回调函数，当Promise成功解决（即连接建立成功）时，这个回调函数会被执行。
以下是一个使用.then()方法处理MongoDB连接的示例：
const { MongoClient } = require('mongodb'); // MongoDB连接URI const uri = "mongodb://localhost:27017"; // 数据库名称 const dbName = "myDatabase"; // 创建一个新的MongoClient实例 const client = new MongoClient(uri); async function connectWithThen() { try { // 连接到MongoDB服务器 await client.connect().then(() => { console.log("成功连接到MongoDB！"); // 获取数据库实例 const db = client.db(dbName); console.log(`已连接到数据库: ${db.databaseName}`); // 在这里可以执行数据库操作，例如插入或查询 const Collection = db.collection('myCollection'); collection.insertOne({ name: "Test User", age: 30 }) .then(result => { console.log("插入文档成功:", result.insertedId); }) .catch(err => { console.error("插入文档失败:", err); }) .finally(() => { // 关闭连接 client.close(); console.log("MongoDB连接已关闭。"); }); }); } catch (err) { console.error("MongoDB连接失败:", err); } } connectWithThen();
在这个示例中，client.connect()返回一个Promise。.then()中的代码只会在连接成功后执行，确保了数据库操作在连接建立之后进行。
解决方案二：使用async/await语法
async/await是处理Promise的更现代、更简洁的方式，它让异步代码看起来更像同步代码，提高了可读性。
const { MongoClient } = require('mongodb'); // MongoDB连接URI const uri = "mongodb://localhost:27017"; // 数据库名称 const dbName = "myDatabase"; // 创建一个新的MongoClient实例 const client = new MongoClient(uri); async function connectWithAsyncAwait() { try { // 使用await等待连接建立 await client.connect(); console.log("成功连接到MongoDB！"); // 获取数据库实例 const db = client.db(dbName); console.log(`已连接到数据库: ${db.databaseName}`); // 获取集合并执行操作 const collection = db.collection('myCollection'); const insertResult = await collection.insertOne({ name: "Another User", age: 25 }); console.log("插入文档成功:", insertResult.insertedId); const findResult = await collection.find({}).toArray(); console.log("查询所有文档:", findResult); } catch (err) { console.error("MongoDB操作失败:", err); } finally { // 无论成功失败，最终都要关闭连接 await client.close(); console.log("MongoDB连接已关闭。"); } } connectWithAsyncAwait();
使用async/await时，await关键字会暂停async函数的执行，直到它后面的Promise解决。一旦Promise解决，await表达式就会返回Promise的解决值。这使得错误处理（通过try…catch）也变得更加直观。
完整示例：连接、操作与关闭
为了提供一个更完整的教程体验，以下代码结合了async/await，演示了如何连接到MongoDB，执行简单的插入和查询操作，并最终正确关闭连接。
const { MongoClient } = require('mongodb'); // MongoDB连接URI，如果MongoDB运行在默认端口和本机，通常是这个 const uri = "mongodb://localhost:27017"; // 你想连接或创建的数据库名称 const dbName = "myProjectDb"; // 你想操作的集合名称 const collectionName = "users"; let client; // 声明client变量以便在finally块中访问 async function run() { try { // 1. 创建MongoClient实例 client = new MongoClient(uri); // 2. 连接到MongoDB服务器 console.log("尝试连接到MongoDB..."); await client.connect(); console.log("成功连接到MongoDB！"); // 3. 获取数据库实例 const db = client.db(dbName); console.log(`已连接到数据库: ${db.databaseName}`); // 4. 获取集合实例 const collection = db.collection(collectionName); console.log(`已获取集合: ${collection.collectionName}`); // 5. 执行数据操作：插入一个文档 const user1 = { name: "Alice", email: "alice@example.com", age: 30 }; const insertResult = await collection.insertOne(user1); console.log(`插入文档成功，ID: ${insertResult.insertedId}`); // 6. 执行数据操作：查询所有文档 console.log("查询所有用户..."); const users = await collection.find({}).toArray(); console.log("所有用户:", users); // 7. 执行数据操作：更新一个文档 const updateResult = await collection.updateOne( { name: "Alice" }, { $set: { age: 31 } } ); console.log(`更新文档匹配数: ${updateResult.matchedCount}, 修改数: ${updateResult.modifiedCount}`); // 8. 再次查询确认更新 const updatedUser = await collection.findOne({ name: "Alice" }); console.log("更新后的Alice:", updatedUser); } catch (error) { console.error("发生错误:", error); } finally { // 9. 无论操作成功与否，都要关闭MongoDB连接 if (client) { await client.close(); console.log("MongoDB连接已关闭。"); } } } // 运行主函数 run();
重要注意事项
- 确保mongod服务正在运行： 在运行Node.js应用之前，请务必确认MongoDB服务器（mongod进程）已启动，并且正在监听默认端口（27017）或其他指定端口。可以通过命令行运行 mongod 来启动。
- 错误处理： 异步操作总是伴随着失败的可能性。使用.catch()处理Promise链中的错误，或使用try…catch块处理async/await中的错误，是至关重要的。这能帮助你捕获网络问题、认证失败、数据库操作错误等。
- 关闭连接： 完成数据库操作后，始终调用client.close()来关闭MongoDB连接。这会释放资源，避免资源泄漏。在实际应用中，通常会在应用程序关闭时或在长时间不活动后关闭连接。对于Web服务器，通常会在服务器启动时建立连接，并在服务器关闭时关闭连接。
- 连接池： 对于高并发的应用，频繁地建立和关闭连接效率低下。MongoDB驱动内部实现了连接池。MongoClient.connect()在第一次调用时建立连接池，后续调用client.db()或client.collection()会复用连接池中的连接。因此，通常只需在应用程序生命周期中调用一次client.connect()。
- 驱动版本： 本文的解决方案适用于MongoDB Node.js驱动的较新版本（例如v3.x及以上，特别是v4.x、v5.x、v6.x），这些版本普遍采用Promise模式。如果你使用的是非常老的驱动版本，可能需要查阅其特定版本的文档。
- URI配置： 连接URI（mongodb://localhost:27017）可以包含更多配置选项，例如认证信息（mongodb://user:pass@host:port/dbName）、副本集配置、ssl/TLS设置等。
总结
Node.js与MongoDB的连接问题，归根结底是对javaScript异步编程模式的理解和应用。通过掌握Promise的.then()方法或更现代的async/await语法，开发者可以有效地处理MongoDB驱动的异步连接，确保应用程序能够稳定、可靠地与数据库进行交互。同时，良好的错误处理和连接管理习惯也是构建健壮应用的关键。