Spring Data的Domain Event的用法详解

 更新时间:2018年02月27日 16:40:28   作者:汪云飞记录本  
这篇文章主要介绍了Spring Data的Domain Event的用法详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

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注解方法发布事件

如:

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

@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

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

您可能感兴趣的文章:

相关文章

  • IDEA使用SequenceDiagram插件绘制时序图的方法

    IDEA使用SequenceDiagram插件绘制时序图的方法

    这篇文章主要介绍了IDEA使用SequenceDiagram插件绘制时序图的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • Java正则环视和反向引用功能与用法详解

    Java正则环视和反向引用功能与用法详解

    这篇文章主要介绍了Java正则环视和反向引用功能与用法,结合实例形式较为详细的分析了java正则环视与反向引用的相关概念与使用方法,需要的朋友可以参考下
    2018-01-01
  • 详解用Spring Boot零配置快速创建web项目

    详解用Spring Boot零配置快速创建web项目

    本篇文章主要介绍了详解用Spring Boot零配置快速创建web项目,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
    2017-03-03
  • Java元注解Retention代码示例介绍

    Java元注解Retention代码示例介绍

    注解@Retention可以用来修饰注解,是注解的注解,称为元注解。Retention注解有一个属性value,是RetentionPolicy类型的,Enum RetentionPolicy是一个枚举类型,这个枚举决定了Retention注解应该如何去保持,也可理解为Rentention 搭配 RententionPolicy使用
    2022-08-08
  • Spring中的@ComponentScan注解详解

    Spring中的@ComponentScan注解详解

    这篇文章主要介绍了Spring中的@ComponentScan注解详解,ComponentScan做的事情就是告诉Spring从哪里找到bean,由你来定义哪些包需要被扫描,一旦你指定了,Spring将会在被指定的包及其下级包中寻找bean,需要的朋友可以参考下
    2024-01-01
  • 详解spring封装hbase的代码实现

    详解spring封装hbase的代码实现

    本篇文章主要介绍了详解spring封装hbase的代码实现,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • Java在指定路径上创建文件提示不存在解决方法

    Java在指定路径上创建文件提示不存在解决方法

    在本篇文章里小编给大家整理的是一篇关于Java在指定路径上创建文件提示不存在解决方法,有需要的朋友们可以参考下。
    2020-02-02
  • mybatis-plus使用问题小结

    mybatis-plus使用问题小结

    这篇文章主要介绍了mybatis-plus使用问题汇总,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-03-03
  • Spring中@Autowire注入的深入讲解

    Spring中@Autowire注入的深入讲解

    这篇文章主要给大家介绍了关于Spring中@Autowire注入的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • 利用java反射机制实现自动调用类的简单方法

    利用java反射机制实现自动调用类的简单方法

    下面小编就为大家带来一篇利用java反射机制实现自动调用类的简单方法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-08-08

最新评论