事件溯源-以事件为中心的编写业务逻辑和持久化领域对象方法
1、事件溯源
事件溯源是一种事件为中心的技术，用于实现业务逻辑和聚合的持久化。聚合作为一系列事件存储在数据库中，每个事件代表聚合状态的变化。
- 事件溯源通过事件来持久化聚合
- 事件代表状态的变化
- 聚合方法都和事件相关（业务逻辑上通过聚合根上的命令方法来处理聚合的更新请求）
2、使用乐观锁处理并发更新
- 场景：两个或更多的请求同时更新一个聚合
- 为了防止一个事务覆盖另一个事务
- 示例：
update aggregate_root_table
set version = version + 1
where version = <original version>
3、事件溯源和事件发布
- 场景：如果事务A插入Event_ID为1010的事件，事务B插入EVENT_ID为1020的事件并且先提交。在事务A提交以前，事件发布者查询事件并发布到消息代理，此时发布的事件为1020，此后事务A提交的1010的事件将不会被发布。
- 处理方式：增加一个发布状态的字段
## 1、查询未发布的事件
select * from events where published = 0 order by event_id ASC;
## 2、发布事件到消息代理
## 3、修改事件的标记
update events set published = 1 where event_id in ()
4、使用快照提升性能
- 场景：长生命周期的聚合可能会产生大量事件，随着时间的推移，加载和重放这些事件的速度会越来越慢
-
处理方式：为事件表创建一个快照表，定期存储快照。查询时，只查询快照事件以后的事件
image.png
Tabale: EVENTS
| event_id | event_type | entity_type | entity_id | event_data |
|---|---|---|---|---|
| ... | ... | User | e_01 | {...} |
| 103 | create | User | e_01 | {...} |
| 104 | update | User | e_01 | {...} |
| 105 | update | User | e_01 | {...} |
Tabale: SNAPSHOTS
| event_id | event_type | entity_type | entity_id | snapshot_data |
|---|---|---|---|---|
| ... | ... | ... | ... | ... |
| 103 | create | User | e_01 | {...} |
| ... | ... | ... | ... | ... |
5、幂等
- 在关系数据库中检测和丢弃重复消息
- 非关系数据库，存储处理消息的ID。验证聚合的所有事件中是否包含此消息的ID
6、事件溯源的好处和弊端
- 好处：
可靠地发布领域事件
保留聚合历史
为开发者提供一个“时光机” - 弊端：
编程模式有一定的学习曲线
基于消息传递的应用程序的复杂性
处理事件演化有一定难度
删除数据库存在一定难度
查询事件存储库非常有挑战性
