MassTransit是否支持RabbitMQ空消息体？消费空体消息报错咨询

MassTransit支持处理仅含消息头的空消息体场景，但默认的JSON序列化逻辑会因为空内容无法解析而报错，导致消息进入_error队列。

报错原因 #

你遇到的The input does not contain any JSON tokens错误，是因为默认使用的System.Text.Json序列化器要求消息体必须是有效的JSON格式（比如空对象{}、空数组[]），完全空的消息体不符合其解析规则，因此触发异常。

官方推荐解决方案：使用Empty消息类型 #

MassTransit内置了MassTransit.Empty类型，专门用于空消息体场景。发送和消费时使用该类型，序列化器会自动将其序列化为空JSON对象{}（而非完全空的内容），既满足序列化要求，又实现了"无业务消息体"的需求。

发送示例 #

await bus.Publish<Empty>(new { }, context =>
{
    // 设置自定义消息头
    context.Headers.Set("YourCustomHeader", "header-value");
});

消费示例 #

public class EmptyMessageConsumer : IConsumer<Empty>
{
    public Task Consume(ConsumeContext<Empty> context)
    {
        // 读取消息头
        var headerValue = context.Headers.Get<string>("YourCustomHeader");
        
        // 执行业务逻辑
        return Task.CompletedTask;
    }
}

替代方案：自定义序列化配置 #

如果必须使用完全空的消息体，可以通过配置序列化器允许空输入。以System.Text.Json为例，可自定义转换器处理空内容，但这种方式可能引发其他兼容性问题，不推荐作为首选方案。

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