学完这篇 Nest.js 实战,还没入门的来锤我!(长文预警)

2021-11-30 13:55:35 浏览数 (1)

前言

最近一直比较忙, 而且自己工作中做的事也不适合写文章,所以一直没有更文..

最近接到一个小需求,需要自己全干(前端 后端),看到群里大家对Nest.js热情都很高,自己也心痒痒,所以就走上了Nest.js的不归路~

我会将自己做这个小项目过程记录下来,同时也分享一些踩坑的经验,给想学的小伙伴一点参考吧。文章是循序渐进的, 并不是一上来就是深入Nest.js难点, 但是每一章都有一些开发注意点和自己的思考, 欢迎大佬们指点一二。

为什么选择Nest.js

前面也说了, 大家都说香啊~

其次,我之前也使用过Egg.js,19年使用的时候,感觉egg约束性比较强,但是对于内部统一规范还是有好处的,但现在2021了, 已经习惯了TS,但Egg.js没有原生提供的TypeScript支持, 开发时可使用egg-ts-helper 来帮助自动生成 d.ts 文件,这样第三方库的支持完全不受控制, 风险还是很大, 所有选择放弃了

说了这么多,接下来开始吧!文章主要包含以下内容:

初识 Nest.js

Nest.js官网介绍:

Nest (NestJS) 是一个用于构建高效、可扩展的 Node.js 服务器端应用程序的开发框架。它利用JavaScript 的渐进增强的能力,使用并完全支持 TypeScript (仍然允许开发者使用纯 JavaScript 进行开发),并结合了 OOP (面向对象编程)、FP (函数式编程)和 FRP (函数响应式编程)。 在底层,Nest 构建在强大的 HTTP 服务器框架上,例如 Express (默认),并且还可以通过配置从而使用 Fastify ! Nest 在这些常见的 Node.js 框架 (Express/Fastify) 之上提高了一个抽象级别,但仍然向开发者直接暴露了底层框架的 API。这使得开发者可以自由地使用适用于底层平台的无数的第三方模块。

上面这段话刚开始并不能完全理解, 但是简单可以解读出来Nest.js的几个特点:

  • 原生支持TypeScript的框架
  • 可以基于Express也可以选择fastify, 如果你对Express非常熟练, 直接用它的API也是没问题的

至于其他看不懂,就暂时放一边, 因为不影响我们入门,后面深入学习后会再来分析。

项目创建

首先确定你已经安装了Node.js, Node.js 安装会附带npx和一个npm 包运行程序。要创建新的Nest.js 应用程序,请在终端上运行以下命令:

代码语言:javascript复制
npm i -g @nestjs/cli  // 全局安装Nest
nest new project-name  // 创建项目

执行完创建项目, 会初始化下面这些文件, 并且询问你要是有什么方式来管理依赖包:

如果你有安装yarn,可以选择yarn,能更快一些,npm在国内安装速度会慢一些,我这里就用npm下载了。这里省略一个漫长的等待过程~, 终于看到了它成功了(然后我又删除了,使用yarn,确实速度快了很多)

接下来按照提示运行项目:

这里说一下我安装的环境,Nest.js版本不同有些API会有差异

版本

Node.js

v12.16.1

npm

6.13.4

nest.js

8.1.4

typescript

4.3.5

注意:Nest.js 要求 Node.js(>= 10.13.0,v13 除外), 如果你的Node.js 版本不满足要求,可以通过nvm包管理工具安装符合要求的Node.js版本

项目结构

进入项目,看到的目录结构应该是这样的:

这里简单说明一下这些核心文件:

代码语言:javascript复制
src
├── app.controller.spec.ts
├── app.controller.ts
├── app.module.ts
├── app.service.ts
├── main.ts

app.controller.ts

单个路由的基本控制器(Controller)

app.controller.spec.ts

针对控制器的单元测试

app.module.ts

应用程序的根模块(Module)

app.service.ts

具有单一方法的基本服务(Service)

main.ts

应用程序的入口文件,它使用核心函数 NestFactory 来创建 Nest 应用程序的实例。

第一个接口

前面我们已经启动了服务, 那我们怎么查看呢, 首先就是找到入口文件main.ts

代码语言:javascript复制
import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  await app.listen(3000);
}
bootstrap();

内容比较简单, 使用Nest.js的工厂函数NestFactory来创建了一个AppModule实例,启动了 HTTP 侦听器,以侦听main.ts 中所定义的端口。

监听的端口号可以自定义, 如果3000端口被其他项目使用,可以更改为其他的端口号 因为我的3000端口有别的项目在用, 所以修改成:9080,重新启动项目

我们打开浏览器访问http://localhost:9080地址:

这里看到的Hello World就是接口地址http://localhost:9080返回的内容, 不信我们也可以使用常用 Postman看看:

说明Nest.js创建项目默认就给写了一个接口例子,那就通过这个接口例子来看,我们应该怎么实现一个接口。

前边看到mian.ts中也没有别的文件引入, 只有AppModule, 打开src/app.module.ts:

