Axon - SubscribingEvent 与 TrackingEvent 处理器

Question

我目前在 Axon 中使用 SubscribingEvent 处理器。使用它，所有内容都在单线程中执行（因为我想在单线程中执行命令并将事件应用于投影）确保所有内容都保存到数据库或回滚。

如果我们使用 TrackingEvent 处理器，如果该命令在 Aggregate 中成功执行并且 Aggregate 发出的事件被保存到 DB，但应用程序在 Projections 完成之前失败（这意味着没有保存到 DB），会发生什么？重新启动后的应用程序会继续投射此事件吗？

在我的情况下，我正在对 REST 调用进行投影，所以我想使用 SubscribingEvent 处理器对我来说是有意义的（所以要么一切正常，要么什么都没有）。如果我使用 TrackingEvent 处理器，并且应用程序在保存和投影之间崩溃 - 我会有不一致的状态。即使投影在下次启动时重新启动（我假设是这样），客户端也会再次发送相同的命令（认为它失败了），但是如果它第二次收到相同的命令会发生什么？

Answer 1

让我尝试为您提供一些见解！

如果我们使用 TrackingEvent 处理器，如果该命令在 Aggregate 中成功执行并且 Aggregate 发出的事件被保存到 DB，但应用程序在 Projections 完成之前失败（这意味着没有保存到 DB），会发生什么？

Axon 中的TrackingEventProcessor 通过TrackingToken 跟踪它处理过的事件。跟踪处理器只会在调用所有事件处理组件（例如更新您的投影的组件）之后更新TrackingToken。 因此，在该时间点重新启动时，跟踪处理器将再次处理该事件。在这样做时，它会尝试与您的整个事件流保持同步。

如果我使用 TrackingEvent 处理器，并且应用程序在保存和投影之间崩溃 - 我的状态会不一致。

这取决于您实现应用程序的方式。听起来一切都非常紧密耦合，这样做并没有接受你必须处理最终一致性的事实。我知道说起来容易做起来难，但是让您的前端不在您发出命令时期望立即响应最终会简化系统。话又说回来，这在很大程度上取决于您是否可以影响 UI 对做事的看法；不确定这是否适合您的情况。

即使在下次启动时重新启动投影（我假设是这样），客户端也会再次发送相同的命令（认为它失败了），但是如果它第二次收到相同的命令会发生什么？

这完全取决于您实施聚合的方式。聚合应决定是否可以执行命令。如果该决策的一部分是确保先前的命令与当前操作不同，那么您需要在 @CommandHandler 带注释的函数中考虑到这一点。

我希望这能给 Bojan 一些见解，并毫不犹豫地回答更多问题以掌握 Axon 的这一部分。