龙空技术网

谈谈架构层级的“开闭原则”

EAWorld 1100

前言:

此刻看官们对“订阅者和发布者是什么关系呢”可能比较关注,同学们都需要了解一些“订阅者和发布者是什么关系呢”的相关知识。那么小编在网摘上网罗了一些对于“订阅者和发布者是什么关系呢””的相关知识,希望咱们能喜欢,看官们快快来了解一下吧!

本文由公众号EAWorld翻译发表,转载需注明出处。

作者:David Llobregat

译者:白小白

原文:

原题:The Open-Closed Principle at an Architectural Level

简介:

本文是关于架构层级SOLID原则的文章系列的第一篇。你可能熟悉如何在面向对象的层级遵循SOLID原则来进行类的设计,或者你也曾经疑惑这些原则是否适用于系统的架构设计,关于这一点,我将尝试给出一些我的见解。

在类的层级,开闭原则(the-Open-Closed-Principle,简称OCP原则)的含义是:一个类对扩展是“开”放的,而对变更是封“闭”的,意思是说,应该在不改变类的前提下扩展一个类的行为。而通常的方式是继承和多态。

在架构层级,我们并不会变更系统的一部分功能(可能是最适用于当前架构的进程,守护进程,服务,或者微服务),而是通过新增功能的方式来复用已完成的代码。为了不对现有的部分做出变更,系统需要做到完全的解耦。接下来的内容将聚焦于事件驱动系统,并以消息队列实现服务间通信。消息队列 可以是ActiveMQ, RabbitMQ, ZeroMQ, Kafka或者其他服务,我将以Kafka的话语体系来进行描述,如主题(Topic),发布者,订阅者,以及类似Kafka的多个订阅者共享相同主题的能力。

一、消息系统

上图是一个一般用例:发布者向主题发布消息(或者事件),多个订阅者可以从主题处获得该事件。箭头指示了通信的流向。假定发布者和订阅者都是微服务的话,双层的圆角矩形代表某一特定微服务的多个实例。在本例中的四个微服务:发布者,订阅者1,订阅者2,订阅者n,每个微服务都有多个实例。

二、具体示例

举一个具体的例子。假设我们在一家汽车租赁公司工作,并负责建立一个车辆的可用性系统。整个租赁流程的简化视图如下:

第1步,车辆租赁:包含租赁协议的签订和客户选车的过程。随即可用的车辆数减1。

第2步,客户用车:客户在一定的时间范围内使用租赁的车辆。

第3步,车辆归还:车辆的归还和签到。随即可用的车辆数加1。

其中第1步和第3步都需要将租赁协议入库,因此我们可以设计一个事件,RentalAgreementSaved,在保存数据时触发。这一事件将被存储在RentalAgreementSaved主题中。因此到目前为止,共有两个发布者向主题发送消息,一个是CarRental微,另一个是CarCheckin微服务。

下面来定义消息的内容。鉴于本主题的意图是为了表征租赁协议的保存,因此所需的最小信息量即协议ID。但系统的使命是跟踪车辆的可用性,最好还是设置一个Status字段。这一字段可以有两个值:

激活状态。代表客户正在使用车辆。

关闭状态。代表客户已经归还了车辆并进行了签到。

CarRental微服务可以选用如下的JSON数据结构:

{

"Status":"Active",

"RentalAgreementID":1234

}

CarCheckin微服务对应的数据结构是:

{"Status":"Closed","RentalAgreementID":1234}

Status字段本应从数据库读取,并通过协议ID加载租赁协议,但因为我们只关心车辆的可用性,直接在JSON消息中写入协议ID更简单,性能也更好。这一点在后文还会提到。

有了消息发布者和消息的格式,我们就可以完成下面的图表:

CarAvailability微服务会对发送给RentalAgreementSaved主题的消息进行消费:如果Status是“激活状态”,就减1,如果Status是“关闭状态”,就加1。

现在已经有了能够完成既定目标的可用系统,可以计算车辆的可用性。这一系统是否可以扩展以适用其他有意义的工作?是否可以真的在此过程中应用开闭原则?

三、系统扩展

假定我们需要在租赁流程结束的时候,给客户开具发票。可以设计一个Invoicing微服务来订阅RentalAgreementsSaved主题消息(消息中附加了租赁协议的ID)。当Status是“关闭状态”时,发票微服务可以从数据库中读取租赁协议的数据,并从Customers表中读取用户数据(Customers表和RentalAgreements表是相关联的)。有了上述信息,Invoicing微服务将可以向用户提供发票。过程如下图所示:

我们扩展了系统的功能,但并没有变更系统的代码。只是利用了多个订阅者可以订阅同一个消息主题的机制。因此是的,OCP原则可以在架构层级得以应用。

迪米特法则

迪米特法则(Law of Demeter)又叫作最少知识原则(Least Knowledge Principle 简称LKP),就是说一个对象应当对其他对象有尽可能少的了解。

假设,我们对现有的功能很满意,并准备添加一个新的功能:向用户发出感谢信来感谢他或她使用了我们的服务。参考发票微服务的例子,我们可以同样从数据库中获得租赁协议和用户数据。但这样的设计效率不高,因为CustomerThanking服务根本不需要用到租赁协议的内容。事实上,这也违反了“迪米特法则”,而我们希望所有的系统都是符合良好的架构实现的。

也许我们可以这样,变更RentalAgreementsSaved主题的消息内容,添加一个“CustomerID”字段,JSON格式数据如下:

{"Status":"Closed","RentalAgreementID":1234,"CustomerID":8965}

