详解基于详解基于Spring Data的领域事件发布的领域事件发布
主要介绍了详解基于Spring Data的领域事件发布，文中通过示例代码介绍的非常详细，对大家的学习或者工作
具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
领域事件发布是一个领域对象为了让其它对象知道自己已经处理完成某个操作时发出的一个通知，事件发布力求从代码层面让
自身对象与外部对象解耦，并减少技术代码入侵。
一、一、 手动发布事件手动发布事件
// 实体定义
@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);
// 事件发布
applicationEventPublisher.publishEvent(new DepartmentEvent(department));
}
}
使用applicationEventPublisher.publishEvent在领域服务处理完成后发布领域事件，此方法需要在业务代码中显式发布事件，并在领
域服务里引入ApplicationEventPublisher类，但对领域服务本身有一定的入侵性，但灵活性较高。
二、二、 自动发布事件自动发布事件
// 实体定义
@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());
}
// 事件发布后callback
@AfterDomainEventPublication
void callback() {
System.err.println("ok");
}
}
资源评论
