如何在推送至Azure Topics时自定义MassTransit消息负载

当然可行，MassTransit提供了两种核心方式实现完全自定义消息负载，适配非MassTransit接收端的需求：

1. 直接发送原始消息（Raw Message） #

跳过MassTransit默认的消息包装逻辑，直接传递你自定义的字节流或字符串作为消息内容，完全控制负载格式：

// 自定义的消息内容，比如符合接收端格式的JSON字符串
var customPayload = "{\"OrderId\":\"123\",\"Amount\":99.99}";
var payloadBytes = Encoding.UTF8.GetBytes(customPayload);

// 发送到指定Azure Topic
await bus.SendRaw(
    new Uri("azure://your-connection-string/your-topic-name"),
    payloadBytes,
    new Dictionary<string, object>
    {
        ["ContentType"] = "application/json" // 指定内容类型，方便接收端解析
    });

这种方式下，MassTransit不会添加任何额外包装，消息队列中存储的就是你传入的原始内容。

2. 自定义序列化器 #

如果仍想使用强类型消息对象，但不想用MassTransit默认的Envelope包装格式，可以自定义序列化器，直接序列化消息对象本身：

• 实现IMessageSerializer接口（或继承现有序列化器如JsonMessageSerializer），重写序列化逻辑，输出纯对象的JSON（而非MassTransit的包装结构）：

public class CustomJsonSerializer : IMessageSerializer
{
    public ContentType ContentType => new ContentType("application/json");

    public void Serialize<T>(Stream stream, T message)
    {
        // 直接序列化消息对象，跳过MassTransit的Envelope包装
        JsonSerializer.Serialize(stream, message);
    }

    public object Deserialize(Stream stream, MessageContext context)
    {
        // 如果需要接收消息，这里实现对应的反序列化逻辑（仅发送的话可简化）
        throw new NotImplementedException();
    }
}

• 在MassTransit配置中替换默认序列化器：

services.AddMassTransit(x =>
{
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("your-connection-string");
        // 使用自定义序列化器
        cfg.UseSerializer(() => new CustomJsonSerializer());
    });
});

之后发送强类型消息时，就会直接输出对象的JSON结构，没有MassTransit的额外字段。

注意事项 #

• 务必设置正确的ContentType，确保接收端能识别并解析消息格式；
• 发送原始消息时，需自行处理序列化、编码逻辑，避免格式不匹配；
• 自定义消息头的需求仍可满足：发送原始消息时通过SendRaw的参数添加，使用强类型消息时可通过Send上下文配置，不会影响负载的自定义。

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