Marten项目中的投影API模型重构思考

引言

在事件溯源架构中，投影(Projection)是将事件流转换为可查询视图的核心机制。Marten作为.NET生态中强大的事件存储和文档数据库，其投影API的设计直接影响到开发者的使用体验和系统性能。本文将深入分析Marten当前投影模型存在的问题，并探讨未来版本可能的改进方向。

当前投影模型的问题

Marten现有的投影API主要面临以下几个关键挑战：

1. 代码生成方法的局限性：对于简单工作流，基于约定的Create()和Apply()方法表现良好，但在处理复杂业务逻辑时变得难以维护。

2. 显式代码编写体验不佳：CustomProjection作为显式编码的逃生舱口，当前API设计不够优雅，且不支持实时聚合。

3. 事件切片API复杂：现有的分组/切片API对开发者不够友好，学习曲线陡峭。

4. 功能重叠与冗余：存在多种投影类型(SingleStreamProjection、MultiStreamProjection等)，API边界不清晰。

5. 缺乏灵活的事件处理：难以在约定方法中实现"对最后遇到的事件应用此逻辑"等常见需求。

重构方向与解决方案

1. 投影接口简化

建议将现有复杂的IProjection接口拆分为更专注的职责：

// 基础投影接口
public interface IProjection
{
    Task ApplyAsync(IDocumentOperations operations, IReadOnlyList<IEvent> events, CancellationToken cancellation);
}

// 内联投影专用接口
public interface IInlineProjection<TOperations>
{
    Task ApplyAsync(IDocumentOperations operations, IReadOnlyList<StreamAction> streams, CancellationToken cancellation);
}

这种设计遵循了接口隔离原则，使不同类型的投影可以只实现它们真正需要的功能。

2. 聚合投影统一

计划将现有的多种聚合投影类型统一为：

• SingleStreamProjection<T>：处理单事件流聚合
• MultiStreamProjection<TDoc, TId>：取代现有的多种多流投影实现

两者都支持三种使用方式：

1. 覆盖ApplyChangesAsync方法处理复杂工作流
2. 实现简单的BuildAsync方法
3. 继续支持现有的约定方法

3. 事件切片API改进

新设计引入更清晰的事件分组接口：

public interface IEventGrouping<TId>
{
    void AddEvent(TId id, IEvent @event);
    void AddEvents(TId id, IEnumerable<IEvent> events);
    void AddEvents<TEvent>(Func<TEvent, TId> singleIdSource, IEnumerable<IEvent> events);
    void FanOutOnEach<TSource, TChild>(Func<TSource, IEnumerable<TChild>> fanOutFunc);
}

切片策略可以通过以下方式定义：

1. 使用Identity<T>、Identities<T>等现有方法
2. 覆盖新的IdentityFor(IEvent e)方法
3. 实现完整的SliceAsync方法处理自定义切片逻辑

4. 实时聚合器优化

新的ILiveAggregator<T>接口提供了更简洁的聚合方式：

public interface ILiveAggregator<T>
{
    ValueTask<T> BuildAsync(IReadOnlyList<IEvent> events, IQuerySession session, T? snapshot, CancellationToken cancellation);
}

配合C#的模式匹配，可以实现清晰的事件处理逻辑：

public ShoppingCart Build(ShoppingCart? current, IReadOnlyList<IEvent> events)
{
    var cart = current ?? ShoppingCart.Create(events.OfType<IEvent<CartCreated>>().First().Data.Id);
    
    foreach (var @event in events)
    {
        cart = @event.Data switch
        {
            ItemAdded itemAdded => cart.Apply(itemAdded),
            ItemRemoved itemRemoved => cart.Apply(itemRemoved),
            _ => cart
        };
    }
    return cart;
}

架构层面的改进

1. 核心逻辑提取：将事件存储和异步守护进程中不特定于PostgreSQL的部分提取到独立库中。

2. 显式代码优先：鼓励开发者在业务逻辑复杂时使用显式代码而非约定方法。

3. 生命周期简化：重新评估并简化投影生命周期选项，可能回归到更直观的命名方式。

开发者体验提升

1. 更严格的验证：确保投影定义方式(显式代码vs约定方法)是互斥的，避免混淆。

2. 更好的错误消息：为常见错误场景提供更清晰的指导。

3. 辅助工具类：提供帮助方法处理聚合初始化等常见模式。

4. 文档完善：特别是针对多流投影和事件切片等复杂场景。

总结

Marten的投影API重构旨在解决现有模型的痛点，同时为复杂事件处理场景提供更强大的支持。通过接口简化、功能整合和显式代码优先等原则，新设计将使开发者能够更自然地表达业务逻辑，同时保持框架的灵活性和性能。

这些改进将使Marten在事件溯源和CQRS架构中继续保持其作为.NET首选事件存储解决方案的地位，同时为未来的功能扩展(如事件归档和分区)奠定坚实基础。