轴突事件处理程序读取所有事件每次重启

Question

我在 Spring 应用程序中使用 Event Handler 来查询我在 axon 框架中的事件。我可以从我的命令中放置一个事件，我可以从我的查询应用程序中读取它们。直到重新启动时间没问题但是当我重新启动我的查询应用程序时，每次它在开始时再次读取相同的事件并导致重复过程。阅读时如何提交事件？

ToMyAxonConfig

@Bean
    public TokenStore tokenStore(Serializer serializer, EntityManagerProvider entityManagerProvider) {
      return JpaTokenStore.builder()
                .entityManagerProvider(entityManagerProvider)
                .serializer(serializer)
                .build();
    }

   @Autowired
    public void configureProcessors(EventProcessingConfigurer eventProcessingConfigurer) {
        TrackingEventProcessorConfiguration tepConfig = TrackingEventProcessorConfiguration.forSingleThreadedProcessing().andInitialTrackingToken(StreamableMessageSource::createHeadToken);
        eventProcessingConfigurer.registerTrackingEventProcessorConfiguration(config -> tepConfig);
    }

Answer 1

我感觉你没有配置TokenStore。 在这种情况下，Axon Framework 将为您提供一个 InMemoryTokenStore 实现，这意味着每次重新启动时，您都将从您的事件存储中再次获取所有事件，因为您的应用程序没有令牌的“状态”。

您可以查看ref-guide 以了解更多信息以及如何从多个选项中正确配置一个。

我如何在阅读时提交事件？

此外，为了更正此处的单词用法，事件是在您的事件存储中“提交”的。如果您在谈论您的查询端应用程序，您不会在那里提交事件，而只是根据事件保存状态。