代码语言:javascript复制
import { Module } from '@nestjs/common';
import { AppController } from './app.controller';
import { AppService } from './app.service';

@Module({
  imports: [],
  controllers: [AppController],
  providers: [AppService],
})
export class AppModule {}

AppModule是应用程序的根模块,根模块提供了用来启动应用的引导机制,可以包含很多功能模块。

.mudule文件需要使用一个@Module() 装饰器的类,装饰器可以理解成一个封装好的函数,其实是一个语法糖(对装饰器不了解的,可以看走近MidwayJS:初识TS装饰器与IoC机制)。@Module() 装饰器接收四个属性:providerscontrollersimportsexports

  • providers:Nest.js注入器实例化的提供者(服务提供者),处理具体的业务逻辑,各个模块之间可以共享(注入器的概念后面依赖注入部分会讲解);
  • controllers:处理http请求,包括路由控制,向客户端返回响应,将具体业务逻辑委托给providers处理;
  • imports:导入模块的列表,如果需要使用其他模块的服务,需要通过这里导入;
  • exports:导出服务的列表,供其他模块导入使用。如果希望当前模块下的服务可以被其他模块共享,需要在这里配置导出;

如果你是Vue或者React技术栈,初次接触Nest.js,可能会觉得很面生啊, 其实很正常,Nest.js的思维方式一开始确实不容易理解,但假如你接触过AngularJS,就会感到熟悉,如果你用过 Java 和 Spring 的话,就可能会想,这不是抄的 Spring boot嘛!

确实AngularJSSpringNest.js都是基于控制反转原则设计的,而且都使用了依赖注入的方式来解决解耦问题。如果你觉得一头雾水, 别急,这些问题后面深入学习都会一一讲解的。这里我们还是照葫芦画瓢,学一下Nest究竟怎么使用的。

app.module.ts中,看到它引入了app.controller.tsapp.service.ts,分别看一下这两个文件:

代码语言:javascript复制
// app.controller.ts
import { Controller, Get } from '@nestjs/common';
import { AppService } from './app.service';

@Controller()
export class AppController {
  constructor(private readonly appService: AppService) {}

  @Get()
  getHello(): string {
    return this.appService.getHello();
  }
}

使用@Controller装饰器来定义控制器, @Get是请求方法的装饰器,对getHello方法进行修饰, 表示这个方法会被GET请求调用。

代码语言:javascript复制
// app.service.ts
import { Injectable } from '@nestjs/common';

@Injectable()
export class AppService { 
  getHello(): string {
    return 'Hello World!';
  }
}

从上面,我们可以看出使用@Injectable修饰后的 AppService, 在AppModule中注册之后,在app.controller.ts中使用,我们就不需要使用new AppService()去实例化,直接引入过来就可以用。

至此,对于http://localhost:9080/接口返回的Hello World逻辑就算理清楚了, 在这基础上我们再详细的学习一下Nest.js中的路由使用。

路由装饰器

Nest.js中没有单独配置路由的地方,而是使用装饰器。Nest.js中定义了若干的装饰器用于处理路由。

@Controller

如每一个要成为控制器的类,都需要借助@Controller装饰器的装饰,该装饰器可以传入一个路径参数,作为访问这个控制器的主路径:

app.controller.ts文件进行修改

代码语言:javascript复制
// 主路径为 app
@Controller("app")
export class AppController {
  constructor(private readonly appService: AppService) {}

  @Get()
  getHello(): string {
    return this.appService.getHello();
  }
}

然后重新启一下服务,此时再去访问http://localhost:9080/会发现404了。

就是由于通过@Controller("app")修改这个控制器的路由前缀为app, 此时可以通过http://localhost:9080/app来访问。

HTTP方法处理装饰器

@Get@Post@Put等众多用于HTTP方法处理装饰器,经过它们装饰的方法,可以对相应的HTTP请求进行响应。同时它们可以接受一个字符串或一个字符串数组作为参数,这里的字符串可以是固定的路径,也可以是通配符。

继续修改app.controller.ts,看下面的例子:

代码语言:javascript复制
// 主路径为 app
@Controller("app")
export class AppController {
  constructor(private readonly appService: AppService) {}
  
  // 1. 固定路径:
  // 可以匹配到 get请求,http://localhost:9080/app/list
  @Get("list")
  getHello(): string {...}
  
  // 可以匹配到 post请求,http://localhost:9080/app/list
  @Post("list")
  create():string{...}
  
  // 2.通配符路径(? * 三种通配符 )
  // 可以匹配到 get请求, http://localhost:9080/app/user_xxx
  @Get("user_*")
  getUser(){return "getUser"}
  
  // 3.带参数路径
  // 可以匹配到put请求,http://localhost:9080/app/list/xxxx
  @Put("list/:id")
  update(){ return "update"}
}
  

由于修改了文件, 需要重启才能看到路由, 每次都重启简直就是噩梦,本来打算配置一个实时监听文件变化,发现Nest.js非常贴心的配置好了, 我们只要运行命令即可:

代码语言:javascript复制
npm run start:dev

这样再修改什么内容, 保存后都会自动重启服务了。

