Spring Data的Domain Event的用法詳解

更新時間：2018年02月27日 16:40:28 作者：汪云飛記錄本

這篇文章主要介紹了Spring Data的Domain Event的用法詳解，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

1.DDD與Spring Data

DDD: domain-driven design(領(lǐng)域驅(qū)動設(shè)計)是復(fù)雜需求下軟件開發(fā)的實(shí)現(xiàn)方式。有時間我將專門來講解一下DDD。

Spring Data在很多地方都是按照DDD原則進(jìn)行的設(shè)計(如Repository), 這里Spring Data主要是實(shí)現(xiàn)了DDD的aggregate和domain event:

aggregate:一系列可以看成單一單元的領(lǐng)域?qū)ο蟮慕M合。如訂單(order)和購物清單(line-items)都是單獨(dú)的對象，但是將他們當(dāng)成一個獨(dú)立的單元(aggregate)。每個aggregate都有一個aggregate root,任何和外部交互應(yīng)該只能通過aggregate root,這樣aggregate root就可以確保aggregate的完整性。一個aggregate內(nèi)部具有事務(wù)(數(shù)據(jù)一致性)邊界。
domain event: aggregate之間為了保證數(shù)據(jù)的一致性，使用事件驅(qū)動架構(gòu)(Event-Driven Architecture)來實(shí)現(xiàn)數(shù)據(jù)的最終一致性(Eventual consistency)。而這些事件是通過aggregate root發(fā)布的domain events。

下面我們演示一個當(dāng)Person這個aggregate root 保存成功后，通過Person的gender屬性對統(tǒng)計實(shí)體GenderStat更新男女性別的統(tǒng)計數(shù)量。

2.演示

2.1 Person Aggregate Root

Person作為Aggregate Root具備發(fā)布domain event的能力，在Spring Data 下可以有兩種實(shí)現(xiàn)方式:

– 繼承AbstractAggregateRoot，并使用其registerEvent()方法注冊發(fā)布事件
– 使用@DomainEvents注解方法發(fā)布事件

如：

@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() {
  //
 }
}

或

@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 監(jiān)聽事件處理

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

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: