如何在MassTransit中配置使用自定义System.Text.Json转换器

实现步骤 #

• 直接在总线传输配置（比如RabbitMQ、InMemory、Azure Service Bus等对应的Usingxxx配置块）中调用ConfigureJsonSerializerOptions扩展方法，在传入的委托中修改序列化选项，添加自定义ConverterFactory即可。
• 如果需要自定义反序列化逻辑，调用ConfigureJsonDeserializerOptions做相同配置即可。

代码示例 #

// 以ASP.NET Core集成 + RabbitMQ传输为例
var builder = WebApplication.CreateBuilder(args);

builder.Services.AddMassTransit(busConfig =>
{
    // 此处添加你的消费者、Saga等常规配置
    busConfig.AddConsumer<YourMessageConsumer>();

    busConfig.UsingRabbitMq((context, mqConfig) =>
    {
        mqConfig.Host("your-rabbitmq-host", h =>
        {
            h.Username("your-username");
            h.Password("your-password");
        });

        // 配置System.Text.Json序列化选项，添加自定义ConverterFactory
        mqConfig.ConfigureJsonSerializerOptions(jsonOpts =>
        {
            jsonOpts.Converters.Add(new YourCustomJsonConverterFactory());
            // 可在此处添加其他序列化配置，比如命名策略、忽略规则等
            return jsonOpts;
        });

        // 反序列化配置（如果需要单独调整反序列化逻辑）
        mqConfig.ConfigureJsonDeserializerOptions(jsonOpts =>
        {
            jsonOpts.Converters.Add(new YourCustomJsonConverterFactory());
            return jsonOpts;
        });

        mqConfig.ConfigureEndpoints(context);
    });
});

注意事项 #

• 上述配置为全局生效，会应用到所有MassTransit处理的消息序列化/反序列化流程
• 该方法适用于MassTransit 8.x及以上版本（默认使用System.Text.Json作为序列化器），更低版本如果已经手动切换到System.Text.Json序列化器，也可以用相同逻辑配置

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