Next.js中无法连接MongoDB数据库的问题排查求助

环境信息 #

• nodejs: v18.17.0
• nextjs: v13.4.13
• mongodb版本: MongoDB 6.0.8 Community
• mongodb工具: mongodbcompass
• 操作系统: Windows 10

问题详情 #

• 采用Next.js作为应用后端服务
• 在Next.js中编写的API对应路径/文件路径为：src/pages/api/v1/knowledge
• 前端请求URL http://localhost:3000/api/v1/knowledge 时出现超时

个人推测 #

• Next.js服务可正常运行
• 无法连接MongoDB，但尚未明确原因，怀疑代码存在错误

相关API代码（src/pages/api/v1/knowledge） #

import { MongoClient, Db } from "mongodb";
import { NextApiRequest, NextApiResponse } from "next";

const resolveGetRequest = async (
  req: NextApiRequest,
  res: NextApiResponse,
  db: Db
) => {
  const collection = db.collection("KnowledgePointComments");
  const data = await collection.find({}).toArray();
  res.status(200).json({
    code: "0",
    messgae: "success",
    data: "hello-world!",
  });
};

const resolvePostRequest = async (
  req: NextApiRequest,
  res: NextApiResponse,
  db: Db
) => {};

export default async function handler(
  req: NextApiRequest,
  res: NextApiResponse
) {
  const url = "mongodb://localhost:27017";
  const dbName = "TEST_FRONTEND_EVERYDAY";
  const client = new MongoClient(url);
  // console.log(client);
  try {
    const __res = await client.connect();
    console.log("@", __res);
    console.log("connect mongodb success!");

    const db: Db = client.db(dbName);

    // 获取随机知识点
    if (req.method === "GET") {
      resolveGetRequest(req, res, db);
    }

    // 发布知识点
    if (req.method === "POST") {
      resolvePostRequest(req, res, db);
    }
  } catch (err) {
    res.status(500).json({
      code: "-1",
      message: "unable to connect mongodb",
    });
  } finally {
    await client.close();
  }
}

已尝试操作 #

• 修改mongod.cfg配置文件，将bindIp从127.0.0.1改为0.0.0.0
• 重启MongoDB服务

问题分析与解决方案 #

核心问题 #

1. 异步函数未等待执行完成：调用resolveGetRequest和resolvePostRequest时未加await，导致MongoDB连接在数据库操作完成前就被finally块关闭，请求逻辑无法正常结束，引发超时。
2. POST请求无响应返回：resolvePostRequest为空实现，前端发起POST请求时服务端不会返回任何响应，同样会触发超时。

修复后的代码 #

import { MongoClient, Db } from "mongodb";
import { NextApiRequest, NextApiResponse } from "next";

const resolveGetRequest = async (
  req: NextApiRequest,
  res: NextApiResponse,
  db: Db
) => {
  try {
    const collection = db.collection("KnowledgePointComments");
    const data = await collection.find({}).toArray();
    res.status(200).json({
      code: "0",
      message: "success", // 修正原代码拼写错误：messgae → message
      data: data // 可根据需求返回实际查询数据，原代码返回固定字符串可调整
    });
  } catch (err) {
    res.status(500).json({
      code: "-1",
      message: "查询数据失败"
    });
  }
};

const resolvePostRequest = async (
  req: NextApiRequest,
  res: NextApiResponse,
  db: Db
) => {
  // 补充POST请求处理逻辑示例
  try {
    const collection = db.collection("KnowledgePointComments");
    const result = await collection.insertOne(req.body);
    res.status(200).json({
      code: "0",
      message: "数据提交成功",
      data: result.insertedId
    });
  } catch (err) {
    res.status(500).json({
      code: "-1",
      message: "提交数据失败"
    });
  }
};

export default async function handler(
  req: NextApiRequest,
  res: NextApiResponse
) {
  const url = "mongodb://localhost:27017";
  const dbName = "TEST_FRONTEND_EVERYDAY";
  const client = new MongoClient(url);
  
  try {
    await client.connect();
    console.log("连接MongoDB成功!");

    const db: Db = client.db(dbName);

    if (req.method === "GET") {
      await resolveGetRequest(req, res, db); // 添加await等待处理完成
    } else if (req.method === "POST") {
      await resolvePostRequest(req, res, db); // 添加await等待处理完成
    } else {
      // 处理未支持的请求方法
      res.setHeader("Allow", ["GET", "POST"]);
      res.status(405).end(`方法 ${req.method} 不被允许`);
    }
  } catch (err) {
    res.status(500).json({
      code: "-1",
      message: "无法连接MongoDB"
    });
  } finally {
    await client.close();
  }
}

额外优化建议 #

• 修复字段拼写错误：原代码中messgae应为message，避免返回响应时的字段错误。
• 添加异常捕获：在数据处理函数中加入try-catch块，处理数据库操作可能出现的异常，返回更明确的错误信息。
• 支持请求方法校验：添加对非GET/POST请求的处理，返回405状态码，符合RESTful规范。
• 复用数据库连接：Next.js API路由每次请求都会创建新连接，频繁创建关闭会影响性能，可考虑使用连接池或缓存客户端实例（注意并发安全）。

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