当前位置：首页 > news >正文

架构设计基础系列：事件溯源模式浅析

news 来源：原创 2025/5/8 18:23:58

图片来源网络，侵权删

‌1. 引言‌

‌1.1 研究背景‌

传统CRUD模型的局限性：状态覆盖导致审计困难、无法追溯历史。
分布式系统复杂性的提升：微服务架构下数据一致性、回滚与调试的需求激增。
监管合规性要求：金融、医疗等领域对数据不可篡改性的强制需求。

‌1.2 事件溯源的核心价值‌

‌完整历史追溯‌：通过事件流重建任意时间点状态。
‌业务逻辑显式化‌：事件作为业务意图的直接表达。
‌解耦与扩展性‌：读写模型分离（CQRS）支持独立优化。

‌2. 事件溯源的理论基础

‌

‌2.1 核心概念‌

‌事件（Event）‌：不可变的状态变更记录，如 AccountOpened、OrderCancelled。
‌事件存储（Event Store）‌：有序、持久化的事件流数据库。
‌聚合根（Aggregate Root）‌：一致性边界内的业务实体，负责生成事件。
‌投影（Projection）‌：从事件流生成实时查询视图。

‌2.2 事件溯源与CQRS模式‌

‌命令与查询职责分离‌：写模型通过事件溯源处理业务逻辑，读模型通过投影提供高性能查询。
‌最终一致性模型‌：通过异步事件传播实现读写模型同步。

‌2.3 事件溯源的数学基础‌

‌事件流作为状态函数‌：

其中 StSt 表示时间 tt 的状态，eiei 为事件，ff 为状态转换函数。

‌幂等性与事件顺序‌：事件顺序必须严格保证，幂等性设计可应对重复投递问题。

2.4 事件溯源优点

事件不可变，并且可使用只追加操作进行存储。 用户界面、工作流或启动事件的进程可继续，处理事件的任务可在后台运行。此外，处理事务期间不存在争用，此过程可极大提高应用程序的性能和可伸缩性，尤其是对于演示级别或用户界面。
**事件是描述已发生操作的简单对象以及描述事件代表的操作所需的相关数据。 **事件不会直接更新数据存储。只会对事件进行记录，以便在合适的时间进行处理。使用事件可简化实现和管理。
事件通常对域专家而言具有意义，然而对象关系阻抗不匹配却会让复杂数据库表变得难以理解。表是表示系统的当前状态（而不是已发生事件）的人工构造。
事件溯源不需要直接更新数据存储中的对象，因而有助于防止并发更新造成冲突。但是，域模型必须仍然设计为避免可能导致不一致状态的请求。
事件的只追加存储提供的审核线索可用于监视对数据存储采取的操作。它可以通过随时重播事件将当前状态重新生成为具体化视图或投影，并且可以帮助测试和调试系统。此外，使用补偿事件取消更改的要求可以提供反向更改的历史记录。如果模型存储了当前状态，则此功能不会是这种情况。事件列表还可用于分析应用程序性能和检测用户行为趋势。或者，也可用于获取其他有用的业务信息。
事件存储会引发事件，任务会执行操作以响应这些事件。通过将任务从事件中分离，可提供灵活性和可扩展性。任务知道事件类型和事件数据，但不知道触发事件的操作。此外，多个任务可以处理每个事件。这样可实现与仅侦听事件存储引发的新事件的其他服务和系统的轻松集成。但是，事件溯源事件的级别通常非常低，可能需要生成特定的集成事件。

通过执行响应事件的数据管理任务和具体化存储事件的视图，事件溯源通常与 CQRS 模式结合。

‌3. 主流事件溯源框架分析‌

‌3.1 框架分类‌

‌类别‌	‌代表框架‌	‌核心能力‌
‌企业级框架‌	Axon Framework	完整CQRS支持、分布式事件总线、Saga管理
‌轻量级库‌	Eventuous (.NET)	简化聚合根定义、多存储后端支持
‌事件流平台‌	Kafka + Kafka Streams	高吞吐量事件处理、流式计算集成
‌云原生服务‌	AWS EventBridge	无服务器事件路由、与Lambda/DynamoDB集成

‌3.2 Axon Framework 深度解析‌

‌3.2.1 架构设计‌

