如何在RabbitMQ消息Header中传递字符串值并正确解析读取

问题原因 #

RabbitMQ .NET客户端对消息Header的序列化有默认规则：数值、布尔等简单值类型会保留原类型传输，字符串类型会被自动序列化为UTF8编码的字节数组，因此你在消费端直接强转字符串会触发类型转换异常，并不是只能在Header中传递整数。

解决方案 #

你只需要在消费端将读取到的字节数组解码为字符串即可，默认使用UTF8编码和生产端序列化规则匹配，修改你的消费端type读取逻辑如下：

string type;
try
{
    // 先取出header值，判断类型后做转换
    var typeHeaderValue = e.BasicProperties.Headers.FirstOrDefault(x => x.Key == "type").Value;
    if (typeHeaderValue is byte[] typeBytes)
    {
        type = System.Text.Encoding.UTF8.GetString(typeBytes);
    }
    else
    {
        // 兼容其他可能的类型场景
        type = typeHeaderValue?.ToString();
    }
}
catch (Exception exception)
{
    Console.WriteLine(exception);
    throw;
}

你也可以封装一个通用的Header读取工具方法，避免重复写类型判断和转码逻辑：

private T GetHeaderValue<T>(IDictionary<string, object> headers, string key)
{
    if (!headers.TryGetValue(key, out var value) || value == null)
        return default;
    
    if (value is T typedValue)
        return typedValue;
    
    // 特殊处理字符串类型：字节数组转UTF8字符串
    if (typeof(T) == typeof(string) && value is byte[] bytes)
        return (T)(object)System.Text.Encoding.UTF8.GetString(bytes);
    
    // 其他类型尝试用Convert转换
    return (T)Convert.ChangeType(value, typeof(T));
}

调用时直接使用即可：

var id = GetHeaderValue<int>(e.BasicProperties.Headers, "entityId");
var type = GetHeaderValue<string>(e.BasicProperties.Headers, "type");

额外说明 #

如果需要避免每次消费都转码，也可以在生产端自定义Header序列化规则，但没必要为了字符串类型单独修改默认逻辑，消费端做转码是最通用、兼容默认规则的处理方式。

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