Axon 如何添加事件侦听器/拦截器以在事件到达其处理程序之前对其进行拦截？

Question

我有一个投影类（用于构建读取模型），我想为其事件添加一个拦截器，如果事件中传递的 id 导致一个空对象（我的数据库中不存在），那么我要阻止它，否则让它过去。

这样我就可以避免在每个事件处理程序上添加一个空检查器。

@EventHandler
public void onEvent(Event event) {
    Entity entity = getEntity(event.getId());
    if(entity!=null){        // what I don't want to add on every event handler
        dostuff();
    }
}

我发现 axon 提供了一个名为 EventListener 的接口，但我不确定如何使用它，我不确定这是否会拦截我的所有事件或者我是否能够拦截选择事件.

除了官方文档中没有提到这个接口的任何地方（没有实际的例子左右）

Answer 1

你说得对，参考指南仍然需要一些改进 @bleh10 - 我可以向你保证，他们正在努力，团队只是分散得相对薄弱。

在没有广受欢迎的例子的情况下，我想我可以给你一些指导。

您正在寻找的是一个MessageHandlerInterceptor 实现，专门用于EventMessage 类型。顾名思义，它会在处理之前拦截消息，这与您提出的问题完美对应。

其次，您显然需要一个地方来配置这些。在 Axon 应用程序中，将事件传递给 @EventHandler 注释方法的技术方面是事件处理器。因此，它负责确保根据需要拦截流经它的事件消息。

因此，配置EventMessage MessageHandlerInterceptor 的位置在您选择的EventProcessor 实现上。为确保给定的事件处理组件设置在特定的 EventProcessor 中，您可以通过使用 @ProcessingGroup 注释对类进行注释来指定它的处理组。

从那里开始，您可以使用EventProcessingConfigurer 轻松配置事件处理器的特定属性。更具体地说，我建议为此使用EventProcessingConfigurer#registerHandlerInterceptor(String, Function<Configuration, MessageHandlerInterceptor<? super EventMessage<?>>>) 方法。

第一个String 参数用于描述处理组的名称。第二个是Function，它接收Axon Configuration，应该输出一个MessageHandlerInterceptor，它可以处理EventMessage类。

希望对你有所帮助！