如何为单个SendEndpoint配置UseRawJsonSerializer？MassTransit技术问询

回答 #

疑问解答 #

1. 不能直接修改已获取的SendEndpoint序列化器：GetSendEndpoint()返回的实例基于总线全局配置生成，获取后无法单独修改其序列化规则。
2. 发送序列化器并非只能全局定义：MassTransit支持为单个发送操作或特定端点单独指定序列化器，无需全局统一配置。
3. Publish操作确实存在默认全局限制，但同样支持单独配置：默认Publish使用总线全局序列化器，但也可通过重载方法指定特定序列化器。

自行方案评价 #

临时创建总线的方式可行，但并非最优：每次创建总线都会新建RabbitMQ连接、信道，频繁操作会产生额外资源开销和性能损耗，不适合高频发送场景。

更优替代方案 #

方案1：单次发送时指定原始JSON序列化器

使用Send方法的重载，通过SendContext临时指定序列化器，仅对当前发送生效：

var endpoint = await _bus.GetSendEndpoint(new Uri("queue:Assembling"));
await endpoint.Send<Message>(message, context =>
{
    context.UseRawJsonSerializer();
});

方案2：总线配置中预设特定端点的序列化规则

如果需要多次向该端点发送原始JSON，可在总线配置时为目标端点预设序列化规则：

builder.Services.AddMassTransit(x =>
{
    x.AddConsumer<AssemblingConsumer>();
    
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("localhost", h =>
        {
            h.Username("admin");
            h.Password("admin");
        });

        // 保留全局默认序列化器（适配其他端点需求）
        // 不要全局调用cfg.UseRawJsonSerializer()

        // 接收端点配置保持不变
        cfg.ReceiveEndpoint("Assembling", ep =>
        {
            ep.ConfigureConsumeTopology = false;
            ep.ClearSerialization();
            ep.UseRawJsonSerializer();
            ep.UseRawJsonDeserializer();
            ep.ConfigureConsumer<AssemblingConsumer>(context);
        }); 

        // 为发送到Assembling队列的消息预设原始JSON序列化器
        cfg.Send<Message>(x =>
        {
            x.UseRawJsonSerializer();
            x.EndpointName = "Assembling";
        });

        cfg.ConfigureEndpoints(context);
    });
})

配置完成后，直接调用Send即可自动使用原始JSON序列化：

var endpoint = await _bus.GetSendEndpoint(new Uri("queue:Assembling"));
await endpoint.Send<Message>(message);

方案3：专用原始JSON发送客户端（极端场景适用）

若需要彻底隔离，可注册专门的ISendEndpointProvider用于原始JSON发送，但前两种方案已覆盖绝大多数场景，该方案仅适用于特殊隔离需求。

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