问Axon -查询时进行投影的最简单方法

EN

对此，简单的回答是，没有简单/快速的方法可以做到这一点。

但是，它当然可以实现一个“按请求时重播给定事件”的设置。

我建议你做的事情有几个步骤：

1. 创建要返回的查询模型，它可以处理事件(在模型上使用@EventHandler注释的方法)
2. 创建一个组件，它可以处理第一步中返回查询模型的查询(为此使用@QueryHandler注释的方法)。
3. 查询处理组件应该能够从EventStore中检索事件流。如果这是基于aggregateIdentifier的，请使用EventStore#readEvents(String)方法。如果需要整个事件流，则需要使用StreamableMessageSource#openStream(TrackingToken)方法(注意：EventStore接口实现StreamableMessageSource)
4. 在查询处理时，创建一个AnnotationEventHandlerAdapter，给它一个新的查询模型实例
5. 对于在第3点中创建的事件流中的每个事件，调用AnnotationEventHandlerAdapter#handle(EventMessage)方法。此方法将调用查询模型对象上的@EventHandler注释方法
6. 如果流被耗尽，则确保查询模型处理了所有必要的事件。因此，您现在可以返回查询模型

所以，再一次，我不认为这是过于琐碎，容易或快速设置。此外，步骤3中有相当多的警告。根据聚合标识符检索给定聚合的流非常快速/简洁，因为聚合一般不会有很多事件。

但是，基于TrackingToken检索事件流(如果您的查询模型跨越几个集合，则需要这样做)，可以确保您在整个事件存储中动态地实例化您的模型。当然，您可以在处理TrackingToken时微调事件流返回事件的时间点，但是更改非常高--您将是不完整的，并且相对较慢。

但是，您表示希望检索给定聚合标识符的事件。因此，我认为在您的场景中，这应该是一个可行的解决方案。

希望这能有所帮助！