轴突骨架同步反应

Question

提前致谢

Answer 1

我想您问的是，是否有一种方法可以在单个事务中处理命令和事件？

如果使用在同一JVM中运行的订阅事件处理器，则会同步处理事件，并在事件处理程序中出现异常时回滚整个事务。这里的情况不是这样，因为您有松散耦合的单独服务，这很好。

使用命令处理程序的聚合的最佳实践是拥有所有可用的信息来决定是否可以成功地处理命令，当应用事件时，这是一个已经发生的信号，并且必须通知其他服务（在本例中是查询端）。查询模块否决这一点（“你说它发生了，我说它没有”）不是一个好的做法。如果查询端出现错误，则修复该错误，并重播事件。

 @Autowired
 private EventBus eventBus;

 (...)

 CatastrophicFailureEvent failureEvent = new CatastrophicFailureEvent("OH NO!");
 eventBus.publish(GenericEventMessage.asEventMessage(failureEvent));