这里要提一个关于路由匹配时的注意点, 当我们有一个put请求,路径为/app/list/user,此时,我们在app.controller.ts控制器文件中增加一个方法:

代码语言:javascript复制
 @Put("list/user")
 updateUser(){
      return {userId:1}
  }

你觉得这个路由会被匹配到吗?我们测试一下:

发现/app/list/user匹配到的并不是updateUser方法, 而是update方法。这就是我要说的注意点。

如果因为在匹配过程中, 发现@Put("list/:id")已经满足了,就不会继续往下匹配了,所以@Put("list/user")装饰的方法应该写在它之前。

全局路由前缀

除了上面这些装饰器可以设置路由外, 我们还可以设置全局路由前缀, 比如给所以路由都加上/api前缀。此时需要修改main.ts

代码语言:javascript复制
async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.setGlobalPrefix('api'); // 设置全局路由前缀
  await app.listen(9080);
}
bootstrap();

此时之前的路由,都要变更为:

代码语言:javascript复制
http://localhost/api/xxxx

到此我们认识了ControllerServiceModule、路由以及一些常用的装饰器, 那接下来就实战一下,我们以开发文章(Post)模块作为案例, 实现文章简单的CRUD,带大家熟悉一下这个过程。

编写代码

写代码之前首先介绍几个nest-cli提供的几个有用的命令:

代码语言:javascript复制
//语法
nest g [文件类型] [文件名] [文件目录]
  • 创建模块

nest g mo posts 创建一个 posts模块,文件目录不写,默认创建和文件名一样的posts目录,在posts目录下创建一个posts.module.ts

代码语言:javascript复制
// src/posts/posts.module.ts
import { Module } from '@nestjs/common';

@Module({})
export class PostsModule {}

执行完命令后,我们还可以发现同时在根模块app.module.ts中引入PostsModule这个模块,也在@Model装饰器的inports中引入了PostsModule

代码语言:javascript复制
import { Module } from '@nestjs/common';
import { AppController } from './app.controller';
import { AppService } from './app.service';
import { PostsModule } from './posts/posts.module';

@Module({
  controllers: [AppController],
  providers: [AppService],
  imports: [PostsModule],
})
export class AppModule {}
  • 创建控制器

nest g co posts

此时创建了一个posts控制器,命名为posts.controller.ts以及一个该控制器的单元测试文件.

代码语言:javascript复制
// src/posts/posts.controller.ts
import { Controller } from '@nestjs/common';

@Controller('posts')
export class PostsController {}

执行完命令, 文件posts.module.ts中会自动引入PostsController,并且在@Module装饰器的controllers中注入。

  • 创建服务类

nest g service posts

代码语言:javascript复制
// src/posts/posts.service.ts
import { Injectable } from '@nestjs/common';

@Injectable()
export class PostsService {}

创建app.service.ts文件,并且在app.module.ts文件下,@Module装饰器的providers中注入注入。

其实nest-cli提供的创建命令还有很多, 比如创建过滤器、拦截器和中间件等,由于这里暂时用不到,就不过多的介绍,后面章节用到了再介绍。

注意创建顺序:先创建Module, 再创建ControllerService, 这样创建出来的文件在Module中自动注册,反之,后创建Module, ControllerService,会被注册到外层的app.module.ts

看一下现在的目录结构:

连接Mysql

路由生效了,既然是后端项目,必须得用上数据库,不然和写静态页面自己玩没什么区别。

数据库我选择的是Mysql,毕竟实际项目中大多数还是选择它的。因为文章属于从零教程, 所以会包含数据库的安装、连接、使用以及使用过程遇到的坑,如果你是有经验的老手,可以跳过这部分。

数据库安装

如果你电脑里没有mysql数据库, 也没有云数据库, 那首先在本地安装一个mysql,通过官网下载

选择你需要的MySQL Community Server 版本及对应的平台:

Windows 上安装 MySQL 相对来说会较为简单, 就和安装一个应用程序差不多, 具体可以跟着# Windows下MySQL的详细安装教程一步步操作, 这里就不赘述了。

接下来用可视化工具来管理数据库,常用的有SQLyog或者Navicat Premium,什么顺手用什么吧,我用习惯了Navicat for MySQL,这里就以它来进行演示:

首先连接上数据库:

然后新建一个数据库blog:

点开创建的blog,里面什么也没有,我们可以在这里手动创建表, 也可以后面使用代码创建,这里我选择后者。

TypeORM连接数据库

前置知识

首先,简单说一下什么是ORM?

我们如果直接使用Node.js操作mysql提供的接口, 那么编写的代码就比较底层, 例如一个插入数据代码:

代码语言:javascript复制
// 向数据库中插入数据 
connection.query(`INSERT INTO posts (title, content) VALUES ('${title}', '${content}')`,
    (err, data) => {
    if (err) { 
    console.error(err) 
    } else {
    console.log(data) 
    }
})

考虑到数据库表是一个二维表,包含多行多列,例如一个posts的表:

代码语言:javascript复制
mysql> select * from posts;
 ---- -------- ------------ 
