Axon

Question

当我想通过 queryUpdateEmitter 但在不同的模块（微服务）中发出查询更新时，我很烦恼。我有基于微服务构建的应用程序，并且都连接到同一个 Axon 服务器。第一个服务创建 subscriptionQuery，并发送一些命令。一段时间后（通过一些命令和事件）第二个服务处理一些事件，并为第一个订阅的查询发出更新。不幸的是，这个发射似乎没有到达订阅者。查询完全相同并且位于相同的包中。

    @GetMapping("/refresh")
    public Mono<MovieDTO> refreshMovies() {
        commandGateway.send(
                new CreateRefreshMoviesCommand(UUID.randomUUID().toString()));

        SubscriptionQueryResult<MovieDTO, MovieDTO> refreshedMoviesSubscription =
                queryGateway.subscriptionQuery(
                        new GetRefreshedMoviesQuery(),
                        ResponseTypes.instanceOf(MovieDTO.class),
                        ResponseTypes.instanceOf(MovieDTO.class)
                );

        return refreshedMoviesSubscription.updates().next();
    }

发射器：

    @EventHandler
    public void handle(DataRefreshedEvent event) {
        log.info("[event-handler] Handling {}, movieId={}",
                event.getClass().getSimpleName(),
                event.getMovieId());
                queryUpdateEmitter.emit(GetRefreshedMoviesQuery.class, query -> true,
                        Arrays.asList(
                                MovieDTO.builder().aggregateId("as").build(),
                                MovieDTO.builder().aggregateId("be").build()));
    }

最新版本的Axon也有这种情况？类似的配置，但在一项服务中按预期工作。

@编辑我找到了解决这种情况的方法：

第二个服务不是通过 queryUpdateEmitter 发出查询，而是发布带有电影列表的事件
第一个服务处理这个事件，然后通过 queryUpdateEmitter 发出更新

但我仍然想知道是否有一种方法可以仅使用查询来执行此操作，因为这对我来说似乎很自然（commandGateways/eventGateways 按预期工作，queryUpdateEmitter 是个例外）。

Answer 1

这遵循 QueryUpdateEmitter 的实施（与使用 Axon 服务器 yes/no 无关）。

QueryUpdateEmitter 存储一组更新处理程序，引用已发出的订阅查询。但是，它仅维护由给定 JVM 处理的已发布订阅查询（因为 QueryUpdateEmitter 实现未分发）。

它的目的是在组件（通常是查询模型“投影仪”）中配对，该组件回答关于给定模型的查询，更新模型并且发出这些更新。

因此，将 QueryUpdateEmitter 操作放在处理查询的不同（微）服务中是行不通的。

Axon - 无法在不同的微服务中发出查询更新

Axon - Cannot emit query update in different microservice

spring-boot

microservices

cqrs