Spring Data的Domain Event的用法详解

Spring Data的Domain Event的用法详解

1.DDD与Spring Data

DDD: domain-driven design(领域驱动设计)是复杂需求下软件开发的实现方式。有时间我将专门来讲解一下DDD。

Spring Data在很多地方都是按照DDD原则进行的设计(如Repository), 这里Spring Data主要是实现了DDD的aggregate和domain event:

aggregate:一系列可以看成单一单元的领域对象的组合。如订单(order)和购物清单(line-items)都是单独的对象，但是将他们当成一个独立的单元(aggregate)。每个aggregate都有一个aggregate root,任何和外部交互应该只能通过aggregate root,这样aggregate root就可以确保aggregate的完整性。一个aggregate内部具有事务(数据一致性)边界。

domain event: aggregate之间为了保证数据的一致性，使用事件驱动架构(Event-Driven Architecture)来实现数据的最终一致性(Eventual consistency)。而这些事件是通过aggregate root发布的domain events。

下面我们演示一个当Person这个aggregate root 保存成功后，通过Person的gender属性对统计实体GenderStat更新男女性别的统计数量。

2.演示

2.1 Person Aggregate Root

Person作为Aggregate Root具备发布domain event的能力，在Spring Data 下可以有两种实现方式:

– 继承AbstractAggregateRoot，并使用其registerEvent()方法注册发布事件

– 使用@DomainEvents注解方法发布事件

如：

@Entity

@Data

@AllArgsConstructor

@NoArgsConstructor

@ToString(exclude = "domainEvents")

public class Person {

@Id

@GeneratedValue

private Long id;

private String name;

http:// private Integer gender;//1:male;2:female

@DomainEvents

Collection

List

events.add(new PersonSavedEvent(this.id,this.gender));

returnhttp:// events;

}

@AfterDomainEventPublication

void callbackMethod() {

//

}

}

或

@Entity

@Data

@AllArgsConstructor

@NoArgsConstructor

@ToString(exclude = "domainEvents")

public class Person extends AbstractAggregateRoot{

@Id

@GeneratedValue

private Long id;

private String name;

private Integer gender;//1:male;2:female

public Person afterPersonSavedCompleted(){

registerEvent(new PersonSavedEvent(this.id,this.gender));

return this;

}

}

2.2 监听事件处理

@Component

public class GenderStatPrVKyZcWgRpMocessor {

@Autowired

GenderRepository genderRepository;

@Async

@TransactionalEventListener

public void handleAfterPersonSavedComplete(PersonSavedEvent event){

GenderStat genderStat = genderRepository.findOne(1l);

if(event.getGender()==1){

genderStat.setMaleCount(genderStat.getMaleCount()+1);

}else {

genderStat.setFemaleCount(genderStat.getFemaleCount()+1);

}

genderRepository.save(genderStat);

}

}

3 源码地址：https://github.com/wiselyman/spring-data-domain-event

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。