C#泛型EventDocument类从MongoDB反序列化失败求助

1. 给Payload字段添加类型鉴别器（无需修改EventDocument类） #

MongoDB C#驱动需要知道Payload的具体类型才能正确反序列化，我们可以通过BsonClassMap在应用启动阶段（比如Program.cs中）配置类型映射，自动给Payload字段添加类型鉴别器（_t字段）——这个字段会记录TPayload的类型全名，存入数据库时自动带上，读取时驱动就能识别对应类型。

示例代码：

// 在应用启动时（比如服务配置完成后）添加配置
// 替换成你实际的事件类型和聚合ID类型
BsonClassMap.RegisterClassMap<EventDocument<OrderCreatedEvent, Guid>>(cm =>
{
    cm.AutoMap();
    // 配置Payload字段启用类型鉴别器
    cm.MapField(c => c.Payload)
      .SetSerializer(BsonSerializer.LookupSerializer<OrderCreatedEvent>()
      .WithDiscriminator(typeof(OrderCreatedEvent).FullName));
});

// 如果有多个事件类型，可以写通用方法批量注册
void RegisterEventDocumentMap<TPayload, TId>() 
    where TPayload : class 
    where TId : struct, IComparable
{
    BsonClassMap.RegisterClassMap<EventDocument<TPayload, TId>>(cm =>
    {
        cm.AutoMap();
        cm.MapField(c => c.Payload)
          .SetSerializer(BsonSerializer.LookupSerializer<TPayload>()
          .WithDiscriminator(typeof(TPayload).FullName));
    });
}

// 调用通用方法注册所有事件类型
RegisterEventDocumentMap<OrderCreatedEvent, Guid>();
RegisterEventDocumentMap<OrderShippedEvent, Guid>();

2. 修正查询过滤条件 #

之前的过滤逻辑错误，因为MongoDB会把类型鉴别器存在Payload的_t子字段中，而非直接将Payload字段的值设为类型名。正确的过滤条件应该匹配Payload._t：

// 正确过滤指定类型的事件
var filter = Builders<EventDocument<TPayload, TId>>.Filter.Eq("Payload._t", typeof(TPayload).FullName);
var targetEvents = await _events.Find(filter).ToListAsync();

3. 兼容已存储的旧数据（可选） #

如果数据库中已有未带_t字段的旧数据，需要批量补全类型鉴别器。可以用MongoDB Shell执行以下命令（根据实际事件类型的特征调整匹配条件）：

// 给OrderCreatedEvent类型的Payload添加_t字段
db.events.updateMany(
    {"Payload.OrderId": {$exists: true}}, // 用Payload的独有字段匹配旧数据
    {$set: {"Payload._t": "YourProjectNamespace.OrderCreatedEvent"}}
)

问题根源说明 #

• 反序列化失败：存入数据库时未保存TPayload的类型信息，MongoDB驱动无法将Object类型的Payload转换为具体的泛型类型。
• 查询返回空：之前的过滤条件试图将Object类型的Payload与字符串类型名直接比较，自然无法匹配到数据。

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