如何存储 sagas 的数据？

Question

根据我的阅读，聚合必须只包含用于保护其不变量的属性。

我还读到 sagas can be aggregates 这对我来说很有意义。

现在我使用 saga 模拟了一个注册过程：在RegistrationStarted 事件上，它发送一个ReserveEmail 命令，如果电子邮件是免费的，它将触发EmailReserved 或EmailReservationFailed。然后，侦听器将发送验证链接或通知帐户已存在的消息。

我想在此侦听器中使用来自 RegistrationStarted 事件的数据（例如 IP 和用户代理）。我该怎么做？

• 将这些数据存储在 saga 中？但它们不用于保护不变量。
• 通过ReserveEmail 命令和结果事件推动他们？听起来很乏味。
• 将 saga 投影到读取模型？那么最终的一致性呢？
• 另一种方式？

Answer 1

Rinat Abdullin wrote a good overview of sagas / process managers.

通常的答案是 saga 拥有它关心的事件的副本，并使用这些事件中的信息来计算要发送的命令消息。

List[Command] processManager(List[Event] events)

通过 ReserveEmail 命令和结果事件推送它们？

是的，这是通常的方法；我们得到一个列表[RegistrationStarted]，我们用它来计算结果[ReserveEmail]。稍后，我们会得到[RegistrationStarted, EmailReserved]，我们可以用它来计算下一组命令（如果有的话）。

听起来很乏味。

数据必须以某种方式在两种功能之间传输。因此，您要么将数据从一条消息复制到另一条消息，要么将 correlation identifier 从一条消息复制到另一条消息，然后允许消费者决定如何使用相关标识符来获取数据的副本。

将这些数据存储在 saga 中？但它们不用于保护不变量。

您通常会将事件存储在 sagas 中（以跟踪发生的事情）。这为您提供了事件中提供的数据的副本。您没有要保护的不变量，因为您只是在缓存一个在其他地方做出的决策的副本。您通常不会让流程管理器运行查询来收集额外的数据。

最终的一致性怎么样？

就其本质而言，saga 总是“最终一致”； saga 实例的“状态”只是其他地方控制的数据的缓存副本。到 saga 看到数据时，数据可能是纳秒级的，假装数据是“现在”是没有意义的。

如果我理解正确，我可以将我的 saga 建模为一个注册聚合，存储其相关标识符是它自己的标识符的所有事件？

乌迪·达汉，writing about CQRS：

这是我能告诉你的最有力的迹象，表明你正在正确地执行 CQRS：你的总根是 sagas。