浓浓 AOP 风格的用户组织服务 nest.js + Typescript + typeorm + GraphQL + Grpc
发布于 1 年前 作者 zuohuadong 1462 次浏览 来自 分享

项目地址： https://github.com/notadd/ns-module-user

功能

  • [x] 注册
  • [x] 登录
  • [x] 授权、鉴权
  • [x] 组织管理
  • [x] 用户管理
  • [x] 角色管理
  • [x] 信息组管理
  • [x] 信息项管理
  • [x] 全局 i18n 支持
  • [ ] …

使用说明

用户模块的大部分接口都定义了权限，在初始化时，会生成一个超级管理员用户，账号为： sadmin，密码为： sadmin，可以自行登录后，使用 accessToken 调用 updateCurrentUserInfo (更新当前登录用户信息)，修改密码。

导入用户模块

在应用程序根模块中导入 UserModule，并配置 i18n 选项

资源定义

@Resouce，是用户对某一实体资源进行业务操作的统称。

在 Resolver 或 Controller 类上设置定义资源的注解，用于定义当前资源，如：

@Resource({ name: '文章管理', identify: 'artical:manage' })

name: 资源的名称，用于定义权限的父级名称，命名方式为: 资源+行为，如：应用内文章管理的相关api => '文章管理'

identity: 资源的唯一标识，命名方式为 模块名:类名 或 name 的拆分英文，如： '文章管理' => 'artical:manage'

权限定义

@Permission，是用户对当前实体资源进行某一具体操作的定义。

在 Resolver、Controller 方法上设置定义操作的注解，用户定义对当前资源的操作权限，如：

@Permission({ name: '添加文章', identify: 'artical:create', action: 'create', personal: true })

name: 权限的名称，用于定义具体的权限名称，命名方式为：操作+资源，如：在文章资源中添加文章 => '添加文章'

identify: 权限的唯一标识，命名方式为：资源:方法，如：'添加文章' => 'artical:createArtical'

action: 权限操作类型，只能是 create、delete、update、find 中的一个

权限的定义离不开资源的定义，二者是共存的状态，在使用权限功能时，先在类上定义资源，而后在需要权限控制的方法上定义权限。

定义好资源和权限后，启动程序，资源和权限会被自动加载并存储到数据库。

配置授权，鉴权功能

以下是 apollo-server-express 2.x 版本的授权、鉴权功能逻辑示例

授权功能只需导入 UserModule 即可自动配置

app.module.ts

import { Module } from '@nestjs/common';
import { GraphQLModule } from '@nestjs/graphql';
import { TypeOrmModule } from '@nestjs/typeorm';

import { UserModule } from './user';

@Module({
    imports: [
        GraphQLModule.forRootAsync({
           useClass: GraphQLConfigService
        }),
        TypeOrmModule.forRoot(),
        UserModule.forRoot({ i18n: 'zh-CN' })
    ],
    controllers: [],
    providers: [],
    exports: []
})
export class AppModule { }

鉴权功能，在 graphql 上下文中 使用 AuthenticationService 类的 validateUser 方法，并将通过身份验证的用户传递给上下文

GraphQLJSON 是用于处理 graphql 中的 JSON 标量类型，需要额外安装 graphql-type-json，然后将其配置到 resolvers 选项中

graphql-config.service.ts

import { Inject, Injectable } from '@nestjs/common';
import { GqlModuleOptions, GqlOptionsFactory } from '@nestjs/graphql';
import * as GraphQLJSON from 'graphql-type-json';
import { AuthenticationService } from '@notadd/module-user';

@Injectable()
export class GraphQLConfigService implements GqlOptionsFactory {
    constructor(
        @Inject(AuthenticationService) private readonly authService: AuthenticationService
    ) {}

    createGqlOptions(): GqlModuleOptions {
        return {
            typePaths: ['./**/*.types.graphql'],
            resolvers: { JSON: GraphQLJSON },
            context: async ({ req }) => {
                const user = await this.authService.validateUser(req);
                return { user };
            }
        };
    }
}

接口逻辑说明

用户模块向各类上层业务系统提供了丰富且灵活的接口，以下介绍常用的接口逻辑

资源

Query：

  • findResources 查询所有资源权限，返回当前业务系统定义的所有资源和权限数据

角色

Query：

  • findRoles 查询所有角色，返回所有角色的 id 和 name
  • findOneRoleInfo(roleId: Int!) 查询角色信息，返回指定 id 的角色详细信息，包含角色拥有的权限及其拥有的信息项

Mutation：

  • createRole(name: String!) 添加角色
  • updateRole(id: Int!, name: String!) 更新角色名称
  • deleteRole(id: Int!) 删除指定 id 的角色
  • setPermissionsToRole(roleId: Int!, permissionIds: [Int]!) 给角色设置权限

