Core Domain Events (CDEs) 为 Spring Data 提供了一种统一的机制,用于在域模型中的聚合之间发布和订阅事件。通过使用 CDEs,可以在松散耦合的方式下构建复杂的域模型,同时保持数据一致性和处理事件的能力。CDEs 支持分布式事件处理,并提供了一个通用框架来处理领域模型中的事件。
Publishing Events from Aggregate Roots
由存储库管理的实体是聚合根。在领域驱动设计应用程序中,这些聚合根通常发布领域事件。Spring 数据提供了一个名为 @DomainEvents
的注释,你可以将它用于你的聚合根的方法,使发布尽可能容易,如下例所示:
Exposing domain events from an aggregate root
class AnAggregateRoot {
@DomainEvents 1
Collection<Object> domainEvents() {
// … return events you want to get published here
}
@AfterDomainEventPublication 2
void callbackMethod() {
// … potentially clean up domain events list
}
}
1 | 使用 @DomainEvents 的方法可以返回单个事件实例或事件集合。它不能采用任何参数。 |
2 | 在发布完所有事件后,我们有一个使用 @AfterDomainEventPublication 注释的方法。你可以使用它(以及其他用法)来尽可能清除待发布的事件列表。 |
只要调用以下 Spring 数据存储库方法之一,就会调用这些方法:
-
save(…)
,saveAll(…)
-
delete(…)
,deleteAll(…)
,deleteAllInBatch(…)
,deleteInBatch(…)
请注意,这些方法将聚合根实例作为参数。这就是为什么 deleteById(…)
明显缺失的原因,因为实现可能会选择发出一个查询来删除该实例,因此我们永远无法首先访问聚合实例。