java - 连接到 Axon 服务器时更改节点的实例名称

标签 java spring-boot kotlin axon

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

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

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

我的想法是,在测试中,两个节点最终在 Axon 服务器上共享实例名称(因为它们共享 processId 和主机名),这会扰乱处理程序注册/跟踪。这有道理吗?

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

最佳答案

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

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

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

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

我建议首先尝试选项 1。如果这不足以满足测试要求,您也可以尝试第二个。

关于java - 连接到 Axon 服务器时更改节点的实例名称,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54587790/

相关文章:

android - 如何正确使用 registerForActivityResult?获取 "LifecycleOwners must call register before they are STARTED"

java - 如何将数字拆分为数字字符串?

java - Spring Boot 如何识别子类方法上的 @Scheduled?

Android:使用定时器通过 Kotlin 动态更新 View

java - 处理 Spring Boot 资源服务器中的安全异常

java - spring boot如何使项目在eclipse中的服务器上运行

java - 如何将 Paging 3 从 Kotlin Flow 移植到 Java? - 找不到 PagingDataFlow.create 函数

java - 为什么我无法将这个带有 @Service 注解的 bean 注入(inject)到 spring-security.xml 配置文件中声明的 bean 中?

java - Geotools:将不同样式的点添加到同一 map 图层

java - Java 中的 ROT-N(或 ROT-X)函数