| id | title       | content      |
 ---- ------------- -------------- 
|  1 | Nest.js入门 | 文章内容描述 |
 ---- -------- ------------ 

每一行可以用一个JavaScript对象来表示, 比如第一行:

代码语言:javascript复制
{
    id: 1,
    title:"Nest.js入门",
    content:"文章内容描述"
}

这就是传说中的ORM技术(Object-Relational Mapping),把关系数据库的变结构映射到对象上。

所以就出现了SequelizetypeORMPrisma这些ORM框架来做这个转换, (ps:Prisma呼声很高,喜欢探索的可以尝试婴一下)我们这里选择typeORM来操作数据库。这样我们读写都是JavaScript对象,比如上面的插入语句就可以这样实现:

代码语言:javascript复制
await connection.getRepository(Posts).save({title:"Nest.js入门", content:"文章内容描述"});

接下来就是真正意义上的使用typeORM操作数据库, 首先我们要安装以下依赖包:

代码语言:javascript复制
npm install @nestjs/typeorm typeorm mysql2 -S

官方提供了两种连接数据库的方法, 这里分别介绍一下:

方法1

首先在项目根目录下创建两个文件.env.env.prod,分别存的是开发环境和线上环境不同的环境变量:

代码语言:javascript复制
// 数据库地址
DB_HOST=localhost  
// 数据库端口
DB_PORT=3306
// 数据库登录名
DB_USER=root
// 数据库登录密码
DB_PASSWD=root
// 数据库名字
DB_DATABASE=blog

.env.prod中的是上线要用的数据库信息,如果你的项目要上传到线上管理,为了安全性考虑,建议这个文件添加到.gitignore中。

接着在根目录下创建一个文件夹config(与src同级),然后再创建一个env.ts用于根据不同环境读取相应的配置文件。

代码语言:javascript复制
import * as fs from 'fs';
import * as path from 'path';
const isProd = process.env.NODE_ENV === 'production';

function parseEnv() {
  const localEnv = path.resolve('.env');
  const prodEnv = path.resolve('.env.prod');

  if (!fs.existsSync(localEnv) && !fs.existsSync(prodEnv)) {
    throw new Error('缺少环境配置文件');
  }

  const filePath = isProd && fs.existsSync(prodEnv) ? prodEnv : localEnv;
  return { path:filePath };
}
export default parseEnv();

然后在app.module.ts中连接数据库:

代码语言:javascript复制
import { TypeOrmModule } from '@nestjs/typeorm';
import { ConfigService, ConfigModule } from '@nestjs/config';
import envConfig from '../config/env';

@Module({
  imports: [
    ConfigModule.forRoot({ 
    isGlobal: true,  // 设置为全局
    envFilePath: [envConfig.path] 
   }),
    TypeOrmModule.forRootAsync({
      imports: [ConfigModule],
      inject: [ConfigService],
      useFactory: async (configService: ConfigService) => ({
        type: 'mysql', // 数据库类型
        entities: [],  // 数据表实体
        host: configService.get('DB_HOST', 'localhost'), // 主机,默认为localhost
        port: configService.get<number>('DB_PORT', 3306), // 端口号
        username: configService.get('DB_USER', 'root'),   // 用户名
        password: configService.get('DB_PASSWORD', 'root'), // 密码
        database: configService.get('DB_DATABASE', 'blog'), //数据库名
        timezone: ' 08:00', //服务器上配置的时区
        synchronize: true, //根据实体自动创建数据库表, 生产环境建议关闭
      }),
    }),
    PostsModule,
  ],
 ...
})
export class AppModule {}

使用环境变量, 推荐使用官方提供的@nestjs/config,开箱即用。简单说明一下

@nestjs/config依赖于dotenv,可以通过key=value形式配置环境变量,项目会默认加载根目录下的.env文件,我们只需在app.module.ts中引入ConfigModule,使用ConfigModule.forRoot()方法即可,然后ConfigService读取相关的配置变量。

TypeORM提供了多种连接方式,这里再介绍一下使用ormconfig.json方式

方法2

在根目录下创建一个ormconfig.json文件(与src同级), 而不是将配置对象传递给forRoot()的方式。

代码语言:javascript复制
{ 
    "type": "mysql",
    "host": "localhost", 
    "port": 3306, 
    "username": "root", 
    "password": "root", 
    "database": "blog", 
    "entities": ["dist/**/*.entity{.ts,.js}"], 
    "synchronize": true  // 自动载入的模型将同步
}

然后在app.module.ts中不带任何选项的调用forRoot(), 这样就可以了,想了解更多连接数据库的方式可以去有TypeORM官网查看

代码语言:javascript复制
import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';

@Module({ 
    imports: [TypeOrmModule.forRoot()],
})
export class AppModule {}

好了,数据库连接成功, 如果你连接失败, 会有这样的错误信息:

检查一下自己数据库的配置是否正确。

CRUD

好了,接下来就进行数据操作,前面我们说通过代码来建表, TypeORM是通过实体映射到数据库表,所以我们先建立一个文章实体PostsEntity,在posts目录下创建posts.entity.ts

