分布式系统-事件消耗-同步问题

Question

在一次采访中，我被要求建立一个支付生态系统，它有两个服务--活动服务和信用服务。Activity负责向客户提供用户活动信息。信用服务公司负责提供与信用相关的数据。

这两种服务都从卡夫卡的主题中收听相同的支付事件。活动服务的功能是侦听支付事件，并对信用服务进行API调用，获取信用数据，并将支付事件的聚集视图和信用数据存储到活动数据库中。

而Credit还侦听支付事件，并根据此事件更新其数据库。

该系统目前面临的问题之一是，当活动服务在消费支付事件时调用Credit时，Credit提供的信息没有更新，原因是Credit没有根据相同的支付事件更新其数据库。

这看起来像是典型的分布式系统问题。任何关于如何解决这个问题的见解都是非常有用的。

Answer 1

由于至少有一个其他服务同时具有支付事件和从该事件中产生的信用服务的更新是有用的，因此一种合理的解决方案可能是让信用服务发布一个事件，该事件只不过是通过对其模型所做的更新而丰富的原始支付事件(或者，如果希望消费者查询信用服务，仅仅是它更新了模型这一事实)。

然后，活动服务可以订阅这些丰富的事件，或者：

• 知道信用服务已经处理了相应的支付事件，因此信用服务的数据模型看到了支付事件
• ，因为它可以查看信用服务对其模型

所做的更改。

注意，后一个选项(而不是查询，只是取决于丰富的视图)使这两个服务解耦。

前一个选项确实允许活动服务查看基于丰富事件的支付事件之后的支付事件修改的状态:这可能是可取的，也可能是不可取的。