多节点环境下Axon订阅查询未触发更新问题咨询

这个情况是Axon的设计预期行为，并非配置错误，下面给你拆解原因和几种符合Axon风格的解决思路：

为什么会出现这个问题？ #

你的Tracking事件处理器只有1个segment，Axon的规则是每个segment只会被一个节点的事件处理器实例激活处理。所以触发更新的事件只在节点B被处理，对应的投影更新也只在节点B生成。而Axon的查询订阅（比如SubscriptionQuery）默认是监听本地事件处理器处理事件后产生的更新，节点A没有处理这个事件，自然收不到更新通知。

符合Axon风格的解决方案 #

1. 开启查询更新分发（Query Update Distribution） #

这是最直接的解决方案，Axon提供了内置的分布式查询更新推送能力，能把任意节点上事件处理器生成的查询更新，推送到所有订阅该查询的节点。

• 如果用Spring Boot，只需要在配置文件里开启：

  axon.query.update.distribution.enabled=true
  

  或者yaml格式：

  axon:
    query:
      update:
        distribution:
          enabled: true
  

• 原理是Axon会借助你配置的消息中间件（比如RabbitMQ、Kafka）来跨节点分发更新通知，不管订阅节点在哪，都能实时收到事件处理后的投影更新。

2. 调整事件处理器的Segment数量（业务允许时） #

如果你的投影业务逻辑不需要严格的事件顺序，可以把Tracking事件处理器的segment数量设置为大于1，这样多个节点可以同时处理不同的segment，事件可能会在节点A或B被处理，对应的更新也会在本地生成并推送给本地的订阅者。

• Java配置示例：

  @Bean
  public EventProcessingConfigurer eventProcessingConfigurer() {
      return configurer -> configurer
          .registerTrackingEventProcessor("your-processor-bean-name",
              config -> TrackingEventProcessorConfiguration.forParallelProcessing(2));
  }
  

• 注意：如果你的事件有强顺序依赖（比如同一个聚合的事件必须按顺序处理），这种方法可能不适用，因为segment会拆分事件流，可能导致顺序错乱。

3. 利用Axon Server的集群协调能力 #

如果你们已经在使用Axon Server，它本身就内置了分布式事件处理和查询更新分发的能力。Axon Server会自动协调事件处理器的segment分配，并且负责把查询更新跨节点推送给所有订阅者，不需要额外配置太多内容就能解决这个问题。

对比当前的轮询方式 #

你现在用的轮询数据源/投影的方式虽然简单，但存在效率低、延迟高的问题。上面的方案都是基于事件驱动的，更贴合Axon的CQRS/Event Sourcing设计理念，能实现实时的更新推送，避免不必要的资源消耗。

内容的提问来源于stack exchange，提问作者Jan