命令和查询端之间的axon事务管理器

Question

我有一个使用axon 4.4.2的spring boot maven多模块项目，项目的层次结构如下：

application
--core
--command-side
----command-side-axon
----command-side-rest
--query--side
----query-side-persistence
----query-side-rest

我有一个创建新目录的例子，如下所示，当我从命令端REST发送请求时，它总是返回一个id作为响应，即使查询端持久性崩溃，并且数据没有保存在数据库中。在这种情况下，我如何处理事务？我希望当查询端持久性崩溃时，事件不会保存在事件库中，并引发异常。

@PostMapping
public String save(@RequestBody Catalog catalog) {
    return (String) commandGateway.sendAndWait(new CreateCatalogCommand(catalog));
}

@CommandHandler
public void handle(CreateCatalogCommand cmd) {
    apply(new CatalogCreatedEvent(cmd.externalId, cmd.name));
}

@EventSourcingHandler
@Order(1)
public void on(CatalogCreatedEvent evt) {
    this.externalId = evt.externalId;
}

@EventHandler
@Transactional(propagation = Propagation.REQUIRED)
@Order(2)
public void on(CatalogCreatedEvent event) {}

Answer 1

关于你的主要问题，我想我可以给你一些关于这件事的信息：

我希望当查询端持久性崩溃时，事件不会保存在事件库中，并引发异常。

嗯，这基本上意味着你根本不想使用CQRS。CQRS所代表的是命令模型（例如，处理命令并发布事件的聚合）和查询模型（例如，处理更新模型的事件的类）的分离。

希望这能对情况有所了解，艾曼！