Marten项目中的内联聚合投影重复事件问题分析

问题背景

在Marten 7.21.0及以上版本中，使用内联(Inline)聚合投影时出现了一个关键问题：当配置为options.Projections.Snapshot<AggregateType>(SnapshotLifecycle.Inline)的聚合会接收到完全相同的两个事件（包括相同的事件ID、关联ID和因果关系ID）。这导致聚合的Apply方法被调用两次，严重影响了系统的正确性。

问题表现

具体表现为：

1. 聚合版本号从1开始
2. 事件被手动应用到聚合实例上（版本号增加到2）
3. 通过session.Events.Append()将事件添加到会话
4. 调用SaveChangesAsync保存更改
5. 在7.21.0+版本中，SingleStreamProjection会再次应用已经应用过的事件
6. 导致聚合状态被错误修改（如集合中出现重复项）

技术原因

问题的根源在于7.21.0版本引入的一个优化改动。该改动原本是为了配合新的FetchForWriting功能，但在实现上存在缺陷：

1. 内联投影现在通过LoadAsync()加载聚合，而不是绕过加载过程
2. 当手动应用事件到聚合实例后，内联投影会再次应用相同的事件
3. 导致聚合状态被修改两次，而数据库只记录最终版本

解决方案

Marten团队已经采取了以下措施：

1. 暂时回滚了所有与内联投影优化相关的代码变更
2. 提供了配置选项opts.Events.UseIdentityMapForInlineAggregates = false来禁用此优化

最佳实践建议

对于使用Marten的开发者，建议：

1. 如果升级到7.21.0+版本后遇到类似问题，可以：

   • 降级回7.20.2版本
   • 或显式设置UseIdentityMapForInlineAggregates = false

2. 在命令处理程序中：

   • 确保事件应用逻辑是幂等的
   • 考虑在聚合设计中加入重复事件检测机制

3. 测试策略：

   • 增加对聚合状态变更次数的断言
   • 验证最终聚合版本号是否符合预期

总结

这个案例展示了ORM/事件溯源框架中优化可能带来的副作用。Marten团队快速响应并提供了解决方案，体现了开源项目的优势。对于开发者而言，在框架升级时需要特别关注变更日志，并对核心业务流程进行充分测试，确保系统行为的正确性。