MassTransit 8.3.0序列化含NpgsqlConnection的异常引发错误，如何处理？

方案1：自定义异常过滤器，清理不可序列化对象 #

通过实现IExceptionFilter拦截MassTransit的异常处理流程，在异常被序列化前移除NpgsqlConnection相关引用：

public class CleanDbConnectionExceptionFilter : IExceptionFilter
{
    public Task Send(ExceptionFilterContext context, IPipe<ExceptionFilterContext> next)
    {
        var exception = context.Exception;
        while (exception != null)
        {
            // 清理异常Data字典中的连接对象
            if (exception.Data != null)
            {
                var keysToRemove = exception.Data.Cast<DictionaryEntry>()
                    .Where(de => de.Value is NpgsqlConnection)
                    .Select(de => de.Key)
                    .ToList();
                
                foreach (var key in keysToRemove)
                    exception.Data.Remove(key);
            }

            // 处理AggregateException的内部异常
            if (exception is AggregateException aggEx)
            {
                var cleanedInners = aggEx.InnerExceptions
                    .Select(CleanException)
                    .Where(ex => ex != null)
                    .ToList();
                
                context.ReplaceException(new AggregateException(cleanedInners));
            }
            // 替换包含连接引用的Npgsql相关异常
            else if (exception.TargetSite?.DeclaringType?.Namespace?.Contains("Npgsql") == true)
            {
                context.ReplaceException(new InvalidOperationException(exception.Message, exception.InnerException));
            }

            exception = exception.InnerException;
        }

        return next.Send(context);
    }

    private Exception CleanException(Exception ex)
    {
        if (ex == null) return null;
        
        if (ex.Data != null)
        {
            var keysToRemove = ex.Data.Cast<DictionaryEntry>()
                .Where(de => de.Value is NpgsqlConnection)
                .Select(de => de.Key)
                .ToList();
            
            foreach (var key in keysToRemove)
                ex.Data.Remove(key);
        }

        if (ex is AggregateException aggEx)
        {
            var cleanedInners = aggEx.InnerExceptions.Select(CleanException).Where(e => e != null).ToList();
            return cleanedInners.Any() ? new AggregateException(cleanedInners) : null;
        }

        return ex;
    }

    public void Probe(ProbeContext context)
    {
        context.CreateFilterScope("clean-db-connection-exception");
    }
}

在MassTransit配置中注册该过滤器：

services.AddMassTransit(x =>
{
    // 其他Saga、消费者配置...
    
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.UseFilter(new CleanDbConnectionExceptionFilter());
        // 其他RabbitMQ连接配置...
    });
});

方案2：限制异常序列化的信息量 #

通过配置ExceptionInfoOptions，禁止序列化异常的Data属性，避免触发不可序列化对象的序列化逻辑：

services.AddMassTransit(x =>
{
    // 其他配置...
    
    x.SetExceptionInfoOptions(options =>
    {
        options.IncludeExceptionData = false; // 关闭异常Data字典的序列化
        options.IncludeInnerExceptions = true; // 保留内部异常栈
        options.IncludeStackTraces = true;
    });

    x.UsingRabbitMq((context, cfg) =>
    {
        // 其他RabbitMQ配置...
    });
});

方案3：业务代码层包装异常 #

在Saga的数据库操作代码中，直接捕获Npgsql相关异常，重新包装为不包含连接对象的自定义异常：

try
{
    await using var conn = new NpgsqlConnection(_connectionString);
    await conn.OpenAsync();
    // 业务数据库操作逻辑
}
catch (NpgsqlException ex)
{
    // 仅保留异常消息和内部栈，不传递连接对象
    throw new SagaDatabaseOperationException("Saga数据库操作失败", ex);
}

自定义异常SagaDatabaseOperationException仅包含必要的错误信息，不持有任何数据库连接引用。

额外排查建议 #

• 升级MassTransit至最新稳定版：后续版本可能修复了废弃TypeMapper属性引发的序列化问题
• 开启MassTransit调试日志：在高负载场景下记录原始异常信息，辅助排查

services.AddLogging(logging =>
{
    logging.AddConsole();
    logging.SetMinimumLevel(LogLevel.Debug);
});

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