如何在MassTransit Consumer中接收RabbitMQ原始消息？

MassTransit本身就支持接收非自身信封格式的原始消息，不需要额外引入原生RabbitMQ客户端，通过配置特定的消息反序列化器或使用内置类型就能实现，完全复用同一连接和处理逻辑。

两种实现方式 #

方式一：用内置RawMessage直接接收原始字节 #

MassTransit提供了RawMessage类型，专门用来接收未包装的原始消息，直接实现IConsumer<RawMessage>接口就能消费：

public class RawMessageConsumer : IConsumer<RawMessage>
{
    public async Task Consume(ConsumeContext<RawMessage> context)
    {
        // 获取原始字节数组
        byte[] rawBytes = context.Message.Body.ToArray();
        
        // 转成字符串（根据实际消息编码调整，比如UTF-8）
        string rawString = Encoding.UTF8.GetString(rawBytes);
        
        // 这里写你的业务处理逻辑
        Console.WriteLine($"收到原始消息：{rawString}");
    }
}

然后在Bus配置里，给目标队列指定使用RawSerializer，这样MassTransit就不会尝试解析自身的信封格式，直接把原始消息传给消费者：

services.AddMassTransit(x =>
{
    x.AddConsumer<RawMessageConsumer>();

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("rabbitmq://localhost");

        cfg.ReceiveEndpoint("你的队列名称", e =>
        {
            // 启用原始消息序列化器，禁用MassTransit信封解析
            e.UseRawSerializer();
            
            e.ConfigureConsumer<RawMessageConsumer>(context);
        });
    });
});

方式二：自定义消息类型接收原始内容 #

如果想直接用自定义类型（比如接收string），可以在配置端点时，给指定类型绑定RawSerializer：

先定义一个简单的消息类：

public class PlainTextMessage
{
    public string Content { get; set; }
}

然后配置Bus时，指定该类型用原始序列化器：

services.AddMassTransit(x =>
{
    x.AddConsumer<PlainTextConsumer>();

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("rabbitmq://localhost");

        cfg.ReceiveEndpoint("你的队列名称", e =>
        {
            // 只为指定的消息类型启用原始序列化
            e.UseRawSerializer(context =>
            {
                return context.MessageType == typeof(PlainTextMessage);
            });
            
            e.ConfigureConsumer<PlainTextConsumer>(context);
        });
    });
});

对应的消费者代码：

public class PlainTextConsumer : IConsumer<PlainTextMessage>
{
    public async Task Consume(ConsumeContext<PlainTextMessage> context)
    {
        // Content就是原始消息的字符串内容（要确保消息是UTF-8编码的文本）
        Console.WriteLine($"收到明文消息：{context.Message.Content}");
    }
}

注意事项 #

• 启用UseRawSerializer后，MassTransit会直接把队列里的原始字节传给消费者，不会做任何信封解析，所以要确保消费者处理的类型和实际发送的消息内容匹配。
• 如果消息是JSON格式但不是MassTransit信封，也可以先拿到原始字符串，再自行反序列化成业务对象。

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