微服务与事件驱动架构

将事件驱动架构与现有系统集成

｜

45

件流的同步。事件流会与遗留应用程序的内部数据集达到最终一致，如图

4-4

所示。

应用程序1 应用程序2

解放的事件流

物化表 物化表

偏移量

K V

A 10

K=A

V=0

K=B

V=20

K=C

V=30

K=A

V=10

B 20

C 30

K V

A 10

B 20

C 30

图 4-4：在两个服务之间解放并物化状态

4.1.2

　将被解放的数据转化成事件

与任何其他事件一样，被解放的数据也要遵循第

3

章中介绍的结构化建议。定义良好的

事件流的一个特点是，它所包含的事件有一个显式定义的、可演化的兼容

schema

。作为

schema

定义的数据契约的一部分

，应该确保消费者有基本的数据质量保证。对

schema

的

变更只能根据演化规则来进行。

在整个组织中对被解放的事件数据和原始的事件数据采用相同标准的格式。

根据定义，在业务中与业务最相关且常用的数据就是需要被解放的数据。对数据源的数据

定义做出更改，比如创建新的字段、更改现有字段或删除其他字段等，可能导致动态变更

数据操作传播到下游消费者。如果不能为解放的数据使用显式定义的

schema

，那么将迫使

下游消费者解决所有不兼容问题。这对提供单一事实来源来说是很困难的，因为下游消费

者不应该试图自己解析数据。提供可靠的数据以及最新的

schema

并仔细考虑数据随时间

的演变，这一点非常重要。

4.2

　数据解放模式

有

3

种主要的数据解放模式可用于从底层数据存储中提取数据。因为解放数据意味着要形

成新的单一事实来源，所以它必须包含数据存储中的全部数据集合。此外，新的插入、更 ...