‌命令模型‌：CommandGateway 处理业务命令，驱动聚合根生成事件。
‌事件存储‌：支持JDBC、MongoDB、Axon Server（专用存储）。
‌查询模型‌：QueryGateway 从投影读取数据，支持订阅更新。

‌3.2.2 核心组件‌

‌聚合根生命周期管理‌：通过@Aggregate注解定义，自动处理事件重放。
‌Saga事务协调‌：长流程事务通过@Saga实现最终一致性。
‌事件回放与快照‌：定期生成快照（Snapshot）优化长事件流重建效率。

‌3.2.3 代码示例‌

// 定义聚合根
@Aggregate
public class BankAccountAggregate {@AggregateIdentifierprivate String accountId;private BigDecimal balance;@CommandHandlerpublic BankAccountAggregate(OpenAccountCommand cmd) {apply(new AccountOpenedEvent(cmd.getAccountId(), cmd.getOwner()));}@EventSourcingHandlerpublic void on(AccountOpenedEvent event) {this.accountId = event.getAccountId();this.balance = BigDecimal.ZERO;}// 处理存款命令@CommandHandlerpublic void handle(DepositCommand cmd) {apply(new DepositCompletedEvent(accountId, cmd.getAmount()));}
}

‌3.3 EventStoreDB 的存储引擎优化‌

‌追加写优化‌：基于日志结构合并树（LSM-Tree）实现高吞吐量写入。
‌内置订阅机制‌：支持持久化订阅（Persistent Subscription）与流分区（Stream Partitioning）。
‌多语言支持‌：通过gRPC/HTTP API提供跨平台兼容性。

‌3.4 云原生框架对比‌

‌框架‌	‌事件存储‌	‌适用场景‌	‌局限性‌
‌Axon Server‌	专用存储	企业级微服务	运维复杂度高
‌Kafka‌	分布式日志	高吞吐量事件流	需额外实现聚合根逻辑
‌AWS EventBridge‌	无服务器事件总线	快速构建Serverless应用	功能扩展性受限

‌4. 实际案例研究‌

‌4.1 案例一：银行账户管理系统‌

‌4.1.1 需求分析‌

合规性要求：所有资金变动记录必须可审计。
高并发挑战：支持每秒万级交易处理。

‌4.1.2 技术选型‌

‌框架‌：Axon Framework + Axon Server
‌存储‌：EventStoreDB + PostgreSQL（读模型）
‌消息总线‌：RabbitMQ

‌4.1.3 事件流设计‌

1. AccountOpenedEvent
2. DepositCompletedEvent
3. TransferOutEvent
4. TransferInEvent
5. InterestCalculatedEvent

‌4.1.4 性能优化‌

‌快照机制‌：每1000个事件生成一次快照，减少聚合根重建时间。
‌分片策略‌：按账户ID哈希分片事件存储，提升并发处理能力。

‌4.2 案例二：电商订单系统‌

‌4.2.1 业务场景‌

订单状态追踪：从创建、支付到物流的全流程事件记录。
实时库存管理：通过事件流触发库存扣减与回滚。

‌4.2.2 技术实现‌

‌框架‌：.NET + Eventuous
‌存储‌：MongoDB（事件存储） + Elasticsearch（读模型）
‌投影逻辑‌：

public class OrderProjection : IEventHandler<OrderCreatedEvent> {public async Task Handle(OrderCreatedEvent @event) {await _readModel.UpdateAsync(@event.OrderId, model => {model.Status = "Created";model.Items = @event.Items;});}
}

‌5. 技术挑战与解决方案‌

‌5.1 事件版本迁移‌

‌问题‌：业务变更导致事件结构不兼容。
‌解决方案‌：
- ‌向上兼容‌：新增字段而非修改旧字段。
- ‌版本转换中间件‌：在读取时动态转换旧事件版本。

‌5.2 长事件流性能瓶颈‌

‌问题‌：重放数万事件导致响应延迟。
‌解决方案‌：
- ‌定期快照‌：存储聚合根的中间状态。
- ‌增量投影‌：仅处理新增事件而非全量重放。

‌5.3 分布式事务一致性‌

