NextJS+MySQL2遭遇Too Many Connections错误，求解决方案

连接池导致Too Many Connections的原因及修复 #

核心问题分析 #

1. MySQL服务器连接数上限冲突：你设置了connectionLimit: 100，但MySQL默认max_connections为151，若存在其他应用/进程连接数据库，总连接数极易超出上限。
2. 潜在连接泄漏：尽管你在finally块中释放连接，但不排除部分端点代码遗漏释放逻辑，或存在异步阻塞导致连接长期被占用。
3. 连接池配置缺失关键参数：缺少闲置连接回收、连接超时配置，导致连接无法及时复用。

具体修复步骤 #

• 调整MySQL服务器连接数上限：
  登录MySQL执行 SHOW VARIABLES LIKE 'max_connections';，若结果小于你的connectionLimit，修改my.cnf（或my.ini）中的max_connections为合适值（如200），重启MySQL服务。

• 改用自动资源管理（Node.js 18+）：
  用using语句替代手动release，确保连接100%被释放，避免代码分支遗漏：

  import pool from "@/app/libs/mysql";
  
  export async function GET(request: Request) {
    using db = await pool.getConnection();
    try {
      const getQuery = `select * from roles`;
      const [roles] = await db.execute(getQuery);
  
      if (roles.length === 0) {
        return Response.json({
          message: `No roles Found`,
          data: roles,
        }, { status: 404 });
      }
  
      return Response.json(roles);
    } catch (err) {
      console.error("Something Went Wrong", err);
      return Response.json({ 
        message: "Something Went Wrong", 
        error: err instanceof Error ? err.message : "Unknown error" 
      }, { status: 500 });
    }
  }
  

• 优化连接池配置：
  添加闲置回收、超时参数，避免连接长期占用：

  import mysql from "mysql2/promise";
  
  const pool = mysql.createPool({
    host: process.env.MYSQL_HOST,
    user: process.env.MYSQL_USER,
    password: process.env.MYSQL_PASSWORD,
    database: process.env.MYSQL_DATABASE,
    waitForConnections: true,
    connectionLimit: 50, // 下调至更合理值，避免占满MySQL连接
    idleTimeout: 60000, // 闲置60秒后自动回收连接
    acquireTimeout: 30000, // 获取连接超时30秒，防止请求挂起
    queueLimit: 0, // 无限制等待队列（可按需调整）
  });
  
  export default pool;
  

• 监控连接池状态：
  添加日志定位泄漏点：

  // 每10秒打印连接池状态
  setInterval(() => {
    const total = pool.pool._allConnections.length;
    const active = pool.pool._activeConnections.length;
    console.log(`连接池总连接数: ${total}, 活跃连接数: ${active}`);
  }, 10000);
  

响应返回的优化方案 #

1. 替换低效的空数组判断：
   放弃JSON.stringify(roles) == "[]"，直接用roles.length === 0，性能更优且代码简洁。

2. 用Response.json()简化代码：
   无需手动设置Content-Type和JSON.stringify，Response.json()会自动处理：

   // 替代手动构造Response
   return Response.json(roles, { status: 200 });
   

3. 规范错误响应格式：
   不要直接返回err对象（可能包含循环引用导致序列化失败），只返回错误信息：

   catch (err) {
     console.error("Something Went Wrong", err);
     return Response.json({
       message: "Something Went Wrong",
       error: err instanceof Error ? err.message : "Unknown error"
     }, { status: 500 });
   }
   

4. 封装响应工具函数：
   减少重复代码，统一项目响应格式：

   // 封装响应工具
   export function successResponse(data: any, status = 200) {
     return Response.json({
       code: status,
       success: true,
       data
     }, { status });
   }
   
   export function errorResponse(message: string, status = 500, error?: string) {
     return Response.json({
       code: status,
       success: false,
       message,
       error
     }, { status });
   }
   
   // 使用示例
   if (roles.length === 0) {
     return errorResponse("No roles Found", 404);
   }
   return successResponse(roles);
   }
   

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