NestJS微服务定时任务无法通过TCP向服务端发送消息求助

核心问题 #

定时任务中调用 client.send() 后服务端未收到数据的根本原因是：Observable 未被订阅。

在 NestJS 中：

• HTTP 控制器方法返回 Observable 时，框架会自动为你订阅 Observable 并处理响应（这就是 Postman 调用 API 正常工作的原因）。
• 但定时任务（@Cron 装饰器修饰的方法）没有自动订阅机制，返回的 Observable 不会被执行，因此消息从未发送到服务端。

解决方案 #

需要手动订阅 client.send() 返回的 Observable，确保消息被发送。推荐使用 RxJS 的 lastValueFrom（RxJS 7+ 推荐方式）或直接调用 .subscribe() 方法，并添加错误处理避免未捕获异常。

修改后的客户端 app.controller.ts #

import { lastValueFrom } from 'rxjs';
// 其他导入保持不变

@Controller('booksstore')
export class AppController {
  constructor(@Inject('BOOKS_SERVICE') private client: ClientProxy) {}

  async onApplicationBootstrap() {
    await this.client.connect();
  }

  @Get(':id')
  getBookByID(@Param('id') id) {
    return this.client.send({ cmd: 'get_book' }, id); // 框架自动订阅
  }

  @Cron(CronExpression.EVERY_5_SECONDS)
  async scheduleTest() {
    console.log('scheduleTest', new Date());
    try {
      // 使用 lastValueFrom 订阅 Observable 并等待结果
      const result = await lastValueFrom(this.client.send({ cmd: 'get_book' }, 123));
      console.log('定时任务执行结果:', result);
    } catch (error) {
      console.error('定时任务发送失败:', error);
    }
  }
}

替代方案（直接使用 .subscribe()） #

如果不需要等待结果，可以直接订阅并处理回调：

@Cron(CronExpression.EVERY_5_SECONDS)
scheduleTest() {
  console.log('scheduleTest', new Date());
  this.client.send({ cmd: 'get_book' }, 123)
    .subscribe({
      next: (result) => console.log('定时任务执行结果:', result),
      error: (err) => console.error('定时任务发送失败:', err),
      complete: () => console.log('定时任务消息发送完成')
    });
}

其他验证点 #

1. 确认 onApplicationBootstrap 中的 client.connect() 已正确执行：该方法确保客户端在应用启动完成后建立与服务端的连接，避免定时任务执行时连接未就绪。
2. 服务端的 @MessagePattern 装饰器参数与客户端发送的 { cmd: 'get_book' } 完全匹配：当前代码中二者一致，无需修改。

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