‌问题‌：跨服务事件处理的最终一致性。
‌解决方案‌：
- ‌Saga模式‌：通过补偿事件实现回滚。
- ‌事件幂等性‌：唯一ID去重或版本号校验。

‌6. 事件溯源使用场景

请在以下方案中使用此模式：

要捕获数据中的意图、用途或原因。例如，可将对客户实体的更改捕获为一系列特定事件类型，例如_已搬家_、帐户已关闭_或_已身故。
尽量减少或完全避免出现数据更新冲突。
需要记录发生的事件，并重播事件以还原系统状态、回滚更改或保留历史记录和审核日志。例如，任务涉及多个步骤时，可能需要执行操作来恢复更新，并重播某些步骤使数据重返一致的状态。
使用事件时。这是应用程序操作的自然功能，且几乎不需要其他开发或实现工作。
需要将输入或更新数据的过程从应用这些操作所需的任务中分离。此更改可能是为了提高 UI 的性能，或者是为了将事件分发给其他在事件发生时采取操作的侦听器。例如，可以将工资管理系统与开支报销网站集成。由事件存储引发的用于响应网站中数据更新的事件可同时供该网站和工资管理系统使用。
希望随要求更改而灵活更改具体化模型和实体数据的格式，或需要调整读取模型或公开数据的视图（与 CQRS 结合使用时）。
与 CQRS 结合使用且更新读取模型时最终一致性可接受或事件流中的解冻实体和数据的性能影响可接受。

此模式在以下情况中可能不起作用：

**小型域或简单域、几乎或完全没有业务逻辑的**系统或者自然地适用于传统 CRUD 数据管理机制的非域系统。
要求一致性和数据视图实时更新的系统。
不需要审核线索、历史记录以及回滚和重播操作功能的系统。
基础数据更新冲突发生率低的系统。例如，主要是添加数据而不是更新数据的系统。

‌7. 结论‌

事件溯源框架通过将业务逻辑显式化为事件流，为构建高可靠、可审计的分布式系统提供了全新范式。主流框架如Axon、EventStoreDB和Kafka在不同场景下展现出独特优势，但需权衡性能、复杂性与扩展性。未来，随着云原生技术与AI的融合，事件溯源将在实时分析、自动化决策等领域发挥更大价值。

‌参考文献‌

https://learn.microsoft.com/zh-cn/azure/architecture/patterns/event-sourcing
https://codeopinion.com/greg-young-answers-your-event-sourcing-questions/

架构设计基础系列：事件溯源模式浅析

图片来源网络，侵权删 ‌1. 引言‌ ‌1.1 研究背景‌ 传统CRUD模型的局限性：状态覆盖导致审计困难、无法追溯历史。分布式系统复杂性的提升：微服务架构下数据一致性、回滚与调试的需求激增。监管合规性要求：金融、医疗等领域对数…...

编程日记 2025/5/8 18:23:58

虚拟试衣间-云尚衣橱小程序-衣橱管理实现