代码语言:javascript复制
//    posts/posts.entity.ts
import { Column, Entity, PrimaryGeneratedColumn } from "typeorm";

@Entity("posts")
export class PostsEntity {
    @PrimaryGeneratedColumn()
    id:number; // 标记为主列,值自动生成

    @Column({ length:50 })
    title: string;

    @Column({ length: 20})
    author: string;

    @Column("text")
    content:string;

    @Column({default:''})
    thumb_url: string;

    @Column('tinyint')
    type:number

    @Column({type: 'timestamp', default: () => "CURRENT_TIMESTAMP"})
    create_time: Date

    @Column({type: 'timestamp', default: () => "CURRENT_TIMESTAMP"})
    update_time: Date
}

接下来在posts.service.ts文件中实现CRUD操作的业务逻辑,这里的表并不是最终的文章表,只是为了先实现一下简单的增删改查接口, 后面还会实现复杂的多表关联。

代码语言:javascript复制
import { HttpException, Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { getRepository, Repository } from 'typeorm';
import { PostsEntity } from './posts.entity';

export interface PostsRo {
  list: PostsEntity[];
  count: number;
}
@Injectable()
export class PostsService {
  constructor(
    @InjectRepository(PostsEntity)
    private readonly postsRepository: Repository<PostsEntity>,
  ) {}

  // 创建文章
  async create(post: Partial<PostsEntity>): Promise<PostsEntity> {
    const { title } = post;
    if (!title) {
      throw new HttpException('缺少文章标题', 401);
    }
    const doc = await this.postsRepository.findOne({ where: { title } });
    if (doc) {
      throw new HttpException('文章已存在', 401);
    }
    return await this.postsRepository.save(post);
  }
  
  // 获取文章列表
  async findAll(query): Promise<PostsRo> {
    const qb = await getRepository(PostsEntity).createQueryBuilder('post');
    qb.where('1 = 1');
    qb.orderBy('post.create_time', 'DESC');

    const count = await qb.getCount();
    const { pageNum = 1, pageSize = 10, ...params } = query;
    qb.limit(pageSize);
    qb.offset(pageSize * (pageNum - 1));

    const posts = await qb.getMany();
    return { list: posts, count: count };
  }

  // 获取指定文章
  async findById(id): Promise<PostsEntity> {
    return await this.postsRepository.findOne(id);
  }

  // 更新文章
  async updateById(id, post): Promise<PostsEntity> {
    const existPost = await this.postsRepository.findOne(id);
    if (!existPost) {
      throw new HttpException(`id为${id}的文章不存在`, 401);
    }
    const updatePost = this.postsRepository.merge(existPost, post);
    return this.postsRepository.save(updatePost);
  }

  // 刪除文章
  async remove(id) {
    const existPost = await this.postsRepository.findOne(id);
    if (!existPost) {
      throw new HttpException(`id为${id}的文章不存在`, 401);
    }
    return await this.postsRepository.remove(existPost);
  }
}

保存文件, 报错信息提示PostsEntity没有导入:

此时在posts.module.ts中将PostsEntity导入:

代码语言:javascript复制
import { TypeOrmModule } from '@nestjs/typeorm';
@Module({
  imports: [TypeOrmModule.forFeature([PostsEntity])],
  ...
})

如果你是按照文章进行,使用第一种方式连接数据库,这里还有一个小坑找不到PostsEntity实体

No repository for "PostsEntity" was found. Looks like this entity is not registered in current "default" connection?

是由于我们连接数据库时,没有注册它, 所有还需要在app.module.ts添加一下:

然后采用REST风格来实现接口,我们可以在posts.controller.ts中设置路由了,处理接口请求,调用相应的服务完成业务逻辑:

代码语言:javascript复制
import { PostsService, PostsRo } from './posts.service';
import { Body, Controller, Delete, Get, Param, Post, Put, Query } from '@nestjs/common';

@Controller('post')
export class PostsController {
    constructor(private readonly postsService:PostsService){}

    /**
     * 创建文章
     * @param post
     */
    @Post()
    async create(@Body() post){
        return await this.postsService.create(post)
    }

    /**
     * 获取所有文章
     */
    @Get()
    async findAll(@Query() query):Promise<PostsRo>{
        return await this.postsService.findAll(query)
    }

    /**
     * 获取指定文章
     * @param id 
     */
    @Get(':id')
    async findById(@Param('id') id) {
        return await this.postsService.findById(id)
    }

    /**
     * 更新文章
     * @param id 
     * @param post 
     */
    @Put(":id")
    async update(@Param("id") id, @Body() post){
        return await this.postsService.updateById(id, post)
    }

    /**
     * 删除
     * @param id 
     */
    @Delete("id")
    async remove(@Param("id") id){
        return await this.postsService.remove(id)
    }
}

操作数据库踩过的坑

  1. 实体的强替换,莫名其妙的删表,清空数据 以我们上面设置的实体为例:
代码语言:javascript复制
export class PostsEntity {
    @PrimaryGeneratedColumn()
    id: number;

    @Column()
    title: string;
}

最开初我设计表中title字段时,字段类型直接设置成string,也就对应数据库类型是varchar(255),后来觉得不合适,对长度进行了限制, 更改为varchar(50),也就是这样修改一下代码:

代码语言:javascript复制
 @Column({length: 50})
    title: string;

保存代码后,结果!我数据库中所以的title都被清空了,这个坑真是谁踩谁知道~

  1. entities的三种设置方式 这个坑前面我们其实算踩了一下, 就是每次创建一个实体, 都要在链接数据库的地方导入,想想都挺鸡肋的。官方倒是给了3种方式,这里都说一下各种方式的坑点:

方式1:单独定义

代码语言:javascript复制
TypeOrmModule.forRoot({
  //...
  entities: [PostsEntity, UserEntity],
}),]

