Event Sourcing And CQRS Event Sourcing 、CQRS 简述 Event Sourcing 简单来说就是记录对象的每个事件而不是记录对象的最新状态，比如新建、修改等，只记录事件内容，当需要最新的状态的时，通过堆叠事件将最新的状态计算出来。那么这种模式查询的时候性能会变的非常差，这个时候就涉及到了 CQRS ，简单的理解就是读写分离，通过事件触发，将最新状态保存到读库，查询全都走读库，理论上代码层，数据库层，都可以做到分离，当然也可以不分离，一般来说为了保证数据库性能，这里起码会将数据库分离。 为什么要使用 了解了 Event Sourcing 的基本内容之后，我们可以发现这个模式有很多的好处： 记录了对象的事件，相当于记录了整个历史，可以查看到任意一个时间点的对象状态； 都是以事件形式进行写入操作，理论上在高并发的情况下，没有死锁，性能会快很多； 可以基于

Kafka Streams的事件源和物化视图 介绍 Kafka帮助您构建快速，高吞吐量，容错，可扩展的微服务和应用程序。 Kafka Streams将数据存储在Kafka集群（Kafka State Stores）中，并快速获取数据检票口。 该存储库通过Kafka Streaming演示了事件源（材料化视图）（ ） 在典型的生产环境中，我们有多个带有专用数据库的微服务，并且我们希望对每个数据库执行多阶段提交。 假设用户要在eShopping应用程序中下订单，我们可以使用不同的微服务来执行以下操作（a）检查所请求产品的库存（Inventory MicroService会处理此问题）（b）检查是否有任何付款方式可用并处理付款（由MicroService负责付款）（c）获取收货地址和帐单地址（由客户管理MicroService负责） 如果上述微服务中的任何一个发生故障，我们都希望回滚事务

Streamstone是一个微型可嵌入式库，旨在在Azure表存储之上构建可扩展的事件源应用程序。 它具有简单，实用的样式API，深受Greg Young的活动商店的启发。 特征 完全符合ACID 乐观并发支持 重复事件检测（基于身份） 自动继续写入和读取（超过WATS限制） 您可以查询的自定义流和事件属性 同步（内联）投影和快照 更改对内联投影的跟踪支持 友好的多租户设计 分片支持（跳转一致哈希） 与.NET Standard 2.0和.NET Framework 4.6兼容 从NuGet安装 要通过NuGet安装Streamstone，请在NuGet程序包管理器控制台中运行以下命