客户端

## 前言

当我们基于NestJS框架构建和管理应用程序时，为了保障其安全性，我们常常需要对某些敏感操作或敏感信息的访问进行限制，这是我们需要使用到 **守卫** 的地方。它作为一种可以阻止未经授权的访问的机制，对我们的应用程序起到了守护的作用。

在这篇文章中，我将深入剖析 NestJS 的守卫，以帮您全面了解这个概念。我会从解释其背后的工作机制开始，接着介绍使用守卫的各种场景，并以详细的示例来演示如何在 NestJS 项目中实现和使用守卫。

## **什么是 Guards 守卫**

在去解析NestJS的守卫之前，我们先来简单了解一下NestJS。NestJS是一种设计用于构建高效，可扩展的 Node.js 服务器端应用程序的框架。它使用渐进式 JavaScript，内置并完全支持 TypeScript，并结合了 OOP、FP 和 FRP 的元素。

既然我们已经对NestJS有了基本的理解，那么，什么是NestJS的守卫(Guards)呢？简单来说，守卫（Guards）是NestJS中的一个概念，其职责就像其名字一样，它起到了保护我们应用程序不被未经授权的访问的作用。在特定的路由处理程序执行之前，守卫负责确定请求是否应该被路由处理程序处理。

## 使用场景

守卫通常用于身份验证和授权，也就是在执行业务代码之前验证用户是否有权做出某个操作。

例如，在许多应用程序中，你需要防止未经授权的用户访问敏感信息或执行特定的操作。若用户请求查看或修改某些只有特定权限或角色才能查看或修改的数据时，守卫即可起到“守门人”的作用。

## 使用案例

### 一、**创建一个身份验证守卫**

我们首先要创建一个 **`AuthGuard`** 类并注入它。这个类需要实现 **`CanActivate`** 接口并实现 **`canActivate`** 方法：

```typescript
import { Injectable, CanActivate, ExecutionContext } from '@nestjs/common';
import { Observable } from 'rxjs';

@Injectable()
export class AuthGuard implements CanActivate {
  canActivate(
    context: ExecutionContext,
  ): boolean | Promise<boolean> | Observable<boolean> {
    const request = context.switchToHttp().getRequest();
    // 添加你的身份验证逻辑
    // For example:
    return validateRequest(request);
  }
}
```

在上面的示例中，我们首先从 **`@nestjs/common`** 包导入了 **`Injectable`**，**`CanActivate`** 和 **`ExecutionContext`**。然后，我们创建了一个 **`AuthGuard`** 类，它会实现 **`CanActivate`** 接口，这个接口要求我们实现 **`canActivate`** 方法。

在这个方法中，我们首先获取上下文请求对象。然后，我们可以在这个方法中执行我们需要的任何判断逻辑，比如检查请求中是否包含有效的 JWT 令牌。

### 二、使用身份验证守卫（控制器维度）

现在，我们已经创建了守卫，那该如何使用呢？其实非常简单，我们只需要在控制器或者具体路由上添加 **`@UseGuards()`** 装饰器：

```typescript
import { Controller, Get, UseGuards } from '@nestjs/common';
import { AuthGuard } from './auth.guard';

@Controller('users')
@UseGuards(AuthGuard)
export class UserController {
  
  @Get()
  findAll() {
    return "这个操作返回所有的猫，只有通过身份验证的用户能看到!";
  }
}
```

这样，我们就可以确保只有通过 `AuthGuard` 权限认证的用户才能够访问到我们的 **`CatsController`** 控制器中的所有路由。

### 三、使用身份验证守卫（路由维度）

如果你只希望在某个特定的路由上应用这个守卫，而不是整个控制器，你可以将 **`UseGuards`** 装饰器应用于具体的路由处理函数：

```typescript
import { Controller, Get, UseGuards } from '@nestjs/common';
import { AuthGuard } from './auth.guard';

@Controller('cats')
export class CatsController {
  
  @Get()
  @UseGuards(AuthGuard)
  findOne() {
    return "这个操作返回一只猫，只有通过身份验证的用户能看到!";
  }
}
```

## 总结

以上我们已经展示了如何创建和使用自定义守卫。然而，在真实的业务场景中，可能会有更复杂的情况，比如基于角色的访问控制(Role-Based Access Control, RBAC)。这种情况下，你的守卫可能需要复杂的逻辑来确定一个用户能接触哪些资源。这些都是你可以使用守卫来处理的场景。

总的来说，NestJS 的守卫是一个非常强大的工具，特别是对于大型和复杂的项目，在权限判断上，使用守卫可以极大地提高代码的可维护性和安全性。


当我们基于NestJS框架构建和管理应用程序时，为了保障其安全性，我们常常需要对某些敏感操作或敏感信息的访问进行限制，这是我们需要使用到守卫的地方。它作为一种可以阻止未经授权的访问的机制，对我们的应用程序起到了守护的作用。在这篇文章中，我将深入剖析NestJS的守卫，以帮您全面了解这个概念。我会从解释其背后的工作机制开始，接着介绍使用守卫的各种场景，并以详细的示例来演示如何在NestJS项目中实现

一篇文章学会如何使用 NestJS 的 Guards 守卫实现系统身份验证和授权

## 前言

服务端消息推送**SSE**是常用的服务器消息通信手段，适用于服务器主动给客户端发送消息的场景，例如私信通知，扫描登录等都可以使用SSE实现。SSE的底层原理是客户端与服务端建立 HTTP 长链接。

