NestJS微服务clientProxy.send/@MessagePattern无法发送消息求助

问题背景 #

使用@nestjs/microservices搭建两个Nest应用，事件驱动模式（clientProxy.emit + @EventPattern）可正常工作，但请求响应模式（clientProxy.send + @MessagePattern）无响应，已确认服务连接正常。

客户端请求代码：

this.shortenerService
      .send('create', {
        url: 'test',
      });

服务端接收代码：

@UsePipes(new ValidationPipe())
@MessagePattern('create')
async create(@Payload() data: CreateDto): Promise<string> {
  return Promise.resolve(`${Math.random()}`);
}

排查与解决步骤 #

1. 客户端必须订阅Observable发起请求

clientProxy.send()返回RxJS Observable，只有订阅后才会真正发起请求，这是最常见的遗漏点：

// 修改客户端代码，添加订阅逻辑
this.shortenerService.send('create', { url: 'test' }).subscribe({
  next: (res) => console.log('响应结果:', res),
  error: (err) => console.error('请求失败:', err),
});

2. 检查ValidationPipe是否拦截请求

服务端使用的ValidationPipe可能因请求数据不符合CreateDto规则拦截请求：

• 临时注释@UsePipes(new ValidationPipe())测试是否能收到响应，验证是否为校验规则问题
• 确认CreateDto的字段约束，比如url是否要求合法URL格式，若要求则传入的'test'不符合规则

3. 确保传输器配置完全一致

客户端与服务端的传输器（如TCP）配置必须匹配：

• 服务端启动配置示例：

// 服务端main.ts
async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(UrlShortenerModule, {
    transport: Transport.TCP,
    options: {
      host: 'localhost',
      port: 3001, // 端口需与客户端一致
    },
  });
  await app.listen();
}

• 客户端服务配置示例：

// 客户端模块配置
@Module({
  providers: [
    {
      provide: 'SHORTENER_SERVICE',
      useFactory: () =>
        ClientProxyFactory.create({
          transport: Transport.TCP,
          options: {
            host: 'localhost',
            port: 3001, // 与服务端端口一致
          },
        }),
    },
    AcService,
  ],
})
export class AcModule {}

4. 确认服务端控制器已正确注册

确保@MessagePattern所在的控制器被添加到服务端模块的controllers数组中：

@Module({
  controllers: [UrlShortenerController], // 必须包含目标控制器
  providers: [UrlShortenerService],
})
export class UrlShortenerModule {}

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