Nuxt Nitro中通过插件初始化MySQL连接并挂载至上下文是否合理？

你的方案整体是合理的——Nitro插件本身就是初始化服务端全局资源并挂载到上下文的标准方式，目前能正常运行也验证了这一点。不过针对生产环境的稳定性、可维护性，这里有几个更优的实现方向：

1. 改用连接池替代单连接 #

原代码用createConnection创建单连接，高并发场景下会出现请求排队、连接耗尽的问题，推荐使用MySQL连接池：

// server/plugins/sql.js 优化后的连接池实现
import mysql from 'mysql'
export default defineNitroPlugin((nitro) => {
  const config = useRuntimeConfig()
  // 创建连接池，设置合理的连接上限
  const pool = mysql.createPool({
    host: config.db.host,
    user: config.db.user,
    password: config.db.password,
    database: config.db.database,
    connectionLimit: 10, // 根据业务调整并发连接数
    waitForConnections: true
  })

  // 测试连接（可选，用于启动时验证数据库可用性）
  pool.getConnection((err, conn) => {
    if (err) {
      console.error('数据库连接失败:', err)
      return
    }
    console.log('DB Connected!')
    conn.release() // 释放测试连接
  })

  // 封装Promise风格的查询方法，避免重复手写Promise
  nitro.$db = {
    query: (sql, params) => new Promise((resolve, reject) => {
      pool.query(sql, params, (err, results) => {
        if (err) {
          console.error('数据库查询错误:', err)
          return reject(err)
        }
        resolve(results)
      })
    })
  }

  // 服务关闭时销毁连接池
  nitro.hooks.hookOnce("close", async () => {
    await new Promise((resolve) => pool.end(() => resolve()))
    console.log("数据库连接池已关闭")
  })
})

2. 抽离配置到环境变量 #

把硬编码的数据库配置放到.env文件，通过useRuntimeConfig()读取，既安全又方便多环境切换：

# .env 文件内容
DB_HOST=127.0.0.1
DB_USER=users_service
DB_PASSWORD=123
DB_DATABASE=users

在nuxt.config.ts中暴露服务端配置：

export default defineNuxtConfig({
  runtimeConfig: {
    db: {
      host: process.env.DB_HOST,
      user: process.env.DB_USER,
      password: process.env.DB_PASSWORD,
      database: process.env.DB_DATABASE
    }
  }
})

3. 优化API中的错误处理 #

避免直接throw err导致服务崩溃，改用createError返回标准错误响应：

// server/api/hello.js 简化版
export default defineEventHandler(async (event) => {
  const { $db } = useNitroApp()
  try {
    const directoryData = await $db.query("SELECT * FROM directory")
    return directoryData
  } catch (err) {
    throw createError({
      statusCode: 500,
      statusMessage: '数据库查询失败',
      message: err.message
    })
  }
})

核心优化点总结 #

• 连接池解决单连接的并发瓶颈，提升服务稳定性
• 环境变量抽离配置，符合生产环境安全规范
• 封装通用查询方法，减少代码冗余
• 统一错误处理，避免未捕获异常导致服务崩溃

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