cqrs

    2热度

    3回答

    我有一个设计或至少应该根据众所周知的DDD原则的项目。 后退 - DDD + CQRS +事件存储 UI - NGRX /存储 我有很多问题想请教一下,但现在我会坚持这些两个: 单个命令/操作执行后应如何更新UI存储? 一)订阅response.ok 二)听取域事件 C)触发通用事件持创建/更新/删除对象? 在每个命令/事件中将整个聚合根dto与其所有实体进行转换是否是一个好主意,或者最好是有更多

    2热度

    1回答

    我需要对此进行一些意见/建议/建议。 予有这种使用情况下,其中1个事件可以在CQRS触发另一个命令。 的情况是,有1名指挥人员和2名用户/查询服务和用户的1需要执行一些搜索和基于搜索可以发出另一个命令的结果。 现在,问题是查询服务应该发出一个命令(直接发送到事件库:我猜这打败了cqrs的目的),或者对命令服务(可能通过api网关)进行正常的api调用,命令?

    1热度

    3回答

    我正在使用Axon + Spring Boot创建一个简单的应用程序,只是为了确保我在Axon框架中理解基本组件,然后才将其用于实际项目。 有一个应该当我通过CommandGateway命令发送到被称为类TaskAggregate内的@CommandHandler注释的方法,但在运行应用程序后,我得到异常: Exception in thread "main" org.axonframework.

    1热度

    1回答

    我有一个处理Report Run Command的报告运行器聚合。聚合具有目标标识符,并且这两个命令具有相同的目标标识符。 得到以下错误 java.lang.IllegalArgumentException异常:工作单元已经具有在org.axonframework.common.Assert.isTrue(Assert.java:54)具有相同标识符 一个聚合〜[axon-core-3.0.6.j

    9热度

    2回答

    我被要求在事件源中进行一些探索。我的目标是创建一个满足所有传统CRUD操作的小API层。我现在正在使用一个名为'sourced'的包,并尝试使用它(使用Nodejs)。 但是,当我单独使用时,我意识到事件源并不是很有用。通常,它与CQRS耦合。 我对CQRS的理解是,当UI向服务器发送写命令时。该应用程序对数据做了一些验证。并保存在事件存储(我用的MongoDB),例如:这里是我的事件存储应该是什

    0热度

    2回答

    我设计采用DDD一个CQRS应用程序,并想知道如何实现以下情形: 一个Participant骨料可以被多个引用ParticipantEntry聚集 的AddParticipantInfoCommand发出的命令侧,这包含Participant和一个ParticipantEntry的(类似于Order和一个OrderLineItem)所有信息 应该在哪里逻辑实现为ch ecks参与者是否已经存在,如

    0热度

    3回答

    我们正在使用使用的NodeJS微服务,CQRS,事件存储CQRS域,一切就像一个魅力和典型的流程是这样: REST-> 2。服务 - > 3。命令验证 - > 4。命令 - > 5。聚集物> 6。事件 - > 7。事件库(事务数据) - > 8。返回聚合ID-> 9.存储在微服务本地数据库(本质上是读数据库) - > 10.发布事件到队列 上面的流程的问题是,由于事务数据保存,即持久性到事件存储和

    1热度

    1回答

    我是CQRS的新手,需要关于设计中以下情况的建议。一个命令更新聚合A的状态;读取模型需要随后用交叉聚合计算方法的结果进行更新;此方法属于另一个集合B,该集合B持有对集合A的引用;该方法是聚合B和引用聚合A的状态的函数。在哪里调用该函数的正确位置? 我的注意事项(可以跳过): 命令处理程序更新机组A的国家可以从技术上就可以了仓库,呼叫计算,并把结果在域事件获取骨料B;但是我相信这不是命令处理程序的工

    2热度

    1回答

    因为我没有在我的CQRS应用程序中使用事件源,所以我引入了一个简单的事件日志,它使我能够更新读取存储。 这意味着一个状态变化到我的应用程序包括两个动作: 更新写模型状态,例如SQL INSERT 插入到事件日志 两个写操作必须发生,因为一个原子操作。不幸的是,事件日志驻留在另一个数据库中,所以我必须考虑分布式事务。 大多数CQRS样本处理传奇模式,他们似乎都利用事件采购,这使事情变得更简单。 我的

    0热度

    1回答

    我用阿卡持久性,与性LevelDB作为存储插件,在用Scala编写的应用程序。在查询方面,目前执行的只知道演员的标识符采用PersistentView,其调查的消息从PersistentActor的日记。 现在我已经了解到,PersistentView已被弃用,一个是鼓励使用持久查询代替。但是,我还没有找到关于如何修改使用PersistentView来支持首选持久性查询实现的详细说明。 任何帮助,