Spring Data的Domain Event的用法详解

2025-05-29 0 88

1.DDD与Spring Data

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

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

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

  1. – 继承AbstractAggregateRoot,并使用其registerEvent()方法注册发布事件
  2. – 使用@DomainEvents注解方法发布事件

如:

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24
@Entity

@Data

@AllArgsConstructor

@NoArgsConstructor

@ToString(exclude = "domainEvents")

public class Person {

@Id

@GeneratedValue

private Long id;

private String name;

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

@DomainEvents

Collection<Object> domainEvents() {

List<Object> events= new ArrayList<Object>();

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

return events;

}

@AfterDomainEventPublication

void callbackMethod() {

//

}

}

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17
@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 监听事件处理

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18
@Component

public class GenderStatProcessor {

@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/springdata-domain-event

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持快网idc。

原文链接:http://www.wisely.top/2017/06/20/spring-data-domain-event-usage/

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 Spring Data的Domain Event的用法详解 https://www.kuaiidc.com/112421.html

相关文章

发表评论
暂无评论