Next.js API路由中如何预处理并保留请求体数据？

在Next.js的API路由中，NextRequest的请求体是可读流，一旦调用json()/text()等方法读取后，流就会被消耗，无法再次读取。以下是无需外部库的几种解决方法及最佳实践：

方法一：直接缓存解析后的原始/处理后数据 #

这是最直接的方案——将解析后的请求体存储在变量中，后续主逻辑直接使用这些变量，完全避开流被消耗的问题。

修改后的示例代码：

import { NextRequest, NextResponse } from 'next/server';

export const POST = async (request: NextRequest) => {
  // 1. 解析并缓存原始请求体
  const originalBody = await request.json(); 

  // 2. 执行预处理（验证、转换、添加额外数据等）
  const processedBody = { 
    ...originalBody, 
    additionalData: "some extra info",
    sanitizedPhone: originalBody.phone?.replace(/\D/g, '') // 示例：清洗手机号格式
  };

  // 3. 主处理逻辑：直接使用缓存的originalBody或processedBody
  if (!processedBody.userId) {
    return NextResponse.json({ error: "缺少必填字段userId" }, { status: 400 });
  }

  // 示例业务逻辑：比如写入数据库
  // await db.user.create({ data: processedBody });

  return NextResponse.json({ 
    message: '请求处理完成', 
    originalBody,
    processedBody 
  });
};

方法二：克隆请求对象（适用于需多次读取请求体的场景） #

如果需要同时获取多种格式的请求体（比如既要解析JSON，又要记录原始文本），可以用request.clone()创建请求副本，分别读取原始请求和克隆请求的体数据。

示例代码：

import { NextRequest, NextResponse } from 'next/server';

export const POST = async (request: NextRequest) => {
  // 创建请求克隆体
  const clonedRequest = request.clone();

  // 从原始请求读取JSON格式
  const originalBody = await request.json();
  // 从克隆请求读取原始文本（用于日志或验签）
  const rawBodyText = await clonedRequest.text();

  // 预处理逻辑
  const processedBody = { ...originalBody, timestamp: Date.now() };

  // 主逻辑：同时使用多种格式的请求数据
  console.log("原始JSON数据:", originalBody);
  console.log("原始请求报文:", rawBodyText);

  return NextResponse.json({ message: '请求处理完成' });
};

方法三：封装预处理函数（复用逻辑） #

如果多个API路由需要相同的预处理逻辑（比如认证、数据校验），可以把预处理逻辑抽离成独立函数，返回缓存的原始/处理后数据。

第一步：创建预处理工具函数 #

// utils/requestPreprocess.ts
import { NextRequest } from 'next/server';

export async function preprocessRequest(request: NextRequest) {
  // 1. 解析请求体
  const originalBody = await request.json();

  // 2. 认证验证示例
  if (!originalBody.authToken) {
    throw new Error("未提供认证令牌");
  }
  const isTokenValid = originalBody.authToken === "VALID_ADMIN_TOKEN";
  if (!isTokenValid) {
    throw new Error("无效的认证令牌");
  }

  // 3. 数据清洗/转换
  const processedBody = {
    ...originalBody,
    normalizedEmail: originalBody.email?.toLowerCase().trim(),
    authToken: undefined // 移除敏感字段
  };

  return { originalBody, processedBody };
}

第二步：在API路由中使用 #

import { NextRequest, NextResponse } from 'next/server';
import { preprocessRequest } from '@/utils/requestPreprocess';

export const POST = async (request: NextRequest) => {
  try {
    // 执行预处理
    const { originalBody, processedBody } = await preprocessRequest(request);

    // 主业务逻辑
    console.log("处理后的数据:", processedBody);

    return NextResponse.json({ message: '请求处理成功', data: processedBody });
  } catch (error) {
    return NextResponse.json({ error: (error as Error).message }, { status: 401 });
  }
};

最佳实践总结 #

1. 优先使用缓存变量：这是最简洁高效的方式，无需修改请求对象，直接复用解析后的变量。
2. 克隆请求仅在必要时使用：比如需要同时获取JSON和原始文本的场景，避免滥用克隆造成不必要的内存开销。
3. 抽离预处理逻辑：多路由复用相同逻辑时，封装成工具函数，保持路由代码简洁易维护。
4. 避免重建请求体：NextRequest的body是只读流，强行修改或重建可能导致Next.js内部处理异常，不要尝试这种方式。

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