就是用到哪些实体, 就逐一的在连接数据库时去导入,缺点就是麻烦,很容易忘记~

方式2:自动加载

代码语言:javascript复制
 TypeOrmModule.forRoot({
  //...
  autoLoadEntities: true,
}),]

自动加载我们的实体,每个通过forFeature()注册的实体都会自动添加到配置对象的entities数组中, forFeature()就是在某个service中的imports里面引入的, 这个是我个人比较推荐的,实际开发我用的也是这种方式。

**方式3:配置路径自动引入 **

代码语言:javascript复制
 TypeOrmModule.forRoot({
      //...
      entities: ['dist/**/*.entity{.ts,.js}'],
    }),]

通过配置的路径, 自动去导入实体。

这种方式就是前面介绍连接数据库第二种方式中使用的, But~超级不推荐。给你呈现一下我当时踩得坑:

  1. 当时写了一个Category实体, 然后想增加一个Tag实体
  2. 复制了category.entity.ts,放到tag文件夹下,并且更名为tag.entiry.ts
  3. 修改了内部的属性(删的删,改的改), 变成了一个Tag实体,开心的保存了
  4. 但是,我忘记了修改类名, 所以我的category表被清空了, 里面数据都没了~

就上面这两个坑,如果你是空数据库, 你随便折腾, 但是你数据库中有数据的童鞋, 建议一定要谨慎点, 连接数据库时, 上来先把synchronize:false设置上, 保命要紧

到这里我们就实现了简单的数据库增删改查操作, 是不是很简单, 我们试着用Postman来测试一下接口。

作为一个前端开发, 实际开发中给你这样的接口,你开森吗~,估计心里鄙视后端千百遍吧!(os:什么破接口,请求状态码不规范,返回数据格式不规范....), 己所不欲勿施于人,赶紧优化一下

接口格式统一

一般开发中是不会根据HTTP状态码来判断接口成功与失败的, 而是会根据请求返回的数据,里面加上code字段

首先定义返回的json格式:

代码语言:javascript复制
{
    "code": 0,
    "message": "OK",
    "data": {
    }
}

请求失败时返回:

代码语言:javascript复制
{
    "code": -1,
    "message": "error reason",
    "data": {}
}

拦截错误请求

首先使用命令创建一个过滤器:

代码语言:javascript复制
nest g filter core/filter/http-exception

过滤器代码实现:

代码语言:javascript复制
import {ArgumentsHost,Catch, ExceptionFilter, HttpException} from '@nestjs/common';

@Catch(HttpException)
export class HttpExceptionFilter implements ExceptionFilter {
  catch(exception: HttpException, host: ArgumentsHost) {
    const ctx = host.switchToHttp(); // 获取请求上下文
    const response = ctx.getResponse(); // 获取请求上下文中的 response对象
    const status = exception.getStatus(); // 获取异常状态码

    // 设置错误信息
    const message = exception.message
      ? exception.message
      : `${status >= 500 ? 'Service Error' : 'Client Error'}`;
    const errorResponse = {
      data: {},
      message: message,
      code: -1,
    };

    // 设置返回的状态码, 请求头,发送错误信息
    response.status(status);
    response.header('Content-Type', 'application/json; charset=utf-8');
    response.send(errorResponse);
  }
}

最后需要在main.ts中全局注册

代码语言:javascript复制
...
import { HttpExceptionFilter } from './core/filter/http-exception.filter';

async function bootstrap() {
  const app = await NestFactory.create<NestExpressApplication>(AppModule);
  ...
   // 注册全局错误的过滤器
  app.useGlobalFilters(new HttpExceptionFilter());
  await app.listen(9080);
}
bootstrap();

这样对请求错误就可以统一的返回了,返回请求错误只需要抛出异常即可,比如之前的:

代码语言:javascript复制
 throw new HttpException('文章已存在', 401);

接下来对请求成功返回的格式进行统一的处理,可以用Nest.js的拦截器来实现。

拦截成功的返回数据

首先使用命令创建一个拦截器:

代码语言:javascript复制
nest g interceptor core/interceptor/transform

拦截器代码实现:

代码语言:javascript复制
import {CallHandler, ExecutionContext, Injectable,NestInterceptor,} from '@nestjs/common';
import { map, Observable } from 'rxjs';

