NestJS 集成graphql grpc 分布式实践

前言: 为了学习nestjs graphql grpc 微服务方面的知识,具体grpc和graphql的语法再之后在做详细分析1 创建项目npm i -g @nestjs/clinest new project-name2 添加graphql创建graphql-config.service.ts文件，用于graphql的配置及编写过滤器的逻辑@Injectable()export class GraphQLConfigService implements GqlOptionsFactory { constructor() {} createGqlOptions(): GqlModuleOptions { return { typePaths: [join(process.cwd(), “./graphqls/*.graphql”)], // 配置的graphql文件地址 installSubscriptionHandlers: true, definitions: { path: join(process.cwd(), “src/graphql.schema.ts”), // 解析之后的文件地址 outputAs: “class” }, context: async ({ req }) => { // 过滤器 let user = Jwt.verifyToken(req.headers.authorization); // 业务逻辑 return { user }; } }; }}添加进app.module.ts里@Module({ imports: [ GraphQLModule.forRootAsync({ imports: [ApplicationModule], useClass: GraphQLConfigService }), ],})export class ApplicationModule {}创建文件xxx.resolvers.ts @Query(‘getUser’) async getUser() { return {}; }3 添加grpc首先，创建一个子项目xxx子项目创建grpc.options.ts文件，用于init连接的配置export const grpcClientOptions: ClientOptions = { transport: Transport.GRPC, options: { url: “localhost:50051”, // 服务地址 package: “xxx”, protoPath: join(__dirname, ‘./xxx.proto’), },};创建接口, 注意这里的首字母会被自动装为大写 @GrpcMethod(“UserService”) async addUser(data: User): Promise<any> { return data }在main.ts引入import { grpcClientOptions } from ‘./grpc.options’;async function bootstrap() { const app = await NestFactory.create(AppModule); app.connectMicroservice(grpcClientOptions); await app.startAllMicroservicesAsync();}bootstrap();其他微服务或是apigateway调用是创建一个 const grpcClientOptions: ClientOptions = { transport: Transport.GRPC, options: { url: grpcServe.user.url, package: grpcServe.user.package, protoPath: join(__dirname, ‘../../common/proto/user.proto’), },};@Injectable()export class ClentServe { constructor() {} @Client(grpcClientOptions) public readonly client: ClientGrpc;}