如何使用事件源（axon框架）在一个saga中处理从REST-API传递的多个实体？

Question

因此，目前我正在用axon框架实现一个saga，使用事件源和CQRS。

情况如下：

我有3个微服务，m1、m2和m3

用户在GUI中输入由m1、m2、m3分别处理和保存的3个实体e1、e2、e3的数据，因此M1->e1、M2->e2、M3->e3

现在来看看这个传奇的必要性：

e1没有e2就不能存在，e2没有E3就不能存在。

因此，所有3个实体必须由它们各自的服务成功创建，如果其中一个失败，则saga需要执行补偿事务以确保一致性。首先，m1创建e1，发出一个e1CreatedEvent，一个orchestrator发送一个createE2Command作为对此的反应，等等。

现在我的问题是：

如何获取/存储用户输入的信息？在单个RequestBody中？那我该怎么处理这些数据呢？因为它需要以某种方式缓存，以便与命令一起发送。

@Saga
public class ManagementSaga{

@Autowired
private transient CommandGateway commandGateway

@StartSaga
@SagaEventhandler
public void handle (e1CreatedEvent e1CreatedEvent){


  commandGateway.send (new CreateE2Command (e1CreatedEvent.Id, **HERE NEEDS TO BE THE INFO THAT THE USER CREATED PREVIOUSLY**)}}

我是否只创建一个对象来保存这三个实体的信息？感觉真的不对。

现在我明白了，也许选择这样的领域模型真的很糟糕，如果可能的话，应该避免它，但这是为了谨慎：-）

Answer 1

在这种情况下，我的第一反应是完全质疑设计。似乎（微）服务是围绕实体设计的。这种类型的设计在某些情况下可能有效，但在其他情况下将不可避免地导致分布式整体。你面临的挑战暗示着后者。

从API的角度来看，交互和系统的设计方式似乎也不匹配。虽然每个定义不是错误的，但这也可能表明API不正确（没有正确反映系统的行为），或者行为模型不正确。

无论如何，要给出一个比“视情况而定”更有用的答案，您可以在多个命令甚至查询中获得单个交互结果。它不需要在所有情况下都有一个传奇。