RabbitMQ对接NestJS消费者是否必须使用pattern-data消息格式

NestJS的RabbitMQ微服务默认要求消息携带pattern和data两层结构，是因为内置的ServerRMQ传输层默认反序列化逻辑会硬编码读取这两个字段做路由和参数传递，你碰到的报错就是反序列化后拿不到pattern值导致的。不需要修改生产者消息结构，通过自定义反序列化器替换默认逻辑即可实现需求，侵入性极低，不需要修改框架源码。

方案实现步骤 #

1. 编写自定义反序列化器 #

如果你的队列所有消息都对应同一个固定的事件处理逻辑，直接在反序列化阶段把原始消息映射为NestJS需要的结构，给消息绑定你在@EventPattern()中定义的固定pattern值即可：

import { ReadPacket, Deserializer } from '@nestjs/microservices';

export class RawRmqDeserializer implements Deserializer {
  // 替换为你自己@EventPattern()装饰器里填写的pattern值
  private readonly fixedPattern = 'your_event_pattern_name';

  deserialize(rawMsg: any): ReadPacket {
    return {
      pattern: this.fixedPattern,
      // 直接把生产者发送的原始消息作为data传给处理函数
      data: JSON.parse(rawMsg.content.toString()),
    };
  }
}

如果单个队列需要路由到多个不同的事件处理函数，只需要在这个反序列化方法里加自己的路由规则即可，比如从RabbitMQ的消息头、或者消息体内的自定义字段（比如eventType）映射到对应的pattern值，不需要强制要求生产者在外层包裹固定结构。

2. 启动微服务时注入自定义反序列化器 #

在NestJS初始化RabbitMQ微服务的配置中，替换框架默认的反序列化器：

import { NestFactory } from '@nestjs/core';
import { Transport, MicroserviceOptions } from '@nestjs/microservices';
import { AppModule } from './app.module';
import { RawRmqDeserializer } from './raw-rmq.deserializer';

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
    AppModule,
    {
      transport: Transport.RMQ,
      options: {
        urls: ['amqp://你的RabbitMQ连接地址'],
        queue: '你的队列名',
        queueOptions: { durable: true },
        // 注入自定义反序列化器，替换默认逻辑
        deserializer: new RawRmqDeserializer(),
      },
    },
  );
  await app.listen();
}
bootstrap();

注意事项 #

• 该方案在NestJS 8及以上版本均可正常使用，反序列化器是官方开放的扩展点，不存在兼容问题
• 配置完成后，@EventPattern('your_event_pattern_name')装饰的处理函数，接收到的参数就是生产者发送的原始消息体，不需要做任何额外结构解析
• 不推荐通过重写框架内部ServerRMQ类方法的方式实现需求，后续框架升级容易出现兼容问题

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