Next.js中使用instrumentation.js与middleware.ts时的MongoDB连接异常

问题根源 #

1. Edge Runtime环境不兼容：Next.js的Middleware默认运行在Edge Runtime，而Mongoose依赖Node.js的内置API（如net、tls），这些在Edge环境中不可用。如果middleware中触发了数据库连接逻辑，必然会报错。
2. 重复连接导致资源耗尽：Middleware会在每个请求时执行，若没有单例控制，每次请求都会尝试创建新的MongoDB连接，导致连接池溢出或连接状态混乱。
3. 连接初始化时机冲突：移除instrumentation.ts中的await会导致服务器未完成数据库连接就开始处理请求，此时middleware触发的数据库操作会遇到未就绪的连接。

修复方案 #

1. 隔离Middleware与数据库操作 #

• 禁止在middleware中直接执行数据库读写或连接逻辑，仅用它处理路由校验、请求头改写等轻量操作。
• 若middleware需要数据支撑，通过调用Node.js Runtime的API路由（如/api/get-data）间接获取，避免在Edge环境中触发数据库操作。

2. 实现MongoDB连接单例模式 #

修改mongoose.ts，确保整个应用生命周期内只创建一次数据库连接：

import mongoose from 'mongoose';

const MONGODB_URI = process.env.MONGODB_URI!;

// 全局变量存储连接实例，避免重复初始化
declare global {
  var mongoose: {
    conn: typeof mongoose | null;
    promise: Promise<typeof mongoose> | null;
  };
}

global.mongoose = global.mongoose || { conn: null, promise: null };

export async function connectDB() {
  // 复用已存在的连接
  if (global.mongoose.conn) {
    return global.mongoose.conn;
  }

  // 仅在首次请求时创建连接Promise
  if (!global.mongoose.promise) {
    global.mongoose.promise = mongoose.connect(MONGODB_URI, {
      dbName: 'your-db-name', // 替换为你的数据库名
    }).then(mongoose => mongoose);
  }

  global.mongoose.conn = await global.mongoose.promise;
  return global.mongoose.conn;
}

• 在instrumentation.ts中保留await connectDB()，确保服务器启动时完成连接初始化：

  import { connectDB } from './mongoose';
  
  export async function register() {
    await connectDB();
  }
  

3. 强制Middleware使用Node.js Runtime（可选） #

如果必须在middleware中操作数据库，可以指定其使用Node.js Runtime（仅适合非Edge场景）：
在middleware.ts顶部添加配置：

export const config = {
  runtime: 'nodejs', // 强制使用Node.js Runtime
};

// 后续可安全调用connectDB()
import { connectDB } from './mongoose';

export async function middleware(request: Request) {
  await connectDB();
  // 执行数据库操作...
  return NextResponse.next();
}

注意：此方案会失去Edge Runtime的性能优势，仅适合特定场景。

4. 排查连接状态 #

在服务器端代码中添加连接状态校验，确保操作数据库前连接已就绪：

import { connectDB } from './mongoose';

export async function someDatabaseOperation() {
  const db = await connectDB();
  if (!db.connection.readyState) {
    throw new Error('MongoDB connection not ready');
  }
  // 执行数据库操作
}

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