MERN项目服务端MongoDB Atlas连接异常求助

我正在开发首个MERN项目，按官方教程搭建服务端时遇到问题。尝试连接MongoDB Atlas，现有server.js、conn.js、jobs.js三个文件。运行node server.js仅打印"connectToServer called"，却未输出"client.connect() called"，推测客户端未成功连接，该如何解决？

相关代码 #

server.js #

const express = require("express");
const app = express();
const cors = require("cors");
require("dotenv").config({ path: "./config.env" });
const port = process.env.PORT || 5000;
app.use(cors());
app.use(express.json());
app.use(require("./routes/jobs"));
// get driver connection
const dbo = require("./db/conn");

app.listen(port, () => {
  // perform a database connection when server starts
  dbo.connectToServer(function (err) {
    if (err) console.error(err);
  });
  console.log(`Server is running on port: ${port}`);
});

conn.js #

const { MongoClient } = require("mongodb");
const Db = process.env.ATLAS_URI;
const client = new MongoClient(Db, {
  useNewUrlParser: true,
  useUnifiedTopology: true,
});

var _db;

module.exports = {
  connectToServer: function (callback) {
    console.log("connectToServer called");
    client.connect(function (err, db) {
      console.log("client.connect() called");
      // Verify we got a good "db" object
      if (db) {
        _db = db.db("jobs");
        console.log("Successfully connected to MongoDB.");
      }
      return callback(err);
    });
  },

  getDb: function () {
    return _db;
  },
};

jobs.js #

const express = require("express");

// recordRoutes is an instance of the express router.
// We use it to define our routes.
// The router will be added as a middleware and will take control of requests starting with path /record.
const recordRoutes = express.Router();

// This will help us connect to the database
const dbo = require("../db/conn");

// This help convert the id from string to ObjectId for the _id.
const ObjectId = require("mongodb").ObjectId;

// This section will help you get a list of all the records.
recordRoutes.route("/record").get(function (req, res) {
  let db_connect = dbo.getDb("jobs");
  db_connect
    .collection("jobs")
    .find({})
    .toArray(function (err, result) {
      if (err) throw err;
      res.json(result);
    });
});

// This section will help you get a single record by id
recordRoutes.route("/record/:id").get(function (req, res) {
  let db_connect = dbo.getDb();
  let myquery = { _id: ObjectId(req.params.id) };
  db_connect.collection("jobs").findOne(myquery, function (err, result) {
    if (err) throw err;
    res.json(result);
  });
});

// This section will help you create a new record.
recordRoutes.route("/record/add").post(function (req, response) {
  let db_connect = dbo.getDb();
  let myobj = {
    name: req.body.name,
    position: req.body.position,
    level: req.body.level,
  };
  db_connect.collection("jobs").insertOne(myobj, function (err, res) {
    if (err) throw err;
    response.json(res);
  });
});

// This section will help you update a record by id.
recordRoutes.route("/update/:id").post(function (req, response) {
  let db_connect = dbo.getDb();
  let myquery = { _id: ObjectId(req.params.id) };
  let newvalues = {
    $set: {
      name: req.body.name,
      position: req.body.position,
      level: req.body.level,
    },
  };
  db_connect
    .collection("jobs")
    .updateOne(myquery, newvalues, function (err, res) {
      if (err) throw err;
      console.log("1 document updated");
      response.json(res);
    });
});

// This section will help you delete a record
recordRoutes.route("/:id").delete((req, response) => {
  let db_connect = dbo.getDb();
  let myquery = { _id: ObjectId(req.params.id) };
  db_connect.collection("jobs").deleteOne(myquery, function (err, obj) {
    if (err) throw err;
    console.log("1 document deleted");
    response.json(obj);
  });
});

module.exports = recordRoutes;

我预期能触发client.connect()并打印对应日志，但实际未触发，推测数据库连接失败。

解决方案 #

1. 检查环境变量有效性 #

• 确认config.env文件在项目根目录，ATLAS_URI是MongoDB Atlas提供的完整连接字符串，已替换<password>为数据库用户的真实密码（密码含特殊字符需转义）。
• 在conn.js开头添加console.log(process.env.ATLAS_URI)，验证变量是否成功加载。

2. 捕获MongoClient初始化错误 #

当前代码中，若Db为空或无效，new MongoClient()会静默失败，无法进入client.connect()回调。修改conn.js添加初始化校验：

const { MongoClient } = require("mongodb");
const Db = process.env.ATLAS_URI;

// 先校验环境变量
if (!Db) {
  console.error("ATLAS_URI环境变量未设置");
  process.exit(1);
}

let client;
try {
  client = new MongoClient(Db, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
  });
} catch (err) {
  console.error("创建MongoClient实例失败:", err);
  process.exit(1);
}

var _db;

module.exports = {
  connectToServer: function (callback) {
    console.log("connectToServer called");
    client.connect(function (err, db) {
      console.log("client.connect() called");
      if (err) {
        console.error("连接MongoDB失败:", err);
        return callback(err);
      }
      if (db) {
        _db = db.db("jobs");
        console.log("Successfully connected to MongoDB.");
      }
      return callback(null);
    });
  },

  getDb: function () {
    return _db;
  },
};

3. 验证MongoDB Atlas权限配置 #

• 登录MongoDB Atlas控制台，确认当前服务器IP已加入集群IP白名单（可临时设置为0.0.0.0/0测试，生产环境需限制指定IP）。
• 确认数据库用户拥有jobs数据库的读写权限。

4. 升级MongoDB驱动并简化配置 #

新版MongoDB驱动（v4+）已默认启用useNewUrlParser和useUnifiedTopology，可移除这些选项并升级驱动：

npm install mongodb@latest

5. 改用async/await优化连接逻辑 #

回调模式易隐藏错误，改用async/await更便于调试：
修改conn.js：

const { MongoClient } = require("mongodb");
const Db = process.env.ATLAS_URI;
let client;
let _db;

module.exports = {
  connectToServer: async function () {
    console.log("connectToServer called");
    try {
      client = await MongoClient.connect(Db);
      console.log("client.connect() called");
      _db = client.db("jobs");
      console.log("Successfully connected to MongoDB.");
    } catch (err) {
      console.error("连接失败:", err);
      throw err;
    }
  },

  getDb: function () {
    return _db;
  },
};

修改server.js的启动逻辑：

app.listen(port, async () => {
  console.log(`Server is running on port: ${port}`);
  try {
    await dbo.connectToServer();
  } catch (err) {
    console.error(err);
    process.exit(1);
  }
});

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