如何在Next.js API路由中分离数据层实现解耦？

问题背景 #

我正在使用Next.js搭配MongoDB，在TypeScript中直接调用MongoDB客户端，但担心后续更换数据库时需要大幅修改app/api/route.ts——当前路由代码与MongoDB API高度耦合（如下），希望通过抽象数据操作逻辑实现解耦，即使不用类式依赖注入（因为POST是函数）也可接受，求可行方案。

原路由代码：

import clientPromise from '@/app/mongodb';
import { NextResponse } from 'next/server';
import * as crypto from 'crypto';
import { v4 as uuidv4 } from "uuid";

export async function POST(request: Request) {
    const ip = // 获取IP的逻辑
    const sha256 = crypto.createHmac("sha256", process.env.SALT!);
    const ipHash = sha256.update(ip!);
    const ipHashDigest = ipHash.digest("hex");

    const client = await clientPromise;
    const db = client.db("survey-db");
    const creatorHistory = await db.collection("creator-ip-hash").findOne({ ipHash: ipHashDigest });

    const uuid = uuidv4();

    if (creatorHistory === null) {
        await db.collection("creator-ip-hash").insertOne({ ipHash: ipHashDigest, count: 1 });
    } else {
        const prevCount = creatorHistory.count;

        if (prevCount >= 3) {
            return NextResponse.json({ "error": "API Limit is reached" }, { status: 429 });
        }

        await db.collection("creator-ip-hash").updateOne({ ipHash: ipHashDigest }, { $set: { count: prevCount + 1 } });
    }

    const survey = await request.json();
    survey.creatorIpHash = ipHashDigest;
    survey.uuid = uuid;
    await db.collection("survey-templates").insertOne(survey);

    return NextResponse.json({ "survey-id": uuid }, { status: 201 });
}

核心解决方案：依赖倒置+数据访问层抽象 #

不用复杂的DI框架，通过定义抽象接口+具体数据库实现的方式，让API路由完全脱离具体数据库细节，后续换数据库仅需新增实现类，无需修改路由代码。

1. 定义抽象数据操作接口

创建app/repositories/survey.repository.ts，把所有需要的数据库操作抽象成方法，路由仅依赖此接口：

// app/repositories/survey.repository.ts
export interface SurveyRepository {
  checkAndUpdateCreatorIpLimit(ipHash: string): Promise<{ allowed: boolean }>;
  createSurvey(surveyData: any, ipHash: string, uuid: string): Promise<void>;
}

2. 实现MongoDB版本的Repository

创建app/repositories/mongodb.survey.repository.ts，将原路由中的MongoDB逻辑全部迁移至此：

// app/repositories/mongodb.survey.repository.ts
import clientPromise from '@/app/mongodb';
import { Db } from 'mongodb';
import { SurveyRepository } from './survey.repository';

export class MongoDBSurveyRepository implements SurveyRepository {
  private db?: Db;

  private async initDb() {
    if (!this.db) {
      const client = await clientPromise;
      this.db = client.db("survey-db");
    }
  }

  async checkAndUpdateCreatorIpLimit(ipHash: string): Promise<{ allowed: boolean }> {
    await this.initDb();
    const creatorHistory = await this.db!.collection("creator-ip-hash").findOne({ ipHash });

    if (!creatorHistory) {
      await this.db!.collection("creator-ip-hash").insertOne({ ipHash, count: 1 });
      return { allowed: true };
    }

    const prevCount = creatorHistory.count;
    if (prevCount >= 3) {
      return { allowed: false };
    }

    await this.db!.collection("creator-ip-hash").updateOne(
      { ipHash },
      { $set: { count: prevCount + 1 } }
    );
    return { allowed: true };
  }

  async createSurvey(surveyData: any, ipHash: string, uuid: string): Promise<void> {
    await this.initDb();
    await this.db!.collection("survey-templates").insertOne({
      ...surveyData,
      creatorIpHash: ipHash,
      uuid
    });
  }
}

// 导出实例供路由直接使用
export const surveyRepository = new MongoDBSurveyRepository();

3. 重构API路由，依赖抽象接口

修改app/api/route.ts，现在完全脱离MongoDB细节，仅依赖抽象接口：

// app/api/route.ts
import { NextResponse } from 'next/server';
import * as crypto from 'crypto';
import { v4 as uuidv4 } from "uuid";
import { surveyRepository } from '@/app/repositories/mongodb.survey.repository';

export async function POST(request: Request) {
    const ip = // 保留你的IP获取逻辑
    const sha256 = crypto.createHmac("sha256", process.env.SALT!);
    const ipHashDigest = sha256.update(ip!).digest("hex");

    const limitCheck = await surveyRepository.checkAndUpdateCreatorIpLimit(ipHashDigest);
    if (!limitCheck.allowed) {
        return NextResponse.json({ "error": "API Limit is reached" }, { status: 429 });
    }

    const uuid = uuidv4();
    const survey = await request.json();
    await surveyRepository.createSurvey(survey, ipHashDigest, uuid);

    return NextResponse.json({ "survey-id": uuid }, { status: 201 });
}

4. 后续更换数据库的成本

比如换成PostgreSQL，仅需两步：

• 新建app/repositories/postgres.survey.repository.ts，实现SurveyRepository接口
• 修改路由中的导入，将mongodb.survey.repository替换为postgres.survey.repository
• 无需修改路由内的任何业务逻辑

可选：用tsyringe实现函数式路由的依赖注入 #

如果希望用DI容器进一步解耦，可按以下步骤配置：

1. 安装依赖：

npm install tsyringe reflect-metadata

2. 修改tsconfig.json启用装饰器：

{
  "compilerOptions": {
    "experimentalDecorators": true,
    "emitDecoratorMetadata": true
  }
}

3. 给MongoDB Repository添加@injectable()装饰器：

// app/repositories/mongodb.survey.repository.ts
import { injectable } from 'tsyringe';
// ...其他导入

@injectable()
export class MongoDBSurveyRepository implements SurveyRepository {
  // ...实现代码不变
}

4. 创建DI容器配置文件app/di.container.ts：

// app/di.container.ts
import { container } from 'tsyringe';
import { SurveyRepository } from './repositories/survey.repository';
import { MongoDBSurveyRepository } from './repositories/mongodb.survey.repository';

container.registerSingleton<SurveyRepository>(SurveyRepository, MongoDBSurveyRepository);

5. 在路由中获取实例：

// app/api/route.ts
import { container } from 'tsyringe';
import '@/app/di.container';
import { SurveyRepository } from '@/app/repositories/survey.repository';
// ...其他导入

export async function POST(request: Request) {
    const surveyRepository = container.resolve(SurveyRepository);
    // ...后续逻辑与之前一致
}

这种方式更换数据库时，仅需修改容器配置中的注册类，连路由导入都无需改动。

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