NestJS+TypeORM实现后端推送数据至前端失败问题排查

核心问题1：@SSE与@OnEvent的组合逻辑错误 #

你的写法存在逻辑矛盾：

• @SSE装饰器要求方法返回一个持续的Observable，用于和客户端维持SSE连接并推送数据
• @OnEvent装饰器是在事件触发时才执行方法，此时返回的Observable无法关联到已经建立好的客户端连接上，自然前端收不到数据

核心问题2：Job实体的序列化问题（次要但可能影响） #

TypeORM实体实例包含ORM内部的元数据属性（如__entityMetadata、__relations），直接作为SSE数据推送时，可能因为循环引用或无法序列化导致前端接收失败——这也是固定对象能正常推送的原因之一。

修复方案 #

步骤1：重构SSE控制器逻辑，用Subject管理推送流 #

把SSE接口改成一开始就返回一个Subject，当事件触发时向Subject发送数据：

import { Controller, Sse } from '@nestjs/common';
import { OnEvent } from '@nestjs/event-emitter';
import { Observable, Subject } from 'rxjs';
import { MessageEvent } from '@nestjs/common';
import { Job } from './job.entity';
import { plainToInstance } from 'class-transformer';

@Controller()
export class JobSseController {
  private jobUpdateSubject = new Subject<MessageEvent>();

  @Sse('/subscribe')
  subscribe(): Observable<MessageEvent> {
    // 返回Subject的可观察流，维持客户端连接
    return this.jobUpdateSubject.asObservable();
  }

  @OnEvent('job.updated')
  handleJobUpdate(job: Job) {
    // 将实体转为普通可序列化对象，排除ORM元数据
    const serializedJob = plainToInstance(Job, job, { excludeExtraneousValues: true });
    // 也可以用简单方式：const serializedJob = job.toJSON();
    this.jobUpdateSubject.next({ data: serializedJob });
  }
}

步骤2：确保Subscriber发送完整的Job实例（可选优化） #

如果event.entity是部分更新的字段，需重新获取完整实体再发送事件：

async afterUpdate(event: UpdateEvent<Job>) {
  const fullJob = await this.dataSource.getRepository(Job).findOneBy({ id: event.entity.id });
  this.eventEmitter.emit('job.updated', fullJob);
}

步骤3：前端SSE连接验证（可选） #

确保前端正确建立连接：

const eventSource = new EventSource('/subscribe');
eventSource.onmessage = (event) => {
  const job = JSON.parse(event.data);
  console.log('收到Job更新:', job);
};
eventSource.onerror = (error) => {
  console.error('SSE连接错误:', error);
};

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