JOliver EventStore 快照

Question

假设我有这段代码：

private void CreateSnapshots(IEnumerable<StreamHead> streams)
{
    foreach (StreamHead head in streams)
    {
        IAggregate aggregate = ???;
        IMemento memento = aggregate.GetSnapshot();

        var snapshot = new Snapshot(head.StreamId, head.SnapshotRevision + 1, memento);

        eventStore.AddSnapshot(snapshot);

        observer.Notify(new SnapshotTaken(head.StreamId, head.HeadRevision));
    }
}

我如何知道要为当前流加载什么聚合？我也在使用 CommonDomain。里面有东西吗？

谢谢

Answer 1

EventStore 的快照方面需要一点关爱。我尝试使 IStoreEvents 接口适合与单个聚合一起使用。我还尝试确保快照不会干扰或妨碍正常使用。

自 v2.0 发布以来，我现在将注意力转向 v2.1，并且我将能够进行一些与此相关的小的 API 更改。同时，您最好的选择可能是在进行快照时完全绕过 IStoreEvents。

另一种选择是让快照代码与常规代码一起在进程内运行。当加载聚合需要快照时，您可以轻松地将对该聚合的引用异步推送到快照代码。通过这种方式，您实际上不必执行加载，因为您已经拥有了聚合。

Answer 2

我找到了一个适合我的解决方案（这绝对是一个黑客）。它仍然是带外快照。这是一个示例。

private void CreateSnapshots(IEnumerable<StreamHead> streams)
{
    foreach (StreamHead head in streams)
    {
        //NOTE: This uses a patched version of EventStore that loads commit headers in OptimisticEventStream.PopulateStream()
        // <code>
        // this.identifiers.Add(commit.CommitId);
        // this.headers = this.headers.Union(commit.Headers).ToDictionary(k => k.Key, k => k.Value);
        // </code>
        var stream = eventStore.OpenStream(head.StreamId, int.MinValue, int.MaxValue);

        //NOTE: Nasty hack but it works.
        var aggregateType = stream.UncommittedHeaders.Where(p=>p.Key=="AggregateType").First();
        var type = aggregateTypeResolver(aggregateType.Value.ToString());

        MethodInfo methodInfo = typeof(IRepository).GetMethod("GetById");
        MethodInfo method = methodInfo.MakeGenericMethod(type);

        object o = method.Invoke(repository, new object[]{head.StreamId, head.HeadRevision});
        var aggregate = (IAggregate) o;

        IMemento memento = aggregate.GetSnapshot();

        var snapshot = new Snapshot(head.StreamId, head.HeadRevision, memento);

        eventStore.AddSnapshot(snapshot);

        observer.Notify(new SnapshotTaken(head.StreamId, head.HeadRevision));
    }
}