呃,等等,不是说好了要应用OCP原则的么,怎么能变更消息内容呢。看来还真是这样,好吧,我们得想想别的办法。

有界上下文

还好,确实有其他方案可供选择。我们可以让领域驱动设计(DDD)来帮忙。只要将领域拆分成有界上下文,就可以利用其优势来完成工作。在一个超简化的系统模型中,我们可以定义如下的有界上下文:

租赁协议

客户

车辆。

租赁专员:使用系统来办理租赁协议

租赁中介:通常情况下客户并不直接租车,而是通过代理人来租车

所有这些实体都出现在租赁协议中,但又自成有界上下文。因此,在最初设定消息格式的时候,我们可以根据正在进行的操作来引入主要的有界上下文。在本例中,初始的消息内容设计应该是下面的样子:

{"Status":"Closed","RentalAgreementID":1234,"CustomerID":8965,"VehicleID":98263,"RentalAgent":24352,"Broker":6723}

有了这样的消息结构,我们总算可以在不打破OCP原则和“迪米特法则”的情况下实现CustomerThanking微服务了。更不用说,我们还可以应用这样的消息结构来应付将来新的业务需要。比如:

计算租赁专员佣金。

提供租赁代理的经济信息。

车辆维护事宜。

诸如此类。

最重要的是,通过这样设计的消息内容,我们打开了一扇门,可以添加大量与这个事件相关的新功能(这些功能我们不可能在一开始就想清楚),而不需要改变现存的代码。

四、事件和消息数据

消息是如何构成的?消息的必要内容是什么?

为了回答这些问题,我们首先需要了解消息类型和目标的差异。首先,消息表征了事件,而事件即事实,代表已经发生的事情。我们在既往的时间定义了事件,这些事件代表已经发生过的事情,我们无法改变既成事实。我们在Topic中存储事件的时候,以事件为Topic命名。为了更好的理解事件,我推荐Jonas Bonér的演讲。

(链接:,英文)

事件的目标又是什么呢?我所知道的两种类型事件的目标是这样的:

表征事实。

建立数据流。

用来表征事实的事件,用于如前文所述的系统之中。其主要的目标就是传达某事已经发生的消息,并提供与这一事情相关的有用的数据。我们尝试不多不少地仅提供所需的信息,比如仅提供与事件相关的有界上下文实体的ID。

用于为系统构建数据流的事件,一般是应用于大数据系统中。在大数据系统中充斥着横跨系统范围内大量的信息,信息在传递过程中会经过多次转换。可以让事件附加我们所能提供的尽量多的信息,以便减少在信息转换所带来的额外的成本。

最小化消息信息

为什么在表征事实的时候,最小化信息量是如此的重要?我们来看一个例子。

假设我们需要为系统添加一个新的功能:一个Recommendations的微服务,来向客户发送一封邮件,并根据客户的个人资料推荐一些优惠信息。简化起见,假定我们只需要客户的年龄信息来进行推荐。为了不产生额外的开销,我们可以选择不读数据库,而是把年龄数据存储在消息中(此处先不考虑OCP原则,我们只是在分析在消息中添加新数据产生的影响)。

{"Status":"Closed","RentalAgreementID":5678,"CustomerID":8965,"VehicleID":98263,"RentalAgent":24352,"Broker":6723,"CustomerAge":27}

系统示意图如下:

看起来我们有了一个良好解耦的系统,这很好。但是,事实真的是这样么?假定我们需要修改推荐算法,把用户驾照的发证信息纳入考虑。很简单,只需要把这个字段加到JSON里即可。但在本例中,我们的微服务并没有实际解耦,因此,每次我们需要一个新的字段的时候,就需要同时修改订阅者和发布者。我们的微服务是紧耦合的,并且是以一种很丑陋的方式,直到我们需要对系统做出变更的时候,我们才会意识到这一点。

我们可能会这样想,是不是可以把每个可能的字段都加到消息数据中,这样问题就解决了,我们再也不需要修改发布者和订阅者了。但系统是随时间进化的,总会有一个时刻,需要在模型中添加新的字段,同时需要修改每一个微服务。因此这条路也行不通。

我们所能采取的最好的方案是,在消息中提供足够的信息,既满足我们最初的设计中所考虑到的用例场景的需要,同时也要让这些信息对我们可能尚未考虑到的新的服务是可用的。比如把主要的有界上下文的实体的ID引入 进来,这些实体要么是我们与事件通信的事实的一个组成部分,要么与之相关。新的微服务需要涵盖很多的实体,当然,这会打破“迪米特法则”,但这是必要的妥协。软件架构的要义即在于此:做出恰当的权衡以达成尽量好的系统。遵循开闭原则的能力是如此的重要而有意义,从某种程度上讲,我们可以为此不惜违背“迪米特法则”。

五、总结

1、事件驱动系统给了我们很好的机会来在架构层级应用开闭原则。我们可以重用已有的代码,并且在未知的方向上实现功能的扩展。

2、然而,需要谨慎的设计事件的内容,同时警惕糟糕的设计可能引入的耦合的可能性。

3、要根据系统的目标来指导架构设计,为某一目标设计某种适用的架构(如,为大数据系统设计的流式数据)很可能对于另一目标来说是糟糕的设计(不适用于表征事实发生的事件驱动系统)。

4、领域驱动设计的有界上下文可以为事件内容的设计提供一些指导。

5、架构是关于决策和权衡,最大化应用开闭原则很可能意味着对“迪米特法则”的最小化遵循,必须谨小慎微地寻找一个平衡点。

关于EAWorld:微服务,DevOps,数据治理,移动架构原创技术分享

标签: #订阅者和发布者是什么关系呢