@Injectable()
export class TransformInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    return next.handle().pipe(
      map((data) => {
        return {
          data,
          code: 0,
          msg: '请求成功',
        };
      }),
    );
  }
}

最后和过滤器一样,在main.ts中全局注册:

代码语言:javascript复制
...
import { TransformInterceptor } from './core/interceptor/transform.interceptor';

async function bootstrap() {
  const app = await NestFactory.create<NestExpressApplication>(AppModule);
  ...
  // 全局注册拦截器
  app.useGlobalFilters(new HttpExceptionFilter());
  await app.listen(9080);
}
bootstrap();

过滤器和拦截器实现都是三部曲:创建 > 实现 > 注册,还是很简单的。

现在我们再试试接口,看看返回的数据格式是不是规范了?

一名合格的前端,你对我说:"这是接口地址xxx, 用postman执行一下就能看到返回结果",这完全就是在挑衅, 鬼知道你每个字段什么意思,每个接口需要传什么参数,哪些参数必传,哪些可选....

反正要是我拿到这样的接口,肯定会喷~

配置接口文档Swagger

所以我们接下来就讲一下怎么写接口文档,既高效又实用。我这里用swagger,用它的原因一方面是 Nest.js提供了专用的模块来使用它,其次可以精确的展示每个字段意义,只要注解写的到位!

说心里话, 使用体验一般般,只能说还行

首先安装一下:

代码语言:javascript复制
npm install @nestjs/swagger swagger-ui-express -S

我这里安装的版本是:5.1.4, 和4.x.x版本相比有些API的变动。

接下来需要在main.ts中设置Swagger文档信息:

代码语言:javascript复制
...
import { SwaggerModule, DocumentBuilder } from '@nestjs/swagger';

async function bootstrap() {
  const app = await NestFactory.create<NestExpressApplication>(AppModule);
  ...
  // 设置swagger文档
  const config = new DocumentBuilder()
    .setTitle('管理后台')   
    .setDescription('管理后台接口文档')
    .setVersion('1.0')
    .addBearerAuth()
    .build();
  const document = SwaggerModule.createDocument(app, config);
  SwaggerModule.setup('docs', app, document);

  await app.listen(9080);
}
bootstrap();

配置完成,我们就可以访问:http://localhost:9080/docs,此时就能看到Swagger生成的文档:

我们写的路由都展示出来了,但是我们就这么看,找需要的接口也太难了,而且这些接口仍然没有任何注释,还是看不懂啊~

接口标签

我们可以根据Controller来分类, 只要添加@ApiTags就可以

代码语言:javascript复制
...
import { ApiTags } from '@nestjs/swagger';
import { Body, Controller, Delete, Get, Param, Post, Put, Query } from '@nestjs/common';

@ApiTags("文章")
@Controller('post')
export class PostsController {...}

posts.controller.tsapp.controller.ts 都分别加上分类标签,刷新Swagger文档,看到的效果是这样的:

接口说明

进一步优化文档, 给每一个接口添加说明文字, 让使用的人直观的看到每个接口的含义,不要让使用的人去猜。同样在Controller中, 在每一个路由的前面使用@ApiOperation装饰器:

代码语言:javascript复制
//  posts.controller.ts
...
import { ApiTags,ApiOperation } from '@nestjs/swagger';
export class PostsController {

  @ApiOperation({ summary: '创建文章' })
  @Post()
  async create(@Body() post) {....}
  
  @ApiOperation({ summary: '获取文章列表' })
  @Get()
  async findAll(@Query() query): Promise<PostsRo> {...}
  ....
}

现在我们对每一个接口都写上了说明,再来看看接口文档展现:

接口传参

最后我们要处理的就是接口参数说明, Swagger的优势之一就是,只要注解到位,可以精确展示每个字段的意义,我们想要对每个传入的参数进行说明。

这里需要先插入一段关于DTO的解释, 因为后面参数说明会用到:

数据传输对象(DTO)(Data Transfer Object),是一种设计模式之间传输数据的软件应用系统。数据传输目标往往是数据访问对象从数据库中检索数据。数据传输对象与数据交互对象或数据访问对象之间的差异是一个以不具有任何行为除了存储和检索的数据(访问和存取器)。

这一段是官方解释, 看不懂没关系,可以理解成,DTO 本身更像是一个指南, 在使用API时,方便我们了解请求期望的数据类型以及返回的数据对象。先使用一下,可能更方便理解。

posts目录下创建一个dto文件夹,再创建一个create-post.dot.ts文件:

代码语言:javascript复制
// dto/create-post.dot.ts
export class CreatePostDto {
  readonly title: string;
  readonly author: string;
  readonly content: string;
  readonly cover_url: string;
  readonly type: number;
}

然后在Controller中对创建文章是传入的参数进行类型说明:

代码语言:javascript复制
//  posts.controller.ts
...
import { CreatePostDto } from './dto/create-post.dto';

@ApiOperation({ summary: '创建文章' })
@Post()
async create(@Body() post:CreatePostDto) {...}

