【问题标题】:Change a node's Instance Name when connecting to Axon Server连接到 Axon 服务器时更改节点的实例名称
【发布时间】:2019-02-08 07:29:56
【问题描述】:

我目前正在为 Spring Boot / Axon 应用程序进行集成测试。

在其中一个测试中,它(一个节点)通过 SpringApplicationBuilder(在不同的配置文件下)创建另一个节点,连接到与其创建者相同的 Axon Server 实例。

我遇到的问题是事件处理开始表现得很奇怪,我相信原始应用程序上带有第二个创建节点的任何“通用”事件处理程序都会被忽略/丢失。 当实例在测试环境之外启动时,一切似乎都正常。

我的想法是,在测试中,两个节点最终在 Axon Server 上共享一个实例名称(因为它们共享一个 processId 和主机名),这与处理程序注册/跟踪混淆。这有意义吗?

有没有办法可以手动为连接到 Axon 服务器的节点设置此值,以便在测试期间不会发生这种情况?

【问题讨论】:

    标签: java spring-boot kotlin axon


    【解决方案1】:

    我不确定哪些组件由外部测试应用程序启动,哪些由内部测试应用程序启动。请注意,这里有多个方面可能会妨碍您。

    1. AxonServer 可能会感到困惑,并认为这两个组件实际上是相同的。实际上,两者的主机名和 processId 将是相同的,这导致 AxonServer 认为它只是在处理来自同一应用程序的多个连接。为了避免这种情况,您可以使用axon.axonserver.clientId 属性定义不同的clientId。只需将其设置为随机值,就可以解决这部分问题。

    2. 另一个问题是您的组件可能具有同名的跟踪处理器。在这种情况下,AxonServer 会将处理器的两个实例视为同一处理器的多个实例,并平衡两者之间的负载(如果存在足够的段)。如果您只有一个处理段可用,则只有一个处理程序处于活动状态。其他组件不会收到任何事件。

      为避免这种情况,请在您的测试用例中为您的处理器名称添加一些独特的前缀。您可以使用EventProcessingConfigurerassignProcessingGroup(Function<String, String> assignmentRule) 方法更改将组分配给处理器的规则。默认情况下,处理器的名称与组的名称相同。在您的情况下,您可以(根据您设置的测试配置文件)在处理器名称中添加一个唯一的测试相关前缀。这将“欺骗”Axon 使其相信它们是不同的处理器,并且需要同时运行。

    我建议先尝试选项 1。如果这还不足以进行测试,您也可以尝试第二个。

    【讨论】:

    • 谢谢,您的第一个建议奏效了。我不知道第二个目前是否存在问题,但如果是,我会更新。
    猜你喜欢
    • 2020-07-08
    • 1970-01-01
    • 2019-12-12
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2013-07-24
    相关资源
    最近更新 更多