基于服务发现的NestJS微服务HTTP通信及ClientProxy使用疑问

1. Kubernetes内置服务发现的NestJS实现示例 #

Kubernetes的Service组件本身就是集群内的服务发现核心，无需额外依赖第三方工具，只需在NestJS的HttpModule中直接使用Service名称作为请求地址即可——K8s的CoreDNS会自动将Service名称解析为集群内的服务IP。

实现步骤： #

1. 确保两个NestJS应用都部署在K8s集群中，且为目标服务创建了K8s Service（假设服务名称为user-service，端口为3000）。
2. 在调用方的Module中配置HttpModule：

@Module({
  imports: [HttpModule.register({
    baseURL: 'http://user-service:3000', // 直接使用K8s Service名称作为域名
  })],
  providers: [UserClientService],
})
export class AppModule {}

3. 在业务服务中通过HttpService发送请求：

@Injectable()
export class UserClientService {
  constructor(private readonly httpService: HttpService) {}

  async getUser(userId: string) {
    const response = await this.httpService.get(`/users/${userId}`).toPromise();
    return response.data;
  }
}

如果两个服务不在同一个Namespace，只需使用完整域名格式：http://user-service.your-namespace.svc.cluster.local:3000。

2. NestJS的ClientProxy能否通过服务名称引用远程服务？ #

可以，但有前提：远程服务必须是NestJS微服务模式启动的（而非普通HTTP Web应用），且使用了支持服务发现的传输层（如TCP、Redis）。

实现示例： #

1. 远程服务以微服务模式启动：

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(AppModule, {
    transport: Transport.TCP,
    options: {
      host: '0.0.0.0',
      port: 3000,
    },
  });
  await app.listen();
}
bootstrap();

2. 调用方通过ClientProxyFactory创建客户端，使用K8s Service名称作为地址：

@Module({
  providers: [
    {
      provide: 'USER_SERVICE_CLIENT',
      useFactory: () => {
        return ClientProxyFactory.create({
          transport: Transport.TCP,
          options: {
            host: 'user-service', // K8s Service名称
            port: 3000,
          },
        });
      },
    },
  ],
})
export class AppModule {}

3. 在业务服务中注入并使用ClientProxy：

@Injectable()
export class UserClientService {
  constructor(@Inject('USER_SERVICE_CLIENT') private readonly client: ClientProxy) {}

  async getUser(userId: string) {
    return this.client.send({ cmd: 'get-user' }, { userId }).toPromise();
  }
}

3. ClientProxy能否用于HTTP场景？ #

不能。ClientProxy是NestJS专门为其微服务传输层设计的客户端，仅支持TCP、Redis、MQTT等非HTTP的消息协议，无法直接发送标准HTTP请求。

如果你的两个应用都是普通HTTP Web应用（用NestFactory.create启动，基于Express/Fastify），仍需使用HttpModule配合K8s服务发现来实现通信。

关于NestJS微服务与HTTP协议的困惑 #

NestJS文档中提到的「微服务本质上是使用不同于HTTP的传输层的应用」，特指NestJS定义的微服务模式：

• 普通HTTP应用：用NestFactory.create启动，基于Express/Fastify处理标准HTTP请求，属于传统Web服务范畴。
• NestJS微服务：用NestFactory.createMicroservice启动，使用自定义的轻量消息协议（基于TCP、Redis等传输层），专为服务间高效通信设计，和标准HTTP协议不兼容。

HTTP确实是基于TCP的应用层协议，但NestJS的微服务模式并未采用HTTP作为传输层，而是封装了自己的消息格式，因此和普通HTTP应用做了明确区分。

内容的提问来源于stack exchange，提问作者KnownUnknown