如何在Next.js中无需客户端请求每15分钟自动发起服务端API调用？

针对你需要在服务端定时调用第三方API并存储数据的需求，以下是几种适配Next.js架构的可行方案，按需选择即可：

方案1：自定义服务器脚本（自部署场景） #

如果你是自己部署Next.js应用（比如用Docker、VPS），可以通过自定义服务器脚本在应用启动时执行初始化任务，并通过setInterval维持定时任务。

步骤： #

1. 创建数据处理函数

// lib/fetchData.js
async function fetchAndSaveData() {
  try {
    // 调用第三方API
    const apiRes = await fetch('https://third-party-api.com/target-endpoint');
    const rawData = await apiRes.json();
    
    // 处理并写入数据库（示例）
    await yourDbClient.query(
      'INSERT INTO your_table (data) VALUES ($1) ON CONFLICT DO UPDATE SET data = $1',
      [JSON.stringify(rawData)]
    );
    
    console.log(`[${new Date().toISOString()}] 数据更新成功`);
  } catch (err) {
    console.error(`[${new Date().toISOString()}] 数据更新失败:`, err.message);
    // 可选：添加重试逻辑
  }
}

module.exports = fetchAndSaveData;

2. 编写自定义服务器入口

// server.js
const next = require('next');
const http = require('http');
const fetchAndSaveData = require('./lib/fetchData');

const dev = process.env.NODE_ENV !== 'production';
const app = next({ dev });
const handle = app.getRequestHandler();

async function startServer() {
  // 启动时立即执行一次数据更新
  await fetchAndSaveData();
  
  // 设置15分钟定时任务
  setInterval(async () => {
    await fetchAndSaveData();
  }, 15 * 60 * 1000);

  // 启动Next.js服务
  await app.prepare();
  http.createServer((req, res) => handle(req, res)).listen(3000, () => {
    console.log('> 服务已启动：http://localhost:3000');
  });
}

startServer();

3. 修改package.json启动脚本

{
  "scripts": {
    "dev": "node server.js",
    "start": "NODE_ENV=production node server.js"
  }
}

方案2：API Route + 外部定时触发器（Serverless部署场景） #

如果用Vercel、Netlify等Serverless平台部署，不能依赖setInterval（函数实例会被销毁），需要通过外部Cron服务触发API Route执行任务。

步骤： #

1. 创建API Route处理任务

// app/api/update-data/route.js
import fetchAndSaveData from '@/lib/fetchData';

export async function GET() {
  try {
    await fetchAndSaveData();
    return new Response('数据更新完成', { status: 200 });
  } catch (err) {
    return new Response(`更新失败：${err.message}`, { status: 500 });
  }
}

2. 配置外部定时触发器

• Vercel用户：直接在vercel.json中配置内置Cron任务

{
  "crons": [
    {
      "path": "/api/update-data",
      "schedule": "*/15 * * * *" // 每15分钟执行一次
    }
  ]
}

• 其他平台：使用Cloudflare Workers Cron、AWS EventBridge等外部服务，定时向/api/update-data发送GET请求

3. 启动时初始化数据
   在部署脚本中添加初始化步骤，比如修改package.json：

{
  "scripts": {
    "dev": "node scripts/init-data.js && next dev",
    "start": "node scripts/init-data.js && next start"
  }
}

创建初始化脚本：

// scripts/init-data.js
const fetchAndSaveData = require('../lib/fetchData');

async function init() {
  await fetchAndSaveData();
  process.exit(0);
}

init();

关键注意事项 #

• 避免重复执行：如果任务执行时间可能超过15分钟，需要加分布式锁（比如用Redis）或数据库状态标记，防止并发执行。
• 错误重试：添加重试逻辑（比如最多重试3次），避免单次API失败导致数据断更。
• 数据库连接：复用连接池，不要每次任务都新建数据库连接，降低资源消耗。

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