Axon事件仅由我的服务的一个实例而不是所有实例拾取(扇出)

Question

我们有一个Spring微服务连接到Axon，在这个类上有一个@组件和一个@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)有关，但我需要该服务的所有实例来获取事件。如何配置？

Answer 1

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

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

本质上，TEP负责“跟踪”它已经接收到的事件，以避免对这些事件产生双重反应。在您的场景中，您的应用程序/实例似乎正在共享相同的数据库(因此共享相同的令牌)，这就是您看到它的原因。

关于您的“变通方法”，您只是将名称分配给一个Processing Group (这也可以使用如下的注释来完成：@ProcessingGroup("processing-group-name-you-want")。如果未指定名称，则使用的默认名称为package。每个处理组背后都有一个跟踪令牌。在这种情况下，您将获得多个令牌，并多次“反应”同一个事件。

有关处理组的更多信息，我推荐使用this answer。

Answer 2

对我有效的答案，虽然不是最漂亮的: Axon根据包名“合并”处理器，这样一个服务的多个实例就会产生一个处理器。

通过使用独特的处理组，您可以使Axon不将不同的处理器“合并”为一个处理器。

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