这里提出两个问题:

  1. 为什么不使用 interface 而要使用 class 来声明 CreatePostDto
  2. 为什么不直接用之前定义的实体类型PostsEntiry,而是又定义一个 CreatePostDto

如果你想到这里,很好,说明你一直在思考,下面我们一边继续完善Swagger接口文档,一般解释这两点。

对于第一个问题,我们都知道Typescript接口在编译过程中是被删除的,其次后面我们要给参数加说明,使用Swagger的装饰器,interface也是无法实现的,比如:

代码语言:javascript复制
import { ApiProperty } from '@nestjs/swagger';

export class CreatePostDto {
  @ApiProperty({ description: '文章标题' })
  readonly title: string;

  @ApiProperty({ description: '作者' })
  readonly author: string;

  @ApiPropertyOptional({ description: '内容' })
  readonly content: string;

  @ApiPropertyOptional({ description: '文章封面' })
  readonly cover_url: string;

  @ApiProperty({ description: '文章类型' })
  readonly type: number;
}

@ApiPropertyOptional装饰可选参数,继续看开一下API文档的UI:

对于上面提到的第二个问题,为什么不直接使用实体类型PostsEntiry,而是又定义一个 CreatePostDto,因为HTTP请求传参和返回的内容可以采用和数据库中保存的内容不同的格式,所以将它们分开可以随着时间的推移及业务变更带来更大的灵活性,这里涉及到单一设计的原则,因为每一个类应该处理一件事,最好只处理一件事。

现在就可以从API文档上直观的看到每个传参的含义、类型以及是否必传。到这一步并没有完, 虽然以及告诉别人怎么传, 但是一不小心传错了呢, 比如上面作者字段没传,会发生什么呢?

接口直接报500了, 因为我们实体定义的author字段不能为空的,所有在写入数据时报错了。这样体验非常不好, 很可能前端就怀疑我们接口写错了,所有我们应该对异常进行一定的处理。

数据验证

怎么实现呢?首先想到的是在业务中去写一堆的if-elese判断用户的传参,一想到一堆的判断, 这绝对不是明智之举,所有我去查了Nest.js中数据验证,发现Nest.js中的管道就是专门用来做数据转换的,我们看一下它的定义:

管道是具有 @Injectable() 装饰器的类。管道应实现 PipeTransform 接口。 管道有两个类型:

  • 转换:管道将输入数据转换为所需的数据输出
  • 验证:对输入数据进行验证,如果验证成功继续传递; 验证失败则抛出异常;

管道在异常区域内运行。这意味着当抛出异常时,它们由核心异常处理程序和应用于当前上下文的 异常过滤器 处理。当在 Pipe 中发生异常,controller 不会继续执行任何方法。

什么意思呢, 通俗来讲就是,对请求接口的入参进行验证和转换的前置操作,验证好了我才会将内容给到路由对应的方法中去,失败了就进入异常过滤器中。

Nest.js自带了三个开箱即用的管道:ValidationPipeParseIntPipeParseUUIDPipe, 其中ValidationPipe 配合class-validator就可以完美的实现我们想要的效果(对参数类型进行验证,验证失败抛出异常)。

管道验证操作通常用在dto这种传输层的文件中,用作验证操作。首先我们安装两个需要的依赖包:class-transformerclass-validator

代码语言:javascript复制
npm install class-validator class-transformer -S

然后在create-post.dto.ts文件中添加验证, 完善错误信息提示:

代码语言:javascript复制
import { IsNotEmpty, IsNumber, IsString } from 'class-validator';

export class CreatePostDto {
  @ApiProperty({ description: '文章标题' })
  @IsNotEmpty({ message: '文章标题必填' })
  readonly title: string;

  @IsNotEmpty({ message: '缺少作者信息' })
  @ApiProperty({ description: '作者' })
  readonly author: string;

  @ApiPropertyOptional({ description: '内容' })
  readonly content: string;

  @ApiPropertyOptional({ description: '文章封面' })
  readonly cover_url: string;

  @IsNumber()
  @ApiProperty({ description: '文章类型' })
  readonly type: number;
}

入门阶段,我们使用的数据比较简单,上面只编写了一些常用的验证,class-validator还提供了很多的验证方法, 大家感兴趣可以自己看官方文档.

最后我们还有一个重要的步骤, 就是在main.ts中全局注册一下管道ValidationPipe

代码语言:javascript复制
app.useGlobalPipes(new ValidationPipe());

此时我们在发送一个创建文章请求,不带author参数, 返回数据有很清晰了:

通过上边的学习,可以知道DTO本身是不存在任何验证功能, 但是我们可以借助class-validator来让DTO可以验证数据

总结

至此我们Nest.js快速上手入门就告一段落了,文章从项目如何搭建,到实现简单的CRUD,再到统一接口格式、完成接口参数验证,最后让使用的人可以看到一个清晰的接口文档, 循序渐进入门。接下来会先实现用户模块,然后在继续完善文章模块,涉及到用户登录注册、实现,多表关联操作以及接口的单元测试

0 人点赞