- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我在聚合中使用注释@AggregateVersion
来处理乐观并发。为了接收请求中的此版本,发出请求的任何人都需要首先从我的 View 投影中获取当前版本。是否有一些标准方法来投影此版本字段(因为我猜这不应该包含在事件 DTO 中)?
到目前为止,我唯一能想到的就是计算投影中的投影事件,并在每次投影其中一个事件时增加版本+1。
最佳答案
Jasper 的 MetaData
建议可以帮助您实现这一点,但是这个问题有一个更简单的解决方案。
Axon 使用 ParameterResolvers
的概念(遗憾的是只描述了很短的 here ,但更深入 here )来解析命令/事件/查询、MetaData
或 MetaDataValue
。但是,您也可以让框架解析序列号,该序列号对于事件源聚合是聚合版本。您可以通过在事件处理函数中添加 @SequenceNumber
带注释的 Long
参数来实现此目的。
因此,您可以像这样编写事件处理程序:
@EventHandler
public void on(YourEvent event, @SequenceNumber Long aggregateVersion) {
// Update the query model And the aggregate version
}
话虽如此,这显然需要您处理事件处理组件中聚合中的所有事件,以便能够相应地更新版本。幸运的是,Axon 会识别您是否处理事件负载的父类。因此,如果您定义事件类层次结构,请确保来自给定聚合的所有事件都实现接口(interface) MyAggregateEvent。因此,您可以编写一个像这样的事件处理程序来覆盖所有剩余的事件,仅用于聚合版本更新,否则您不会对此感兴趣:
@EventHandler
public void on(MyAggregateEvent event, @SequenceNumber Long aggregateVersion) {
// Update the aggregate version only
}
希望这有帮助!
<小时/>附注我刚刚注意到 Handling Events page引用指南确实说明了 @SequenceNumber
注释。
关于java - 在 Axon 中投影 @AggregateVersion,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59855110/
我很想知道在使用 Axon 框架来验证电子邮件字段对于联系人聚合的一组电子邮件是唯一的时,最佳实践方法是什么。 示例设置 ContactCreateCommand { identifier =
我刚开始使用 Axon 框架,但遇到了一些障碍。 虽然我可以使用它们的 ID 加载单个聚合,但我不知道如何获取所有聚合的列表或所有聚合 ID 的列表。 EventSourcingRepository
我是 Axon 的新手,并编写了一个示例代码,其中我们有一个库存服务,用于添加新库存、更新库存,并且我们希望将事件发送到产品服务以进行任何更新。产品服务应充当库存服务的只读副本。 库存服务代码: 所以
是否有必要向 Axon 聚合和消息添加(覆盖)hashCode 和 equals 方法? SonarQube 中的分析表明,在对这些实体执行标准 Axon 操作时(在端到端测试中),它们没有被使用。此
新的一天,新的 Axon 问题。今天我想问一下Axon Saga的流程。在微服务之间使用 Axon Saga 的最佳实践是什么? 异步传奇:“主”服务同时向每个“从”服务发送命令。如果出现问题,也会通
是否可以在没有 Axon Server 的情况下扩展 Axon Framework 企业 ?我有兴趣使用 Axon 创建原型(prototype) CQRS 应用程序,但最终的可部署系统必须免收许可费
问题: 研究:在 https://gitlab.com/ZonZonZon/simple-axon.git我编了一个简单的 Axon-app 表明 JAR-artifact 建于 Gradle插件 c
我们正在使用 Axon 4 的 CQRS 和事件溯源。 我们有以下场景。 域书 操作 - 使用 Axon CRQS 和事件源流(命令 - 聚合 - 事件)在数据库中创建新书籍 操作 - 使用 Axon
在 AxonFramework 中,可以使用消息代理(例如 RabbitMQ)分发事件和命令。 我想知道是否可以对查询执行相同的操作,我在文档上找不到任何内容... 最佳答案 您在文档中找不到它是完全
我们目前正在对CQRS和事件源进行一些研究,并发现了两个主要框架来解决这两个问题:Axon Framework和Eventuate。两者都在继续开发,而Eventuate现在在RBMH reposit
我通常每个聚合有 5-6 个事件,并且不希望将预测存储在数据库中。在查询时进行 View 投影的最简单方法是什么? 最佳答案 对此的简短回答是,没有简单/快速的方法可以做到这一点。 但是,实现“在请求
是否可以使用 usingSubscribingEventProcessors 并且在投影事件时,始终从头开始重新投影所有事件。意思是——我从不将投影保存到数据库,而是在聚合发出新事件时重新投影所有事件
我正在尝试定义我的“事件处理程序拦截器”,我按照官方文档 here 上的说明进行操作,但我收到以下错误: org.springframework.beans.factory.BeanCreationE
我有以下设置: HTTP 请求到达 REST 端点,我在应用程序服务中收到它。 应用程序服务将请求映射到命令 C1 并使用 commandGateway.sendAndWait(new C1(rest
关闭。这个问题是opinion-based .它目前不接受答案。 想要改进这个问题吗? 更新问题,以便 editing this post 提供事实和引用来回答它. 关闭 3 年前。 Improve
我正在尝试测试聚合并想断言夹具之外的事件,甚至可能使用 Hamcrest 进行评估? 使用时间戳的例子 fixture.given() .when(new Use
我有一个用例,我想发布一个非状态更改事件作为触发器。 In the vast majority of cases, the Aggregates will publish events by ap
我正在尝试测试聚合并想断言夹具之外的事件,甚至可能使用 Hamcrest 进行评估? 使用时间戳的例子 fixture.given() .when(new Use
我目前正在为 Spring Boot/Axon 应用程序进行集成测试。 在其中一个测试中,它(一个节点)通过 SpringApplicationBuilder 创建另一个节点(在不同的配置文件下),连
到目前为止,我一直在 CommandHandlers 中处理授权。 一个例子是我有一个聚合“团队”,其中包含一个经理列表(来自用户的聚合标识符)。团队聚合中的所有命令处理程序然后验证执行命令的用户是团
我是一名优秀的程序员,十分优秀!