Nestjs中Service与Gateway间eventEmitter通信异常问题

核心原因 #

你猜的没错——NestJS的EventEmitter模块只会扫描被注册为Provider的类上的@OnEvent装饰器，而Gateway默认仅作为WebSocket入口组件，不会自动被纳入Provider列表，所以你的chat.test事件订阅根本没被注册，自然收不到Service发出的事件。

直接解决方案：把Gateway转为Provider #

只需要给你的ChatGateway加上@Injectable()装饰器，让它成为Nest容器管理的Provider，EventEmitter就能扫描到它的事件订阅了。同时修正socket的获取方式（你原代码里直接用socket会报错，因为没注入实例）：

// chat.gateway.ts
import { Injectable } from '@nestjs/common';
import { WebSocketGateway, OnEvent, WebSocketServer } from '@nestjs/websockets';
import { Server } from 'socket.io';

@Injectable() // 关键：添加这个装饰器
@WebSocketGateway()
export class ChatGateway {
  @WebSocketServer()
  private server: Server; // 注入WebSocket服务器实例

  @OnEvent('chat.test')
  async handleTest(payload: object) {
    // 给所有客户端推送消息，也可以根据需求指定房间/特定客户端
    this.server.emit('test', payload);
  }
}

其他可行方案 #

如果不想用EventEmitter，还有两种更直接的方式：

• 直接在Service中注入Gateway：在ChatService的构造函数里注入ChatGateway，然后直接调用Gateway的方法推送消息，省去事件中转：

  // chat.service.ts
  import { Injectable } from '@nestjs/common';
  import { ChatGateway } from './chat.gateway';
  
  @Injectable()
  export class ChatService {
    constructor(private readonly chatGateway: ChatGateway) {}
  
    async test(payload: object) {
      this.chatGateway.pushTestMessage(payload);
      return { test: true };
    }
  }
  
  // chat.gateway.ts
  export class ChatGateway {
    @WebSocketServer()
    private server: Server;
  
    pushTestMessage(payload: object) {
      this.server.emit('test', payload);
    }
  }
  

• 使用Redis作为事件传输器（微服务场景）：如果你的项目是微服务架构，可配置EventEmitter使用Redis作为传输层，这样跨服务的事件也能正常触发，但单服务场景没必要。

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