Nestjs 框架内置了对SSE的支持，本文详细介绍Nestjs服务端推送服务的实战步骤。

## 使用步骤

### 一、创建 SSE 接口服务

跟普通的 HTTP 方法相同，在 `@nestjs/common` 中引入 `@Sse` 装饰器，在处理服务器推送的方法上使用 `@See`装饰器。

```javascript
import { Controller, Param, Sse } from '@nestjs/common';
import { ApiTags } from '@nestjs/swagger';
import { Observable, interval, map } from 'rxjs';

export interface MessageEvent {
  message: string;
}

@Controller({ path: '/admin/message' })
export class AdminMessageController {
  @Sse('sse')
  sendServerMessage(@Param() params): Observable<MessageEvent> {
    return interval(5000).pipe(map((_) => ({ message: '你好乐闻' })));
  }
}
```

上面的程序目的是服务器每5s向客户端发送一次消息。

### 二、使用 Postman 调试服务端推送接口

由于SSE本质就是 HTTP 连接，在Postman中使用get请求发起请求即可。

会发现每 `5s`收到一条「你好乐闻」的消息。

![Untitled.png](https://cdn.portal.levenx.com/levenx-world/vSIwn4Jg7gOT4DUV.png)

### 三、浏览器前端建立链接

SSE 是客户端和服务端之间的单向通行，即服务端向客户端发送信息。客户端使用 `EventSource` 发送连接。

以 React 为例，实现前端页面与服务端建立SSE连接。服务端推送过来的消息会触发 `EventSource`的 `onmessage`回调事件，所以我们可以在 `onmessage`中自定义业务逻辑。

```javascript
useEffect(() => {
    const eventSource = new EventSource(
      "http://localhost:8822/admin/message/sse",
    );
    eventSource.onmessage = ({ data }) => {
      console.log("New message", JSON.parse(data));
    };
  }, []);
```

当我触发了自定义消息推送接口后，发现在浏览器的控制台可以看到日志输出

![Untitled.png](https://cdn.portal.levenx.com/levenx-world/SIpfsScRyDzp7ypD.png)

## 进阶使用

### 如何自定义推送的内容

由于 Nestjs 底层是依赖 `rxjs` 实现数据流，Nest 的 SSE 方法返回的是 `Observable` ,在SSE服务长链接时，希望在中途能够通知 `Observable`

返回不同的数据。

基于 `rxjs`的 `Subject`可以实现上述形式的数据推送。

1. 安装相关依赖

   ```javascript
   npm install @nestjs/event-emitter
   ```
2. nestjs 注册发布订阅模块

   ```javascript
   import { Module } from '@nestjs/common';
   import { EventEmitterModule } from '@nestjs/event-emitter';

   @Module({
     imports: [
       EventEmitterModule.forRoot()
     ],
   })
   export class AppModule {}
   ```
3. 实现SSE自定义消息逻辑以及发送自定义内容

   ```javascript
   import { Controller, Inject, Get, Sse } from '@nestjs/common';
   import { ApiTags } from '@nestjs/swagger';
   import { EventEmitter2 } from '@nestjs/event-emitter';
   import { Observable, Subject, map } from 'rxjs';

   export interface MessageEventData {
     userId: number;
     message: Record<string, string>;
   }

   export interface MessageEvent {
     message: MessageEventData;
   }

   @Controller({ path: '/admin/message' })
   export class AdminMessageController {
     @Inject(EventEmitter2)
     private readonly eventEmitterService: EventEmitter2;

     @Sse('sse')
     sendServerEvent(): Observable<MessageEvent> {
       const subject = new Subject();

       // 监听CUSTOM_MESSAGE事件
       this.eventEmitterService.on('CUSTOM_MESSAGE', (data) => {
         // subject 处理事件
         subject.next(data);
       });

       return subject.pipe(
         map((data: MessageEventData): MessageEvent => ({ message: data })),
       );
     }

   	// 发送自定义发送消息
     @Get('send')
     emitMessage() {
       const messageEventData: MessageEventData = {
         userId: 123456,
         message: { hi: '你好乐闻' },
       };
       // 发送 CUSTOM_MESSAGE 事件
       this.eventEmitterService.emit('CUSTOM_MESSAGE', messageEventData);
     }
   }
   ```
4. Postman 调试效果

   ![Untitled.png](https://cdn.portal.levenx.com/levenx-world/0VfS5TNXC4ezSybF.png)

   ![Untitled.png](https://cdn.portal.levenx.com/levenx-world/faKXabGdCWorx0P4.png)

## 总结

服务端推送SSE在业务开发中经常使用到的通信手段，Nestjs 是目前比较流行通用的node框架，Nestjs 支持了SSE，本文也大致介绍了使用步骤，希望能够对有需要的同学有所帮助。


服务端消息推送SSE是常用的服务器消息通信手段，适用于服务器主动给客户端发送消息的场景，例如私信通知，扫描登录等都可以使用SSE实现。SSE的底层原理是客户端与服务端建立HTTP长链接。Nestjs框架内置了对SSE的支持，本文详细介绍Nestjs服务端推送服务的实战步骤。使用步骤一、创建SSE接口服务跟普通的HTTP方法相同，在@nestjs/common中引入@Sse装饰器，在处理服务器推送的

一篇文章学会如何使用 NestJS 的 Guards 守卫实现系统身份验证和授权

NestJS 如何进行服务端推送SSE、自定义服务端推送内容