詳解基于Spring Data的領域事件發(fā)布

更新時間：2020年04月02日 09:22:04 作者：barry的異想世界

這篇文章主要介紹了詳解基于Spring Data的領域事件發(fā)布，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

領域事件發(fā)布是一個領域對象為了讓其它對象知道自己已經(jīng)處理完成某個操作時發(fā)出的一個通知，事件發(fā)布力求從代碼層面讓自身對象與外部對象解耦，并減少技術代碼入侵。

一、手動發(fā)布事件

// 實體定義
@Entity
public class Department implements Serializable {
  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Integer departmentId;

  @Enumerated(EnumType.STRING)
  private State state;
}

// 事件定義
public class DepartmentEvent {
  private Department department;
  private State state;
  public DepartmentEvent(Department department) {
    this.department = department;
    state = department.getState();
  }
}

// 領域服務
@Service
public class ApplicationService {

  @Autowired
  private ApplicationEventPublisher applicationEventPublisher;

  @Autowired
  private DepartmentRepository departmentRepository;

  @Transactional(rollbackFor = Exception.class)
  public void departmentAdd(Department department) {
    departmentRepository.save(department);
    // 事件發(fā)布
    applicationEventPublisher.publishEvent(new DepartmentEvent(department));
  }
}

使用applicationEventPublisher.publishEvent在領域服務處理完成后發(fā)布領域事件，此方法需要在業(yè)務代碼中顯式發(fā)布事件，并在領域服務里引入ApplicationEventPublisher類，但對領域服務本身有一定的入侵性，但靈活性較高。

二、自動發(fā)布事件

// 實體定義
@Entity
public class SaleOrder implements Serializable {

  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Integer orderId;
  
  @Enumerated(EnumType.STRING)
  private State state;

  // 返回類型定義
  @DomainEvents
  public List<Object> domainEvents(){
    return Stream.of(new SaleOrderEvent(this)).collect(Collectors.toList());
  }

  // 事件發(fā)布后callback
  @AfterDomainEventPublication
  void callback() {
    System.err.println("ok");
  }
}

// 事件定義
public class SaleOrderEvent {
  private SaleOrder saleOrder;
  private State state;
  public SaleOrderEvent(SaleOrder saleOrder) {
    this.saleOrder = saleOrder;
    state = saleOrder.getState();
  }
}

// 領域服務
@Service
public class ApplicationService {
  @Autowired
  private OrderRepository orderRepository;
  
  @Transactional(rollbackFor = Exception.class)
  public void saleOrderAdd(SaleOrder saleOrder) {
    orderRepository.save(saleOrder);
  }
}

使用@DomainEvents定義事件返回的類型，必須是一個集合，使用@AfterDomainEventPublication定義事件發(fā)布后的回調。

此方法實事件類型定義在實體中，與領域服務完全解耦，沒有入侵。系統(tǒng)會在orderRepository.save(saleOrder)后自動調用事件發(fā)布，另delete方法不會調用事件發(fā)布。

三、事件監(jiān)聽

@Component
public class ApplicationEventProcessor {

  @EventListener(condition = "#departmentEvent.getState().toString() == 'SUCCEED'")
  public void departmentCreated(DepartmentEvent departmentEvent) {
    System.err.println("dept-event1:" + departmentEvent);
  }

  @Async
  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, condition = "#saleOrderEvent.getState().toString() == 'SUCCEED'")
  public void saleOrderCreated(SaleOrderEvent saleOrderEvent) {
    System.err.println("sale-event succeed1:" + saleOrderEvent);
  }

  @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT, condition = "#saleOrderEvent.getState().toString() == 'SUCCEED'")
  public void saleOrderCreatedBefore(SaleOrderEvent saleOrderEvent) {
    System.err.println("sale-event succeed2:" + saleOrderEvent);
  }

  @Async
  @TransactionalEventListener(phase = TransactionPhase.AFTER_ROLLBACK)
  public void saleOrderCreatedFailed(SaleOrderEvent saleOrderEvent) {
    System.out.println("sale-event failed:" + saleOrderEvent);
  }
}

1. 使用@EventListener監(jiān)聽事件

@EventListener沒有事務支持，只要事件發(fā)出就可監(jiān)控到

@Transactional(rollbackFor = Exception.class)
public void departmentAdd(Department department) {
  departmentRepository.save(department);
  applicationEventPublisher.publishEvent(new DepartmentEvent(department));
  throw new RuntimeException("failed");
}

上述情況會造成事務失敗回滾，但事件監(jiān)控端已經(jīng)執(zhí)行，可能導致數(shù)據(jù)不一致的情況發(fā)生

2. 使用@TransactionalEventListener監(jiān)聽事件

TransactionPhase.BEFORE_COMMIT 事務提交前
TransactionPhase.AFTER_COMMIT 事務提交后
TransactionPhase.AFTER_ROLLBACK 事務回滾后
TransactionPhase.AFTER_COMPLETION 事務完成后

使用TransactionPhase.AFTER_COMMIT可在事務完成后，再執(zhí)行事件監(jiān)聽方法，從而保證數(shù)據(jù)的一致性

3. TransactionPhase.AFTER_ROLLBACK回滾事務問題

@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_ROLLBACK, condition = "#departmentEvent.getState().toString() == 'SUCCEED'")
public void departmentCreatedFailed(DepartmentEvent departmentEvent) {
  System.err.println("dept-event3:" + departmentEvent);
}

由于@DomainEvents作用在實體上的，只有剛orderRepository.save(saleOrder)執(zhí)行成功后才會發(fā)送事件，故AFTER_ROLLBACK方法只會在同一事務中其它語句執(zhí)行失敗或顯式rollback時才會執(zhí)行，如果save方法執(zhí)行失敗，將不會監(jiān)聽到回滾事件。

4. @Async異步事件監(jiān)聽