使用Axon Server跨不同JVM将事件分发到订阅事件处理器（没有事件源）

Question

我使用Axon Framework(4.1)，其中一个模块(JVM、容器）中有聚合，另一个模块中有Projections/Sagas。我想做的是让一个分布式应用程序利用CQRS，但没有事件源。

这是相当琐碎的设置和一切工作在一个单一的应用程序预期。当涉及到几个独立的模块（跨独立的JVM）时，问题就出现了。开箱即用的Axon starter使用连接到AxonServerEventStore的跟踪处理器，这允许在监听不同JVM之间的事件时具有“位置透明性”。

在我的情况下，我不想要任何用于持久化或跟踪事件的基础设施。我只想以一种触发-忘记的方式将事件从聚合中分发到任何订阅处理器，就像AxonServerQueryBus分发分散-聚集查询一样。

如果我将所有处理器声明为订阅，如下所示：

    @Autowired
    public void configureEventSubscribers(EventProcessingConfigurer configurer) {
        configurer.usingSubscribingEventProcessors();
    }

事件将到达同一JVM中的所有@eventHandler方法，但事件不再到达其他JVM中的任何处理程序。如果我的理解是正确的，那么，Axon Server将在JVM之间分发事件，仅用于跟踪处理器。

显然，我所能做的是使用外部消息代理(RabbitMQ，Kafka)与SpringamQpMessageSource（如文档中所示）相结合，通过RabbitMQ中的fanout之类的东西将事件分发到所有订阅服务器。这是有效的，但这需要自己维护经纪人。

最好是让Axon服务器来处理这个问题，就像它处理分发命令和查询一样（这样我就可以少关心一个基础结构）。

顺便说一句，我实际上已经设法使用QueryBus将事件分发到投影，并将事件作为有效负载传递到作为分散-聚集查询发送的GenericQueryMessage。不用说，这不是一个稳健的解决方案。但它证明了Axon服务器将事件（毕竟只是另一种类型的消息）无动于衷地分发到SEPs或TEPs并没有什么本质上不可能的。

最后是问题：

2）是否可以让Axon Server跨JVM将事件分发到SEP（不需要外部html" target="_blank">消息代理）？

Answer 1

关于事件来源的注意事项

从Axon框架的角度来看，事件源是命令模型的唯一关注点。这是采取的立场，因为事件来源定义了通过一个模型已经发布的事件重新创建一个模型。然而，查询模型不会对命令做出反应，发布事件改变了它的状态，它只是侦听（分布式）事件来更新它的状态，以供其他人查询。因此，框架只在重新创建聚合时考虑事件源，方法是提供EventSourcingRepository。

事件处理器的工作是“向事件处理程序提供事件的机械方面”。这与CQRS中的Q部分有关，与重新创建查询模型有关。因此，该框架并不将事件处理器视为事件来源概念的一部分。

最后，您将需要定义存储跟踪令牌的基础结构，以便能够分发事件负载，本质上选择完全不使用SubscribingEventProcessor。

然而，上述是否是issu取决于您的应用程序。也许您根本没有复制给定的应用程序，因此实际上不会复制给定的跟踪事件处理器。在这种情况下，您可以满足“不跟踪事件”的请求，同时仍然使用跟踪事件处理器。你所要做的就是确保你没有储存它们。用于存储令牌的接口是tokenstore，其中存在内存版本。

然而，在默认的Axon设置中使用InmemoryTokenStore意味着在技术上每次都要重播事件。这是由于默认的“初始跟踪令牌”过程造成的。当然，这也是可配置的，我建议您使用以下方法：

// Creating the configuration for a TEP
TrackingEventProcessorConfiguration tepConfig = 
    TrackingEventProcessorConfiguration
        .forSingleThreadedProcessing() // Note: could also be multi-threaded
        .andInitialTrackingToken(StreamableMessageSource::createHeadToken);

// Registering as default TEP config
EventProcessingConfigurer.
    registerTrackingEventProcessorConfiguration(config -> tepConfig);    

是否可以让Axon Server跨JVM将事件分发到SEP（不需要外部消息代理）？

正如您已经正确指出的，SEPs（目前）只能用于订阅在给定JVM中发布的事件。Axon Server（还）没有一种机制将事件从一个JVM桥接到另一个JVM以允许分布式订阅事件处理。然而，我（作为AxonIQ的一部分）相对肯定，我们将在未来关注这一点。如果这样一个特性对你的项目的成功结束很重要，我建议直接联系AxonIQ。