NestJS RabbitMQ微服务报错：无匹配事件处理器（事件模式undefined）

问题背景 #

创建接收RabbitMQ消息的NestJS微服务，配置了队列与消费服务，但发送消息后触发上述错误，无法正常接收消息。相关代码如下：

main.ts #

import { NestFactory } from '@nestjs/core';
import { Transport, MicroserviceOptions } from '@nestjs/microservices';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
    AppModule,
    {
      transport: Transport.RMQ,
      options: {
        urls: ['amqp://localhost:5672'],
        queue: 'my-queue',
        queueOptions: { durable: false },
      },
    },
  );
  app.listen();
}
bootstrap();

app.module.ts #

import { Module } from '@nestjs/common';
import { RabbitMQConsumerService } from './rabbitmq-consumer.service';

@Module({
  imports: [],
  providers: [RabbitMQConsumerService],
})
export class AppModule {}

rabbitmq-consumer.service.ts #

import { Injectable } from '@nestjs/common';
import {
  Ctx,
  MessagePattern,
  Payload,
  RmqContext,
} from '@nestjs/microservices';

@Injectable()
export class RabbitMQConsumerService {
  @MessagePattern('my-queue')
  async processMessage(@Payload() data: any, @Ctx() context: RmqContext) {
    console.log('Mensagem recebida:', data);
  }
}

错误原因 #

该错误说明服务端收到的消息未携带可匹配的事件标识（pattern为undefined），导致无法找到对应的消息处理器。核心原因分为两种场景：

1. RPC模式下发送消息未指定pattern：使用@MessagePattern时，NestJS依赖消息中的pattern字段匹配处理器，若发送时未指定该值，服务端会识别为undefined。
2. 误用RPC模式处理普通队列消息：@MessagePattern适用于请求-响应式的RPC场景，若仅需消费消息无需返回响应，应使用事件发布-订阅模式的@EventPattern。

解决方案 #

方案1：RPC模式下确保发送消息指定正确pattern #

若需保留RPC模式（需要响应），发送消息时必须在send方法中指定与@MessagePattern参数一致的pattern：

import { ClientProxyFactory, Transport } from '@nestjs/microservices';

const client = ClientProxyFactory.create({
  transport: Transport.RMQ,
  options: {
    urls: ['amqp://localhost:5672'],
    queue: 'my-queue',
  },
});

// 指定pattern为'my-queue'
client.send('my-queue', { content: '测试RPC消息' }).subscribe({
  next: (res) => console.log('服务端响应:', res),
  error: (err) => console.error('发送失败:', err),
});

方案2：切换为事件模式消费（无响应场景） #

若仅需消费消息无需返回响应，推荐使用@EventPattern替代@MessagePattern，同时发送消息使用emit方法：

修改消费者服务

import { Injectable } from '@nestjs/common';
import { Ctx, EventPattern, Payload, RmqContext } from '@nestjs/microservices';

@Injectable()
export class RabbitMQConsumerService {
  @EventPattern('my-queue') // 替换为EventPattern
  async processMessage(@Payload() data: any, @Ctx() context: RmqContext) {
    console.log('Mensagem recebida:', data);
    // 手动确认消息（需在main.ts中配置noAck: false）
    const channel = context.getChannelRef();
    const originalMsg = context.getMessage();
    channel.ack(originalMsg);
  }
}

修改main.ts中的RMQ配置（可选，用于手动ack）

options: {
  urls: ['amqp://localhost:5672'],
  queue: 'my-queue',
  queueOptions: { durable: false },
  noAck: false, // 关闭自动确认，需手动ack
},

发送事件消息的客户端代码

client.emit('my-queue', { content: '测试事件消息' }).subscribe();

额外注意 #

若通过RabbitMQ管理界面或非NestJS客户端发送消息，需在消息的headers中添加pattern字段，值为my-queue，否则服务端仍会识别为undefined。

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