衣橱管理实现目标 (Goal): 用户 (User): 能通过 UniApp 小程序上传衣服图片。后端 (Backend): 接收图片，存到云存储，并将图片信息（URL、用户ID等）存入数据库。用户 (User): 能在小程序里看到自己上传的所有衣服图片列表。技术栈细化 (Refined Tech Stack for this Pha…...

编程日记 2025/5/8 17:28:35

蓝桥杯省模赛台阶方案

问题描述小蓝要上一个楼梯，楼梯共有 n 级台阶（即小蓝总共要走 n 级）。小蓝每一步可以走 a 级、b 级或 c 级台阶。请问小蓝总共有多少种方案能正好走到楼梯顶端？ 输入格式输入的第一行包含一个整数 n 。第二行包含三个整数…...

编程日记 2025/5/6 2:56:20

Socket编程UDP

Socket编程UDP 1、V1版本——EchoServer2、网络命令2.1、ping2.2、netstat2.3、pidof 3、验证UDP——Windows作为client访问Linux4、V2版本——DictServer5、V3版本——简单聊天室 1、V1版本——EchoServer 首先给出EchoServer目录结构：服务器的类我们实现在UdpServ…...

编程日记 2025/5/8 18:18:53

无人机机体结构设计要点与难点!

一、无人机机体结构设计要点 1. 类型与应用场景匹配固定翼无人机：需优化机翼升阻比，采用流线型机身降低气动阻力（如大展弦比机翼设计）。多旋翼无人机：注重轻量化框架和对称布局（如四轴/六轴碳纤维机…...

编程日记 2025/5/8 17:50:21

前言一个基于C11的高性能运营级流媒体服务框架全协议支持H264/H265/AAC/G711/OPUS/MP3，部分支持VP8/VP9/AV1/JPEG/MP3/H266/ADPCM/SVAC/G722/G723/G729 1：环境 ubuntu22.* ZLMediaKit downlaod:https://github.com/ZLMediaKit/ZLMediaKit or https://g…...

编程日记 2025/5/8 17:27:12

实战 | 餐厅点餐小程序技术解析：SpringBoot + UniApp 高效开发指南

🖥️ 一、系统架构概览 1.1 技术选型为了确保开发效率和系统稳定性，我们采用以下技术栈： 模块技术选型后台服务SpringBoot MyBatis-Plus MySQL用户端（点餐小程序）UniApp（Vue 语法）师傅端&…...

编程日记 2025/5/8 17:22:53

合并相同 patient_id 的 JSON 数据为数组

问题 select patient_id,concat({"itemText":",item_text,","itemValue":",item_value,"}) from hs_patient_groups where active 1;eef41128c47c401abb7f8885a5f9fbdf {"itemText":"旧","itemValue"…...

编程日记 2025/5/6 22:27:20

AI安全：构建负责任且可靠的系统

AI已成为日常生活中无处不在的助力，随着AI系统能力和普及性的扩展，安全因素变得愈发重要。从基础模型构建者到采用AI解决方案的企业，整个AI生命周期中的所有相关方都必须共同承担责任。为什么AI安全至关重要？ 对于企业而言&…...

编程日记 2025/5/6 4:15:41

STM32单片机入门学习——第8节: [3-4] 按键控制LED光敏传感器控制蜂鸣器

写这个文章是用来学习的,记录一下我的学习过程。希望我能一直坚持下去,我只是一个小白,只是想好好学习,我知道这会很难，但我还是想去做！ 本文写于：2025.04.02 STM32开发板学习——第8节: [3-4] 按键控制LED&光敏传感器控制蜂鸣器前言开…...

编程日记 2025/5/8 17:07:13

Linux驱动入门——设备树详解

文章目录一、设备树的引入与作用二、设备树的语法1. Devicetree格式1.1 DTS文件的格式1.2 node的格式1.3 properties的格式 2. dts文件包含dtsi文件3. 常用的属性3.1 #address-cells、#size-cells3.2 compatible3.3 model3.4 status3.5 reg 4. 常用的节点(node)4.1 根节点4.2 …...

编程日记 2025/5/4 1:11:24

Scala集合

Scala集合分为序列Seq、集Set、映射Map，都扩展自Iterable特质，且有可变和不可变版本。不可变集合操作后会返回新对象，可变集合则直接修改原对象。比如数组，不可变数组定义后大小不可变，修改会生成新数组；可…...

编程日记 2025/5/5 22:19:43

阿里云AI Studio 2.0：拖拽搭建企业级智能客服系统

一、平台能力全景 1.1 核心功能矩阵模块子功能技术指标对话设计可视化流程编排支持50节点类型NLP引擎意图识别准确率行业TOP3（92.6%）知识管理多源数据接入15格式支持渠道对接全渠道覆盖8大平台SDK 1.2 企业级特性关键优势： 日均对话承…...

编程日记 2025/5/8 18:11:40

java虚拟机---JVM

JVM JVM，也就是 Java 虚拟机，它最主要的作用就是对编译后的 Java 字节码文件逐行解释，翻译成机器码指令，并交给对应的操作系统去执行。 JVM 的其他特性有： JVM 可以自动管理内存，通过垃圾回收器回收不再…...

编程日记 2025/5/8 17:04:08

您的LarkXR专属顾问上线了！平行云官网新增 AI 小助手，手册同步升级！

遇到LarkXR技术问题？还在手动翻文档？ Paraverse平行云官网双升级——AI小助手实时答疑用户手册智能检索！ 助您快速定位解决方案，效率全面提升！ < 01 > AI 小助手—— 您的 LarkXR 智能顾问欢迎我们的新成员…...

编程日记 2025/5/8 17:45:38

推导Bias² + Variance + σ²_ε

问题的背景我们有一个真实函数 f ( x ) f(x) f(x) 和基于训练数据 D D D 训练得到的模型 f ^ ( x ; D ) \hat{f}(x;D) f^(x;D)。对于任意输入 x x x： y y y 是真实的观测值，定义为 y f ( x ) ϵ y f(x) \epsilon yf(x)ϵ，其中 …...

编程日记 2025/5/8 18:05:30

javaSE知识梳理（一）

一.面向对象编程 1.面向对象的基本元素：类(class)和对象 ①类的声明语法格式： [修饰符] class 类名{属性声明;方法声明; } ②对象的创建(new) 语法格式： //方式1：给创建有名对象类名对象名 new 类名();//方式2&#xff1…...

编程日记 2025/5/8 17:25:50

k8s statefulset pod重启顺序

在 Kubernetes 中，StatefulSet 的 Pod 重启顺序由以下规则和机制决定： 1. StatefulSet 的核心设计原则 StatefulSet 旨在管理有状态应用，其核心特性包括： 稳定的唯一标识：Pod 名称格式为 <statefulset-name>-&…...

编程日记 2025/5/8 17:39:04

记录学习的第十九天

现在这篇是记录一下4.1的学习。今天还没开始。这篇是关于简单的动态规划的题目，思路比较清晰类似。在这里先说一下有关动态规划的四个步骤： 1.确定子问题 2.确定dp数组的递推关系(dp数组也叫子问题数组) 3.确定求解的计算顺序 4.空间优化(初学者可…...

编程日记 2025/5/8 15:32:20

【实用技巧】电脑重装后的Office下载和设置

写在前面：本博客仅作记录学习之用，部分图片来自网络，如需引用请注明出处，同时如有侵犯您的权益，请联系删除！ 文章目录前言下载设置总结互动致谢参考目录导航前言在数字化办公时代，Windows和…...

编程日记 2025/5/6 14:59:35

模拟集成电路设计与仿真 : Mismatch

前情提要此為作者針對 mismatch ，進行資料統整，以便日後查詢原理 1. Mismatch (失配) random offset 靜態消除 : trimming動態消除 : auto zero ，choppingCMRRlinearity 理想差動對只有奇次諧波，沒有偶次諧波，但 mismatch 會引入殘存的偶次諧波PSRR2. Input Offset Volt…...

编程日记 2025/5/8 17:37:32

深度学习查漏补缺：4.数据分布的度量

一、数据分布差异的度量 1.KL散度（Kullback-Leibler Divergence） 什么是KL散度？ KL散度是一种用来衡量两个概率分布之间差异的工具。你可以把它想象成一个“距离测量器”，但它不是传统意义上的距离（比如两点之…...

编程日记 2025/5/7 13:19:40

银河麒麟V10 aarch64架构安装mysql教程

国产操作系统 ky10.aarch64 因为是arm架构，故选择mysql8，推荐安装8.0.28版本尝试8.0.30和8.0.41版本均未成功，原因不明☹️ 1. 准备工作 ⏬ 下载地址：https://downloads.mysql.com/archives/community/ 2. 清理历史环境不用管…...

编程日记 2025/5/8 18:02:48

【NLP 52、多模态相关知识】

生活应该是美好而温柔的，你也是 —— 25.4.1 一、模态 modalities 常见： 文本、图像、音频、视频、表格数据等罕见： 3D模型、图数据、气味、神经信号等二、多模态 1、Input and output are of different modalities (eg： tex…...

编程日记 2025/5/8 18:08:49

[NCTF2019]Fake XML cookbook [XXE注入]

题目源代码 function doLogin(){var username $("#username").val();var password $("#password").val();if(username "" || password ""){alert("Please enter the username and password!");return;}var data "…...

编程日记 2025/4/29 17:29:49

I²C总线高级特性与故障处理分析

IC总线高级特性与故障处理深度分析目录 1. IC基础回顾 1.1 IC通信基本原理1.2 IC总线时序与协议1.3 寻址方式与读写操作 2. IC高级特性 2.1 多主机模式2.2 时钟同步与伸展2.3 高速模式与Fast-mode Plus2.4 10位寻址扩展 3. IC总线故障与锁死 3.1 断电锁死原理3.2 总线挂起与…...

编程日记 2025/4/24 4:35:15

【力扣hot100题】（039）二叉树的直径

这题在简单题中有点难度，主要是不要把边数和深度搞混（我就这样）。我想了很久，发现如果当前节点没有右节点，就将它的右长度设为0，左节点同理，并且在递归是不会加一，而是将加一的操作…...

编程日记 2025/5/8 18:06:54

L2-001 紧急救援

注意题目没有说边的数量，实际最多有5e5条边，开小了第四个样例会错！！！ - 思路: Dijkstra 求最短路并且维护路径条数和最大人数。 #include<bits/stdc.h> using namespace std;typedef pair<int, int> pii…...

编程日记 2025/5/8 17:59:28

分组背包问题

与01背包的区别是，多了一个限制条件，将物品打包，每组物品只能用一个 #include <iostream> #include <algorithm>using namespace std;const int N 110;int v[N][N], w[N][N], s[N]; int f[N]; int n, m;int main() {cin >>…...

编程日记 2025/5/8 17:31:19

【工业场景】用YOLOv12实现饮料类别识别

饮料类别识别任务的意义在于帮助人们更快速地识别和区分不同类型的饮料，从而提高消费者的购物体验和满意度。对于商家而言，饮料类别识别可以帮助他们更好地管理库存、优化货架布局和预测销售趋势，从而提高运营效率和利润。此外，饮…...

编程日记 2025/5/6 2:26:55

宽带空时波束形成算法原理及MATLAB仿真

宽带阵列信号处理空时波束形成、空时波束形成方向图卫星导航空时抗干扰算法 MATLAB仿真文章目录前言一、空时波束形成结构二、空时波束形成方向图三、MATLAB仿真四、MATLAB源代码总结前言 \;\;\;\;\; 空时波束形成（Space-Time Beamforming）是一种结…...

编程日记 2025/5/8 17:19:50

406. 根据身高重建队列

链接 406. 根据身高重建队列 - 力扣（LeetCode） 题目思路可能的一个思路是先对高的人进行处理，这样后面插入矮的人时不会影响高的人的位置。比如，如果先处理高个子，那么当插入一个矮个子的时候，前面的高…...

编程日记 2025/5/8 17:35:58

机器学习：人工智能的核心驱动力

近年来，机器学习（Machine Learning，简称ML）已成为人工智能（AI）领域的核心驱动力。它不仅广泛应用于图像识别、自然语言处理、医疗诊断等领域，还推动了自动驾驶、智能推荐系统等前沿技术的发展。…...

编程日记 2025/5/8 17:18:24

机器视觉中的传统视觉与深度视觉

工业视觉是现代制造业中一个非常重要的应用领域，广泛用于产品质量检测，尤其是在生产线上。几乎所有的工业产品在流入市场之前，都要经历严格的缺陷检测环节，以确保它们符合质量标准。而在这一过程中，工业视觉检测系统发…...

编程日记 2025/5/8 17:12:01

机器学习开发全流程详解：从数据到部署的完整指南

机器学习项目的成功不仅依赖算法选择，更在于系统化的开发流程。本文详细拆解各阶段的核心任务、工具及注意事项，并通过表格总结帮助开发者快速掌握关键要点。 1. 数据获取与准备数据是机器学习的基础，需确保数据的质量与代表性。关键任务…...

编程日记 2025/5/4 17:42:12

春晚魔术[蓝桥]

这里考虑到N很大则快速幂无法处理，因为它并没有被取模欧拉定理： 当是质数时是质数两边同时取mod， // // Created by yumo_ // #include<bits/stdc.h>using namespace std; #define scin std::cin #define scout std::cout using …...

编程日记 2025/5/5 3:14:26

CF580B Kefa and Company（滑动窗口）

题目描述 Sergei B., the young coach of Pokemons, has found the big house which consists of n flats ordered in a row from left to right. It is possible to enter each flat from the street. It is possible to go out from each flat. Also, each flat is connecte…...

编程日记 2025/5/4 4:23:11