NestJS/ClientProxy：无需装饰器手动监听事件的实现方法

当然可以做到。在NestJS的微服务架构里，完全不需要依赖@EventPattern这类装饰器，直接用RabbitMQ客户端的listen()方法就能手动订阅事件，你的示例代码思路本身就是对的。

核心逻辑说明 #

• 手动订阅的关键就是调用客户端提供的listen()方法，传入要监听的事件标识（比如你代码里的RmqPatterns.DID_STUFF），再传入处理消息的回调函数就行。
• 要注意订阅时机：别等发送消息后才去订阅，最好在服务启动阶段就完成订阅（比如放在OnModuleInit钩子中），不然可能出现事件已经触发，但订阅还没建立导致消息丢失的情况。

优化后的可运行示例 #

import { Injectable, OnModuleInit } from '@nestjs/common';
import { lastValueFrom } from 'rxjs';

@Injectable()
export class YourBusinessService implements OnModuleInit {
  constructor(private readonly rabbitmqClient: /* 替换成你的RabbitMQ客户端类型 */) {}

  // 服务启动时就建立订阅
  async onModuleInit() {
    this.rabbitmqClient.listen(RmqPatterns.DID_STUFF, async (msg) => {
      console.log(`Received async event message: ${msg.content.toString()}`);
      // 这里写你的业务处理逻辑
      // 如果是手动确认模式，别忘了调用 msg.ack() 确认消息已处理
    });
  }

  // 触发异步事件的方法
  async initiateAsyncWorkflow(payload: any) {
    // 发送触发消息
    await lastValueFrom(
      this.rabbitmqClient.send(RmqPatterns.DO_STUFF, payload),
    );
  }
}

额外提醒 #

• 如果是临时订阅（不需要一直监听），记得在使用完后调用对应的取消订阅方法，避免占用资源。
• 要是你的RabbitMQ开启了手动消息确认，一定要在回调里执行msg.ack()，不然未确认的消息会一直留在队列里。

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