cqrs - 如何在 CQRS/事件溯源中以确定性方式重放？

Question

在基于 CQRS/ES 的系统中，您将事件存储在事件存储中。这些事件涉及一个聚合，并且它们相对于它们所属的聚合有一个顺序。此外，聚合是一致性/事务边界，这意味着任何事务保证仅在每个聚合级别上给出。

现在，假设我有一个读取模型，它消耗来自多个聚合的事件(据我所知，这完全没问题)。为了能够以确定性的方式重播读取模型，事件需要某种跨聚合的全局排序 - 否则您将不知道是否在 B 的事件之前或之后重播聚合 A 的事件，或者如何混合他们。

实现这一点的最简单的解决方案是在事件上使用时间戳，但通常时间戳不够细(或者，换句话说，并非所有数据库都是相同的)。另一种选择是使用全局序列，但这在性能方面很差并且阻碍扩展。

您如何解决这个问题？或者我的基本假设是，读取模型的重放应该是确定性的，是错误的吗？

Answer 1

我看到这些选项:

• 全局序列

  • 如果你的数据库允许，你可以使用timestamp+aggregateId+aggregateVersion作为索引。这通常在分布式数据库情况下效果不佳。

  • 在分布式数据库中您可以使用 vector clock无需锁定即可获取全局序列。

• 每个读取模型内的事件序列。您可以将所有事件存储在读取模型中，并在应用投影函数之前根据需要对它们进行排序。

• 允许非决定论并处理它。例如，在您的示例中，如果 add_user 事件到达时没有组 - 只需在读取模型中创建一个空组记录并添加用户。当 create_group 事件到达时 - 更新该组记录。毕竟，您已经 checkin 了 UI 和/或命令处理程序是一个具有该aggregateId的组，对吧？