如何在MassTransit消费者中获取RabbitMQ原生消息头？

MassTransit默认不会把RabbitMQ的原生消息头直接放到消息信封的公共头集合里，但你可以通过以下方式获取：

1. 消费时获取RabbitMQ原生属性 #

在消费者的Consume方法中，通过ConsumeContext的GetPayload<IBasicProperties>方法获取RabbitMQ的原生消息属性对象，从中提取目标头或timestamp：

public async Task Consume(ConsumeContext<YourMessageType> context)
{
    // 获取RabbitMQ原生基础属性
    var rabbitMqProperties = context.GetPayload<IBasicProperties>();

    // 场景1：读取RabbitMQ原生timestamp（默认单位为秒）
    if (rabbitMqProperties.Timestamp != null)
    {
        // 转换为毫秒级时间戳
        long timestampInMs = rabbitMqProperties.Timestamp.Value * 1000;
        // 业务逻辑处理...
    }

    // 场景2：读取插件生成的`timestamp_in_ms`自定义头
    if (rabbitMqProperties.Headers.TryGetValue("timestamp_in_ms", out var timestampObj) && 
        long.TryParse(timestampObj.ToString(), out var timestampInMs))
    {
        // 业务逻辑处理...
    }
}

2. 配置注意事项 #

• 确保你的MassTransit接收端点配置没有过滤原生消息头，默认配置下MassTransit会保留RabbitMQ的原生头信息。
• 若使用RabbitMQ原生的timestamp功能（非插件），需要确认RabbitMQ已启用该配置，原生timestamp存储的是Unix时间戳（单位秒），需自行转换为毫秒。

内容的提问来源于stack exchange，提问作者julio.g