Clean Architecture是什么？怎么用Node实现？

2023-05-14 22:23

短信预约 -IT技能 免费直播动态提醒

用户创建，查询
帖子的发布，编辑，查询，删除

项目结构

├── server
│   ├── core // 核心业务逻辑
│   │   └── class="lazy" data-src
│   │       ├── domain
│   │       ├── repository
│   │       └── useCase
│   ├── koa
│   │   └── class="lazy" data-src
│   │       ├── post
│   │       └── user
│   └── nestjs-app
│       ├── class="lazy" data-src
│           ├── post
│           │   ├── dto
│           │   └── entities
│           └── user
│               └── entities
└── web

core：core为核心业务逻辑的代码
- Domain: 存放实体相关的代码，如业务具体的 model 等
- Use Cases: 存放业务逻辑相关的代码，如处理业务逻辑、数据验证、调用 Repository 等
- Repository: 存放和外部存储系统的相关接口
koa/nestjs-app: core的实际消费者
- 根据core的接口实现具体的Router，Repository

项目特点

使用 DDD 和 Clean Architecture 的思想，将业务逻辑与框架实现分离。
使用 monorepo 项目结构，方便管理多个相关的项目。
提供了多个示例应用程序，方便快速上手。
基于 TypeScript，提高代码可读性和可维护性。

在core中，我们有核心的业务逻辑代码。此级别包含域、存储库接口和用例。域包含与实体相关的代码，例如特定的业务模型。存储库包含与外部存储系统的相关接口。用例包含与业务逻辑相关的代码，例如处理业务逻辑、数据验证和调用存储库。

在koa/nestjs-app层面，我们有核心层面的实际消费者。它们根据核心层提供的接口实现特定的路由器和存储库。使用 Clean Architecture 的主要优点之一是它将业务逻辑与技术实现分开。这意味着您可以轻松地在不同的框架和库之间切换，而无需更改核心业务逻辑。在我们的示例中，我们可以在 koa 和 nestjs-app 之间切换，同时保持相同的核心业务逻辑。

代码实现

定义实体层

// server/core/class="lazy" data-src/domain/post.ts
import { User } from "./user";

export class Post {
  author: User | null = null;
  content: string = "";
  updateAt: Date = new Date(); // timestamp;
  createdAt: Date = new Date(); // timestamp;
  title: string = "";
  id: number = -1;
}

// server/core/class="lazy" data-src/domain/user.ts
export class User {
  name: string = ''

  email: string = ''

  id: number = -1
}

定义存储接口

import { Post } from "../domain/post";

export interface IPostRepository {
  create(post: Post): Promise<boolean>;

  find(id: number): Promise<Post>;

  update(post: Post): Promise<boolean>;

  delete(post: Post): Promise<boolean>;

  findMany(options: { authorId: number }): Promise<Post[]>;
}

...
import { User } from "../domain/user";

export interface IUserRepository {
  create(user: User): Promise<boolean>;
  find(id: number): Promise<User>;
}

定义用例层

import { User } from "../domain/user";
import { IUserRepository } from "../repository/user";

export class UCUser {
  constructor(public userRepo: IUserRepository) {}

  find(id: number) {
    return this.userRepo.find(id);
  }

  create(name: string, email: string) {
    if (email.includes("@test.com")) {
      const user = new User();
      user.email = email;
      user.name = name;
      return this.userRepo.create(user);
    }
    throw Error("Please use legal email");
  }
}

koa项目

在koa项目中实现存储层接口

// server/koa/class="lazy" data-src/user/user.repo.ts
import { PrismaClient } from "@prisma/client";
import { IUserRepository, User } from "core";

export class UserRepository implements IUserRepository {
  prisma = new PrismaClient();

  async create(user: User): Promise<boolean> {
    const d = await this.prisma.user_orm_entity.create({
      data: {
        email: user.email,
        name: user.name,
      },
    });

    return !!d;
  }

  async find(id: number): Promise<User> {
    const d = await this.prisma.user_orm_entity.findFirst({
      where: {
        id: id,
      },
    });

    if (d) {
      const u = new User();
      u.email = d?.email;
      u.id = d?.id;
      u.name = d?.name;
      return u;
    }
    throw Error("user id " + id + "not found");
  }
}

在koa项目中实现HTTP路由（表现层）

// server/koa/class="lazy" data-src/user/user.controller.ts
import Router from "@koa/router";
import { UCUser } from "core";
import { UserRepository } from "./user.repo";

export const userRouter = new Router({
  prefix: "/user",
});

userRouter.get("/:id", async (ctx, next) => {
  try {
    const service = new UCUser(new UserRepository());
    if (ctx.params.id) {
      const u = await service.find(+ctx.params.id);
      ctx.response.body = JSON.stringify(u);
    }
  } catch (e) {
    ctx.throw(400, "some error on get user", e.message);
  }
  await next();
});