如何在同一台机器上运行和连接两个nestjs grpc微服务

Question

我正在用nestjs创建Grpc微服务。如何连接本地主机上的两台服务器。

我已经尝试使用ngrok为其中一个服务创建一个隧道，但我仍然收到错误“正在使用的地址”和“没有地址添加到总共2解决”，即使两个都在不同的端口上运行

第一次服务

import { authServiceOptions } from './auth/grpc/auth.options';
import { notificationClientServiceOptions } from '../../notification/src/notification/grpc/notification.options';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.useGlobalPipes(new ValidationPipe());
  app.setGlobalPrefix('api/v1/services');

  // Services
  app.connectMicroservice(notificationClientServiceOptions);
  app.connectMicroservice(authServiceOptions);

  await app.startAllMicroservicesAsync();
  await app.listen(51700);
}
bootstrap();

第二次服务

import { AppModule } from './app.module';
import { notificationServiceOptions } from './notification/grpc/notification.options';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.useGlobalPipes(new ValidationPipe());
  app.setGlobalPrefix('api/v1/services');

  // Services
  app.connectMicroservice(notificationServiceOptions);

  await app.startAllMicroservicesAsync();
  await app.listen(3001);
}
bootstrap();

//第二次服务的客户端选项

export const notificationClientServiceOptions: ClientOptions = {
  transport: Transport.GRPC,
  options: {
    url: 'https://b6a4cd09.ngrok.io/',
    package: 'notification',
    protoPath: join(__dirname, './notification.proto'),
  },
};

Answer 1

弄清楚了！原来我正在为Grpc服务指定一个http url。这是第二个服务的正确客户端选项。

export const notificationClientServiceOptions: ClientOptions = {
  transport: Transport.GRPC,
  options: {
    // you can specify any port that is not in use (just don't prefix it with 'http')
    url: 'localhost:5500', 
    package: 'notification',
    protoPath: join(__dirname, './notification.proto'),
  },
};

我也查了一下nestjs的源代码。结果是任何微服务的默认网址是localhost：5000，因此，如果您运行多个服务，最好为每个服务指定网址。

我遇到的另一个问题是连接微服务;如果服务位于两个独立的nestjs项目中，则不需要在app.connectMicroservice(secondServiceOptions)中使用firstService，这是因为await app.startAllMicroservicesAsync()会尝试启动这两个服务，但它会失败。这是因为secondService已经在一个单独的项目中运行。

要从secondService连接到firstService，请使用@Client(secondServiceOptions)装饰器。