识别并重新运行 Axon 中的特定事件

Question

我们正在研究从 axon 重新运行精心挑选的事件。用例将遵循以下内容。

如果即使命令成功，用户的注册事件也失败了，我们希望为该特定事件处理程序重新运行该特定事件。

我们研究过使用跟踪事件处理器，但这似乎是从特定时间点重放一组事件。但是，在我们的例子中，如果昨天有 100 个事件，我们只想在中间重新运行一个特定事件。

目前我们正在迁移到 Axon，因此决定主要使用 SubscriptionEventProcessors，因为它更加同步（即错误通过命令处理程序传播）。而且我们确实理解订阅处理器是无状态的，因为它们只处理通过事件总线接收到的内容。

所以我假设我们不能使用跟踪处理器？相反，我们需要加载特定事件并将其重新推送到事件总线？

我们怎样才能做到这一点？ （有无上述建议）

此外，关于识别异常，我们正在考虑使用方面和日志记录并读取特定日志行以查找异常。然而，我们确实注意到轴突和弹簧靴的跟踪模块。 https://github.com/AxonFramework/extension-tracing 但是它被提到处于测试阶段，我们也找不到太多参考文档。是否还有更好的基于轴突的解决方案？

Answer 1

为了快点，我会使用我在this问题上发布的类似回复。

我在那边的回复很快，可以总结为： 创建一个查询模型，其中包含“重新处理”所需的 @EventHandler 注释方法，您可以将其作为输入提供给 Axon 的 AnnotationEventHandlerAdapter 构造函数。您将根据您的要求使用过滤的事件流调用后续的AnnotationEventHandlerAdapter。结果，查询模型将更新为您需要的格式。

因此，您不会因为用户需要该信息而将其作为一种查询形式执行，而是在异常情况下执行该操作。无论如何，您仍将重新形成查询模型，但只是基于一组特定的事件。

顺便说一句，在选择事件处理器时，我还是会选择TrackingEventProcessor。是的，这意味着事件失败不会发出回滚，但本质上事件表明它已经发生。因此回滚是因为其他事情无法处理该事件是不正确的；该命令仍然成功，所以它也应该保持原样。

最后，您正在寻找日志记录逻辑。您共享的跟踪扩展程序最近刚刚从测试状态中撤出，因此可以安全使用。接下来，已经可以通过将LoggingInterceptor 配置为MessageHandlerInterceptor 和MessageDispatchInterceptor 来实现基本日志记录（可以在here 找到有关此的文档）。如果您希望引入 Aspect 逻辑：Axon 有一个类似的机制来绑定到那里的每个消息处理程序。看看this页面上的HandlerEnhancer/HandlerEnhancerDefintion。

希望这一切对你有所帮助@MilindaD！