Outbox模式下，无类型信息的JSON与类型化对象序列化反序列化方案

核心问题拆解 #

当前你面临的两个核心痛点：

• 存储AssemblyQualifiedName作为事件类型：存在反序列化安全风险，且耦合具体程序集结构，后续迁移到消息中间件时兼容性差
• 用枚举标记事件类型：新增事件需频繁修改枚举和大量switch分支，维护成本高且违反开闭原则

可维护的解决方案推荐 #

1. 自定义语义化事件标识系统（轻量解耦） #

为每个事件定义唯一、语义化的字符串标识（如"user.created"、"order.updated"），通过自定义特性绑定到事件类上：

[EventKey("user.created")]
public class UserCreatedEvent : INotification
{
    public Guid UserId { get; set; }
    public string Email { get; set; }
}

// 自定义特性类
[AttributeUsage(AttributeTargets.Class, Inherited = false)]
public class EventKeyAttribute : Attribute
{
    public string Key { get; }
    public EventKeyAttribute(string key) => Key = key;
}

程序启动时一次性扫描所有事件类型，构建标识-类型映射字典：

// 初始化映射（可放在Startup/Program.cs中）
var eventTypeMap = AppDomain.CurrentDomain.GetAssemblies()
    .SelectMany(a => a.GetTypes())
    .Where(t => typeof(INotification).IsAssignableFrom(t) && !t.IsAbstract)
    .ToDictionary(
        t => t.GetCustomAttribute<EventKeyAttribute>()?.Key 
             ?? throw new InvalidOperationException($"事件{t.Name}未标记EventKey特性"),
        t => t
    );

序列化事件时存储这个语义化EventKey；反序列化时通过字典匹配对应类型，彻底替代AssemblyQualifiedName。

2. 结合Mediatr的自动映射与注册 #

利用Mediatr的依赖注入能力，在注册事件处理器时同步维护映射关系：

// 扩展方法批量注册事件和映射
public static IServiceCollection AddAppEvents(this IServiceCollection services)
{
    var eventTypes = typeof(UserCreatedEvent).Assembly.GetTypes()
        .Where(t => typeof(INotification).IsAssignableFrom(t) && !t.IsAbstract);

    foreach (var eventType in eventTypes)
    {
        var eventKey = eventType.GetCustomAttribute<EventKeyAttribute>()?.Key;
        if (string.IsNullOrEmpty(eventKey)) continue;

        // 注册Mediatr事件处理器
        services.AddScoped(typeof(INotificationHandler<>).MakeGenericType(eventType));
        // 注册事件映射
        services.AddSingleton(new EventMapping(eventKey, eventType));
    }

    // 注册映射查询服务
    services.AddSingleton<IEventMappingProvider>(sp => 
        new EventMappingProvider(sp.GetRequiredService<IEnumerable<EventMapping>>()));

    return services;
}

// 映射实体与查询服务
public record EventMapping(string Key, Type EventType);
public interface IEventMappingProvider
{
    Type GetEventType(string key);
}

public class EventMappingProvider : IEventMappingProvider
{
    private readonly Dictionary<string, Type> _mappingDict;
    public EventMappingProvider(IEnumerable<EventMapping> mappings)
    {
        _mappingDict = mappings.ToDictionary(m => m.Key, m => m.EventType);
    }

    public Type GetEventType(string key) => 
        _mappingDict.TryGetValue(key, out var type) ? type : 
        throw new KeyNotFoundException($"未找到事件标识{key}对应的类型");
}

后台发布事件时，通过IEventMappingProvider获取类型后反序列化，再交给Mediatr处理即可。

3. 额外优化点 #

• 版本兼容：标识中可加入版本号（如"user.created.v2"），支持多版本事件共存，平滑迭代处理逻辑
• 安全校验：反序列化前校验标识是否在预定义映射中，避免恶意标识触发未知类型反序列化，解决AssemblyQualifiedName的安全隐患
• 迁移友好：语义化标识可直接作为消息中间件的Topic或RoutingKey，后续扩展分布式架构时无需额外适配

方案优势对比 #

• 低耦合：事件标识与程序集、类名解耦，重构或迁移程序集不影响存储逻辑
• 易维护：新增事件只需添加特性，无需修改全局枚举或switch，符合开闭原则
• 安全可控：通过白名单式映射限制反序列化类型，避免注入风险
• 迁移平滑：天然适配消息中间件的路由规则，后续扩展分布式架构成本低

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