Nitro 服务引擎深度解析

// nuxt.config.ts
export default defineNuxtConfig({
  nitro: {
    preset: 'node-server',  // 部署目标
  },
})

nuxi build
# 输出到 .output/ 目录：
# .output/
# ├── server/           ← 服务端代码（编译后）
# │   ├── index.mjs     ← 入口文件
# │   └── chunks/       ← 代码分片
# ├── public/           ← 静态资源
# └── nitro.json        ← 运行时配置

// server/api/example.get.ts
export default defineEventHandler((event) => {
  // event 是 H3Event 实例，包含请求的所有信息
  // 通过工具函数读取：
  const query = getQuery(event)          // 查询参数
  const body = await readBody(event)     // 请求体
  const headers = getRequestHeaders(event) // 请求头
  const cookies = parseCookies(event)    // Cookie
 
  // 设置响应：
  setResponseStatus(event, 201)
  setResponseHeader(event, 'X-Custom', 'value')
  setCookie(event, 'token', 'xxx', { httpOnly: true })
 
  return { message: 'ok' }  // 自动序列化为 JSON
})

import { fromNodeMiddleware } from 'h3'
import helmet from 'helmet'
 
// 将 Express 中间件转为 H3 中间件
export default fromNodeMiddleware(helmet())

// server/api/videos/[id].get.ts → GET /api/videos/:id
export default defineEventHandler((event) => {
  const id = getRouterParam(event, 'id')
  return { id }
})
 
// server/api/videos/[id]/comments/[commentId].delete.ts
// → DELETE /api/videos/:id/comments/:commentId

// server/api/cache.get.ts
export default defineEventHandler(async () => {
  const storage = useStorage()
 
  // 基本操作
  await storage.setItem('views:video-123', 42)
  const views = await storage.getItem('views:video-123')  // 42
  await storage.removeItem('views:video-123')
 
  // 检查存在
  const exists = await storage.hasItem('views:video-123')
 
  // 列出所有 key
  const keys = await storage.getKeys('views')  // ['views:video-123', ...]
 
  return { views }
})

// nuxt.config.ts
export default defineNuxtConfig({
  nitro: {
    storage: {
      // 默认：内存存储（开发环境）
      cache: { driver: 'memory' },
 
      // Redis
      redis: {
        driver: 'redis',
        host: '127.0.0.1',
        port: 6379,
      },
 
      // 文件系统
      data: {
        driver: 'fs',
        base: './data/storage',
      },
 
      // Cloudflare KV
      kv: {
        driver: 'cloudflare-kv-binding',
        binding: 'MY_KV',
      },
    },
  },
})

// 使用 redis 存储
const redis = useStorage('redis')
await redis.setItem('session:abc', { userId: 1 })
 
// 使用文件存储
const data = useStorage('data')
await data.setItem('config.json', { theme: 'dark' })

// server/api/videos/trending.get.ts
export default defineCachedEventHandler(async () => {
  // 这个 handler 的响应会被自动缓存
  const videos = await db.query.videos.findMany({
    orderBy: desc(videos.views),
    limit: 20,
  })
  return videos
}, {
  maxAge: 60 * 5,       // 缓存 5 分钟
  staleMaxAge: 60 * 60, // 过期后仍可用 1 小时（SWR 模式）
  name: 'trending-videos',
})

// server/plugins/01.database.ts
export default defineNitroPlugin(async (nitroApp) => {
  // 1. 初始化数据库连接
  await db.execute(sql`SELECT 1`)
  console.log('✅ Database connected')
 
  // 2. 注册全局钩子
  nitroApp.hooks.hook('request', (event) => {
    event.context.requestStart = Date.now()
  })
 
  nitroApp.hooks.hook('afterResponse', (event) => {
    const duration = Date.now() - (event.context.requestStart || 0)
    console.log(`${event.path} completed in ${duration}ms`)
  })
})

// 优雅关闭：释放数据库连接
export default defineNitroPlugin((nitroApp) => {
  nitroApp.hooks.hook('close', async () => {
    await db.$client.end()
    console.log('Database connection closed')
  })
})

// nuxt.config.ts
export default defineNuxtConfig({
  runtimeConfig: {
    // 私有：仅服务端可访问（不会暴露给客户端）
    jwtSecret: process.env.JWT_SECRET || '',
    databaseUrl: process.env.DATABASE_URL || '',
    openaiApiKey: process.env.OPENAI_API_KEY || '',
 
    // 公开：客户端也能访问
    public: {
      apiBase: process.env.API_BASE || 'http://localhost:3000',
      appName: 'AI Video Platform',
    },
  },
})

// server/api/config.get.ts
export default defineEventHandler(() => {
  const config = useRuntimeConfig()
 
  // ✅ 服务端可读全部配置
  console.log(config.jwtSecret)       // 私有配置
  console.log(config.public.apiBase)   // 公开配置
 
  // ❌ 绝对不要返回私有配置给客户端
  return { appName: config.public.appName }
})

# Docker 部署示例
docker run -e NUXT_DATABASE_URL=postgres://prod:5432/app \
           -e NUXT_JWT_SECRET=xxx \
           -e NUXT_PUBLIC_API_BASE=https://api.example.com \
           my-nuxt-app

// nuxt.config.ts
export default defineNuxtConfig({
  nitro: {
    experimental: {
      tasks: true,  // 启用任务调度
    },
    scheduledTasks: {
      // 每 5 分钟清理过期缓存
      '*/5 * * * *': ['cache:cleanup'],
      // 每天凌晨统计视频数据
      '0 2 * * *': ['analytics:daily'],
    },
  },
})

// server/tasks/cache/cleanup.ts
export default defineTask({
  meta: {
    name: 'cache:cleanup',
    description: '清理过期的缓存数据',
  },
  async run() {
    const storage = useStorage('cache')
    const keys = await storage.getKeys()
    let cleaned = 0
 
    for (const key of keys) {
      const meta = await storage.getMeta(key)
      if (meta?.mtime && Date.now() - meta.mtime > 3600 * 1000) {
        await storage.removeItem(key)
        cleaned++
      }
    }
 
    return { result: `Cleaned ${cleaned} expired cache entries` }
  },
})

// server/tasks/analytics/daily.ts
export default defineTask({
  meta: {
    name: 'analytics:daily',
    description: '每日视频数据统计',
  },
  async run() {
    const yesterday = new Date(Date.now() - 86400 * 1000)
 
    const stats = await db.select({
      totalViews: sum(videos.views),
      newVideos: count(),
    }).from(videos).where(gte(videos.createdAt, yesterday))
 
    await db.insert(dailyStats).values({
      date: yesterday.toISOString().split('T')[0],
      ...stats[0],
    })
 
    return { result: stats[0] }
  },
})

// 通过 Nitro DevTools 或 API 触发
await $fetch('/_nitro/tasks/cache:cleanup', { method: 'POST' })