• 依赖

grpc和microserver的

{
    "@grpc/proto-loader": "^0.6.1",
    "@nestjs/common": "^7.6.15",
    "@nestjs/config": "^0.6.3",
    "@nestjs/core": "^7.6.15",
    "@nestjs/microservices": "^7.6.15",
    "@nestjs/mongoose": "^7.2.4",
    "@nestjs/platform-express": "^7.6.15",
    "@nestjs/schedule": "^0.4.3",
    "@types/cron": "^1.7.2",
    "cron": "^1.8.2",
    "fastq": "^1.11.0",
    "grpc": "^1.24.6",
    "nest-winston": "^1.4.0",
    "reflect-metadata": "^0.1.13",
    "rimraf": "^3.0.2",
    "rxjs": "^6.6.6",
    "schedule": "^0.5.0",
    "winston": "^3.3.3",
    "winston-daily-rotate-file": "^4.5.1"
  }

• proto 文件
  
• 定义接口

import { Observable } from 'rxjs';

export interface StrategyGrpcService {
  hello(data: { message: string }): Observable<any>;
}

• app.modules.ts 组件配置类

	ClientsModule.register([
      {
        //注入的时候需要用这个名字，随便取
        name: 'GrpcClient',
        transport: Transport.GRPC,
        options: {
          //和proto里的package要一样
          package: 'strategy',
          //server端的ip和地址
          url: '192.168.0.140:12300',
          //proto文件
          protoPath: join(__dirname, './grpc/Strategy.proto'),
        },
      },
    ]),

• 定义service，给我们的service里里注入grpc客户端client和service

这个service需要在app.modules.ts的providers:[]里头注册一下

同时在这个service里来调用grpc的函数，返回结果，由于默认是Observable我们调用toPromise()变为promise的，被我包装成了service下的hello函数

@Injectable()
export class SubscribeStrategyService {
  //proto service
  private strategyGrpcService : StrategyGrpcService;

  constructor(
    @Inject('GrpcClient') private client: ClientGrpc,
  ) {}
  
  async hello(message: string): Promise<any> {
    console.log('发送');
    console.log(this.strategyGrpcService);
    try {
      return await this.strategyGrpcService.hello({ message: message }).toPromise();
    } catch (e) {
      console.log(e);
    }
  }
}

到此只需要调用这个SubscribeStrategyService的hello函数就可以了，你也可以直接去调用this.strategyGrpcService来使用。