信息组

Query：

  • findAllInfoGroup 查询所有信息组
  • findInfoItemsByGroupId(groupId: Int!) 查询指定信息组下的所有信息项

Mutation：

  • createInfoGroup(name: String!, roleId: Int!) 新增信息组
  • deleteInfoGroup(groupId: Int!) 删除指定ID的信息组
  • updateInfoGroup(groupId: Int!, name: String, roleId: Int) 更新指定ID的信息组名称或所属角色
  • addInfoItemToInfoGroup(infoGroupId: Int!, infoItemIds: [Int]!) 向指定信息组添加指定信息项
  • deleteIntoItemFromInfoGroup(infoGroupId: Int!, infoItemIds: [Int]!) 删除指定信息组的指定信息项

信息项

Query：

  • findAllInfoItem 查询所有信息项

Mutation：

  • createInfoItem(infoItemInput: InfoItemInput) 新增信息项
  • deleteInfoItem(infoItemId: Int!) 删除指定ID的信息项
  • updateInfoItem(updateInfoItemInput: UpdateInfoItemInput) 更新指定ID的信息项名称、标签、描述、类型

组织

Query：

  • findRootOrganizations 获取根组织
  • findAllOrganizations 获取所有组织
  • findChildrenOrganizations(id: Int!) 获取指定组织下的所有子组织

Mutation：

  • createOrganization(name: String!, parentId: Int) 创建组织，parentId 为空时，代表创建根组织
  • updateOrganization(id: Int!, name: String!, parentId: Int!) 更新组织
  • deleteOrganization(id: Int!) 删除组织
  • addUsersToOrganization(id: Int!, userIds: [Int]!) 给组织添加用户
  • deleteUserFromOrganization(id: Int!, userIds: [Int]!) 删除组织下的用户

用户

Query：

  • login(username: String!, password: String!) 普通用户登录
  • findRegisterUserInfoItem 查询普通用户注册时所需填写的信息项
  • findCurrentUserInfo 查询当前登录的用户信息
  • findUserInfoById(userId: Int!) 通过ID查询用户信息
  • findUsersInRole(roleId: Int!) 查询指定角色ID下的所有用户信息
  • findUsersInOrganization(organizationId: Int!) 获取指定组织ID下的用户

Mutation：

  • register(registerUserInput: RegisterUserInput) 普通用户注册，参数 infoKVs 中的 key 是信息项的ID(infoItem.id)，值是信息项的值(userInfo.value)
  • createUser(createUserInput: CreateUserInput) 创建用户，参数 infoKVs 中的 key 是信息项的ID(infoItem.id)，值是信息项的值(userInfo.value)
  • addUserRole(userId: Int!, roleId: Int!) 给用户添加角色
  • deleteUserRole(userId: Int!, roleId: Int!) 删除用户角色
  • recycleUser(userId: Int!) 删除用户到回收站
  • deleteRecycledUser(userId: Int!) 删除回收站内的用户
  • updateUserInfo(userId: Int!, updateUserInput: UpdateUserInput) 更新用户信息，参数 infoKVs 中的 key是用户信息项值的ID(userInfo.id)，value是信息项的值(userInfo.value)，relationId 是信息项的ID，当返回的 key 为 null 时，也需要传入 null
  • updateCurrentUserInfo(updateCurrentUserInput: UpdateCurrentUserInput) 更新当前登录用户信息，参数 infoKVs 中的 key是用户信息项值的ID(userInfo.id)，value是信息项的值(userInfo.value)，relationId 是信息项的ID，当返回的 key 为 null 时，也需要传入 null
4 回复

有个疑问：grpc服务是客户端和服务端1对1连接的，如果服务端需要部署多台做负载均衡怎么处理？

@yuedun 以k8s 为例的话，连接的是虚拟IP，虚拟IP背后可能是10个或者3个相同的容器。 虚拟ip 做了负载均衡

@zuohuadong 这个虚拟ip还是有点类似于nginx，http请求通过nginx可以随机分配到某一台服务器，可是grpc是长连接，不能每次请求都换一台服务器连接。那么就造成了其他rpc服务空闲。不知道k8s是不是也有相同的问题

@yuedun etcd 和 LVS 七层负载均衡 了解下。 k8s 一般来说部署至少得 6台机器以上，从成本考虑的话， 12台以上才有成本优势， 你都这么大流量了，怎么会有空闲？ 另外，http 虽然如你所说，不是长连接，但是一次 http 请求的消耗足够 几十次 TCP 了。（http 基于 TCP 协议） TCP 保持长连接本身就能够降低每次建立连接的消耗，你的目的是提高负载，降低用户请求时间。 而不是在空闲的时候节省那点微不足道的资源。

回到顶部