使用 CQRS 和 EventSourcing 时如何确保外部投影同步？

Question

我正在启动一个新应用程序，我想使用 cqrs 和事件源。我想到了重播事件以重新创建聚合和快照以在需要时加速，在内存模型、缓存等中使用。

我的问题是关于我不想保留在内存中的大型读取模型。假设我有一个销售产品的应用程序，我想监听诸如“ProductRegistered”“ProductSold”之类的事件流，并在关系数据库中构建一个表，用于报告或与另一个系统集成。假设有很多记录，并且此表可能需要几秒钟到几分钟的时间来截断/重建，并且应用程序会出于多种目的导出数十个这样的预测。

在这种情况下如何处理预测的一致性？

使用内存中的数据，回放事件非常简单和快速。但我觉得保存在磁盘中的外部预测重建速度会慢得多。

1. 我是否应该始终使用 TRUNCATE TABLE + 重建每个外部投影来启动我的应用程序？随着时间的推移，这对我来说似乎不切实际，但我可能会担心我还没有遇到的问题。

2. 由于表本身就像一个快照，我可以保留一个“控制表”来判断哪个事件是我为该投影处理的最后一个事件，因此我可以只重播需要的内容。但是如果应用程序或数据库崩溃，我担心会出现不一致。看来检查表的一致性和重建会是一样的，这又指向了解决方案1。

您将如何以可随时间推移进行维护的方式来处理它？有没有更好的解决方案？

非常感谢。

Answer 1

处理此问题的一种方法是检查点的概念。本质上，您的事件流或整个系统都有一个版本号（检查点），随着每个事件的增加而增加。

对于每个投影，您存储应用的最后提交的检查点。在启动时，您提取大于应用于投影的最后一个检查点编号的事件，并从那里继续构建您的投影。如果您需要重建投影，请删除数据和检查点并重新运行整个流（或流集）。

注意：最后应用的检查点和投影的读取模型需要保存在单个事务中，以确保它们不会不同步。