Axon事件只由我的服务的一个实例而不是全部(扇出)获得



我们有一个连接到Axon的Spring微服务,在这个类上有一个@Component和一个@EventHandler函数。像这样:

@Component
@AllowReplay(false)
class AClass {

@EventHandler
fun on(someEvent: SomeEvent) {
...some handling here
}
}

事件会正常接收,一切正常,但当我们运行服务的多个实例时,只有一个服务实例接收事件。我的用户认为这与事件处理器的工作方式有关(https://docs.axoniq.io/reference-guide/axon-framework/events/event-processors)但我需要该服务的所有实例来获取事件。如何配置?

这在很大程度上取决于您如何配置和使用它

所以,用你描述的方式,"拾取"事件,我认为这是正在处理的事件。在这种情况下,以及这里的另一个假设,即您正在使用某种跟踪事件处理器(TEP(,这就是这种逻辑和响应性所在

本质上,TEP负责"跟踪"它已经收到的事件,以避免对这些事件做出双重反应。在你的场景中,你的应用程序/实例似乎共享相同的数据库(因此共享相同的令牌(,这就是你看到它的原因。

关于您的"变通方法",您只需为处理组分配名称(也可以使用以下注释来完成:@ProcessingGroup("processing-group-name-you-want")。如果不分配名称,则使用包的默认名称。每个处理组后面都有一个跟踪令牌。在这种情况下,您会获得多个令牌,并多次对同一事件做出"反应"。

有关处理组的更多信息,我推荐这个答案。

这个答案对我来说很有效,尽管不是最漂亮的:Axon根据包名称"合并"处理器,因此一个服务的多个实例会导致一个处理器。

通过使用独特的处理组,您可以诱使Axon不要将不同的处理器"合并"为一个处理器。

@Autowired
fun configure(configurer: EventProcessingConfigurer) {
configurer.assignProcessingGroup { t: String? -> "${t}_${UUID.randomUUID()}" }
}

最新更新