event-store

    2热度

    1回答

    我试图在Docker中运行一个服务器(EventStore),在这种情况下是他们自己的图像。我用-P标志运行这个映像来分配外部端口。 (我的用法使得特定的端口分配不切实际。) 当我启动EventStore的映像时,端口2113(它们的网络端口)被映射到一些高端口,如33125.如果我在浏览器中输入(my_ip):33125,它会被重写为像(my_ip):2113/web /。当然,Docker端口

    3热度

    2回答

    有各种示例应用程序和框架实现CQRS +事件源代码架构,大多数描述使用事件处理程序来创建存储在事件存储区中的域事件的非规范化视图。 托管此体系结构的一个示例是作为接受命令到写入端并支持查询非规范化视图的web api。这个web api可能会扩展到负载均衡农场中的许多机器。 我的问题是在哪里读取模型事件处理程序托管? 可能的情景: 托管在一个单一窗口服务单独的主机上。 如果是这样,是不是会造成单点

    5热度

    3回答

    我正在使用Java和Cassandra的事件采购从头开始构建项目。 我的应用程序是基于微服务的,在某些使用情况下,信息将被异步处理。我想知道Message Queue(比如Rabbit,Active MQ Artemis,Kafka等)在这个环境中如何改进技术堆栈,以及如果我理解这些场景,我将不会使用它。

    2热度

    3回答

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

    0热度

    1回答

    我已经创建了服务结构(SF)应用程序与托管我的本地计算机上我的事件存储交互,达到这里的一切fine.Now我想移动应用程序Azure上。我已经成功地部署到Azure上我的SF的应用程序并创建了一个Azure扩展设置有3个节点,并在他们身上安装EventStore。 现在,我怎么连接到Azure上比例集合即我应该通过在SF的我的应用程序参数文件什么的连接字符串我的SF的应用程序托管EventStor

    9热度

    2回答

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

    2热度

    1回答

    假设我正在使用购买和销售材料的使用“事件采购”(存储业务事件)的系统;在某一时刻,会生成一份包含价格和成本信息的报告。 想象一下,我的一个客户打电话给我,说:“成本是错误的,对我来说,从开始获利的规则是这样”。 我可以添加更多处理程序或更改规则以适应此特定情况,并重播事件。 但我的问题是,这是正确的方法(或至少更好)?

    0热度

    3回答

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

    4热度

    2回答

    我已经阅读Jonathan Oliver关于处理乱序事件的好消息。 http://blog.jonathanoliver.com/cqrs-out-of-sequence-messages-and-read-models/ ,我们用的是出队的消息,并把它放在一个“支持台”,直到与前一个序列的所有消息都收到 的解决方案。当收到所有先前的消息时,我们将所有的 消息从保留表中取出,并依次通过 合适的处理

    2热度

    3回答

    我一直在阅读关于事件采购模式,如果您想重建您的系统,这可能非常有用。但是,如果我需要在处理新的传入请求时运行事件重建,该怎么办?这种情况下是否有特定的模式或最佳做法? 因此,如何确保新的传入请求不会在重播时堵塞我的系统,因为事件同步和顺序对我的系统非常重要。它涉及更新依赖于事件序列的数据库记录。有什么想法吗?