美文网首页程序员
AxonFramework聚合事件溯源

AxonFramework聚合事件溯源

作者: 勇赴 | 来源:发表于2017-06-08 06:16 被阅读261次

除了存储一个聚合的当前状态,还可以根据过去发布的事件恢复一个聚合的状态。为此,所有状态的更改必须由一个事件来表示。

主要部分,事件溯源聚合类似于“有规律”聚合:他们必须声明一个标识符并可以使用apply函数发布事件。然而,事件溯源聚合中状态的变化(也就字段的任何变化)必须在@EventSourcingHandler注解的方法中被排他地执行。这包括设置聚合标识符。

注意,聚合标识必须被设置在聚合发布的第一个事件的@EventSourcingHandler上,这通常是创建事件。

事件溯源聚合的聚合根还必须包含一个无参的构造函数,Axon Framework使用这个构造函数创建一个空的聚合实例,在使用过去的事件之前初始化它。没有提供这种构造函数加载聚合时将导致异常。

public class MyAggregateRoot {
    @AggregateIdentifier
    private String aggregateIdentifier;
    // fields containing state...
    @CommandHandler
    public MyAggregateRoot(CreateMyAggregate cmd) {
        apply(new MyAggregateCreatedEvent(cmd.getId()));
    }
    // constructor needed for reconstruction
    protected MyAggregateRoot() {
    }
    @EventSourcingHandler
    private void handleMyAggregateCreatedEvent(MyAggregateCreatedEvent event) {
        // make sure identifier is always initialized properly
        this.aggregateIdentifier = event.getMyAggregateIdentifier();
        // ... update state
    }
}

带@EventSourcingHandler注解的方法使用特定的规则来解析。这些规则对于带@EventHandler注解的方法也同样适合,并在Defining Event Handlers这一章节中彻底解释。

注意
事件处理器(Event handler)的方法可以是私有的,只要JVM的安全设置允许Axon Framework改变方法的可访问性。这使你能够清楚地分离聚合的公共API,该方法从处理事件的内部逻辑中公开生成事件的方法。大多数的IDE有一个选项来忽略“未使用的私有方法”的警告为特定注解的方法。或者,你可以添加一个@SuppressWarnings(UnusedDeclaration)注解到方法,以确保你不意外地删除事件处理器方法。

有时候,特别是当聚合结构的增长远远超过两个实体时,对同一聚合的其他实体中事件发布的影响更明显。然而,由于重构聚合状态时事件处理器方法也会被调用,所以必须采取特殊的预防措施。

在事件溯源处理器方法内可以apply()新事件。这使得实体B可以apply一个事件来响应实体A做的一些事情成为可能。Axond重演历史事件时将忽略apply()调用。注意,在这种情况下,内部apply()调用事件只发布给实体,在所有实体收到第一个事件后。如果有更多的事件需要公布,在apply一个内部事件后的实体状态的基础上,可以用apply(...).andThenApply(...)

你还可以使用静态AggregateLifecycle.isLive()方法来检查聚合是否“存活”。基本上,一个聚合如果已经完成重演历史事件会被认为是存活的。当重演这些事件时,isLive()将返回false。在处理新生成的事件时,使用islive()方法是唯一可以执行的活动。

复杂的聚合结构

复杂的业务逻辑通常需要多个带聚合根的聚合来提供支持。在这种情况下,重要的是把复杂性分布在聚合内的多个实体中。当使用事件溯源时,不仅聚合根需要使用事件来触发状态转换,而且聚合内的实体也如此。

注意一个常见的误解,聚合的实体不应该包含任何属性访问方法来暴露状态。这并非如此。事实上,在同一聚合内的实体向其他的实体暴露状态,可能会使一个聚合受益很多。然而,建议不要向外部暴露聚合的状态。

Axon在复杂的聚合结构中提供了对事件溯源的支持。实体,就像聚合根,简单的对象。子实体的字段声明必须使用@AggregateMember来注解。这个注释告诉Axon被注解的字段,包含一个应该对命令和事件处理程序进行检查的类。

当一个实体(包括聚合根)应用一个事件时,它首先是由聚合根处理,然后向下通过所有带@AggregateMember注解的字段到其子实体。

可能包含子实体的字段必须用@AggregateMember注解,此注释可用于多种字段类型:

  • 字段直接引用的实体类型;
  • 内部包含一个迭代器字段(包括所有集合,例如,列表,等等);
  • 内部包含java.util.Map字段的值。

相关文章

  • AxonFramework聚合事件溯源

    除了存储一个聚合的当前状态,还可以根据过去发布的事件恢复一个聚合的状态。为此,所有状态的更改必须由一个事件来表示。...

  • AxonFramework,EventStore实现

    事件溯源存储库需要一个事件存储(event store)从聚合中存储和加载事件。事件存储提供了一个事件总线的功能,...

  • AxonFramework,分发事件

    在某些情况下,有必要发布事件到外部系统,比如消息broker。 Spring AMQP Axon提供了开箱即用的支...

  • AxonFramework事件处理

    saga中的事件处理非常接近一个普通的事件监听器。上述的对于方法和参数解析的规则在这里是有效的。不过,有一个主要区...

  • DDD之聚合与事件溯源[A +ES]

    在开发微服务的过程中,分布式数据管理是必须解决的问题。不同服务数据库选择的多样性,事务问题及跨服务的数据查询都是我...

  • 微服务架构设计模式(六)事件溯源

    事件溯源-以事件为中心的编写业务逻辑和持久化领域对象方法 1、事件溯源 事件溯源是一种事件为中心的技术,用于实现业...

  • AxonFramework在聚合中处理命令

    建议在包含处理状态命令的聚合中直接定义命令处理器,因为命令处理器有可能需要该集合的状态来执行其任务。 要在一个聚合...

  • 多研究些架构,少谈些框架(2):微服务和充血模型

    上篇我们聊了微服务的DDD之间的关系,很多人还是觉得很虚幻,DDD那么复杂的理论,聚合根、值对象、事件溯源,到底我...

  • AxonFramework消息、命令和事件

    消息传送的概念消息是Axon的核心概念之一。组件之间的所有通信都使用消息对象完成。这为这些组件提供了位置透明性,在...

  • AxonFramework,事件发布和处理

    由应用程序生成的事件需要被分发到更新查询数据库的组件,搜索引擎或其他需要它们的资源:事件处理程序(Event Ha...

网友评论

    本文标题:AxonFramework聚合事件溯源

    本文链接:https://www.haomeiwen.com/subject/bymafxtx.html