重播特定类型的事件

Question

我正在查看 joliver 的 EventStore 并考虑为新的事件处理程序重播事件。我看到有一种方法可以获取自某个时间点（ICommitStreams.GetFrom(Date)）以来的所有提交，但我不知道如何仅获取特定类型的事件。

我错过了什么吗？

Answer 1

仅供参考，这就是我所做的：

var typesToSend = typeof (MyApp.Messages.Events.SomeAggregate.SomeEvent).Assembly
    .GetTypes()
    .Where(t => t.Namespace != null && t.Namespace.StartsWith("MyApp.Messages.Events.SomeAggregate"))
    .ToList();

var commits = eventStore.Advanced.GetFrom(DateTime.MinValue)
    .Where(c => c.Events.Any(e => typesToSend.Contains(e.Body.GetType())))
    .OrderBy(c => c.CommitSequence)
    .ToList();

正如 Jonathan 所说，一次提交可能包含多个事件，这将获取包含至少一个我正在查找的事件的所有提交。要进一步过滤，您必须查看提交中的每个事件。

Answer 2

EventStore 本身并不特别关心提交的内容，这意味着它本身不会跟踪每次提交的单个事件类型。

这有几个原因。一是简单性，二是能够支持几乎任何存储引擎。我想让设计非常简单，模型也非常干净。此外，我希望避免对底层存储引擎要求过高，它可能或可能支持索引。如果您要查询特定类型，则您已经假设底层存储引擎提供索引。由于 EventStore 与存储引擎无关，因此两者不能混合。

另一件事是，“提交”实际上是一组一个或多个事件。当您加载提交时，您会获得所有事件。

一种可能的解决方案是加载某个时间点以来的所有内容，然后忽略您不关心的事件。另一种解决方案是让订阅者监听来自 EventStore 的所有消息，并通过事件类型的适当索引（异步/在另一个线程上）将消息推送到持久存储中。正确答案取决于您的性能要求。