你好,我是蔡元楠。
今天我要与你分享的主题是CAP定理。
在分布式系统的两讲中,我们一起学习到了两个重要的概念:可用性和一致性。
而今天,我想和你讲解一个与这两个概念相关,并且在设计分布式系统架构时都会讨论到的一个定理——CAP定理(CAP Theorem)。
CAP定理
CAP这个概念最初是由埃里克·布鲁尔博士(Dr. Eric Brewer)在2000年的ACM年度学术研讨会上提出的。
如果你对这次演讲感兴趣的话,可以翻阅他那次名为“Towards Robust Distributed Systems”的演讲deck。
在两年之后,塞思·吉尔伯特(Seth Gilbert)和麻省理工学院的南希·林奇教授(Nancy Ann Lynch)在他们的论文“Brewer’s conjecture and the Feasibility of Consistent, Available, Partition-Tolerant Web Services”中证明了这一概念。

他们在这篇论文中证明了:在任意的分布式系统中,一致性(Consistency),可用性(Availability)和分区容错性(Partition-tolerance)这三种属性最多只能同时存在两个属性。
下面,我来为你解读一下这三种属性在这篇论文里的具体意思。
C属性:一致性
一致性在这里指的是线性一致性(Linearizability Consistency)。在线性一致性的保证下,所有分布式环境下的操作都像是在单机上完成的一样,也就是说图中Sever A、B、C的状态一直是一致的。

打个比方,现在有两个操作(Operation),操作A和操作B,都需要在同一个分布式系统上完成。
我们假设操作A作用在系统上的时候,所看见的所有系统状态(State)叫作状态A。而操作B作用在系统上的时候,所看见的所有系统状态叫作状态B。
如果操作A是在操作B之前发生的,并且操作A成功了。那么系统状态B必须要比系统状态A更加新。
可能光看理论的话你还是会觉得这个概念有点模糊,那下面我就以一个具体例子来说明吧。
假设我们设计了一个分布式的购物系统,在这个系统中,商品的存货状态分别保存在服务器A和服务器B中。我们把存货状态定义为“有货状态”或者“无货状态”。在最开始的时候,服务器A和服务器B都会显示商品为有货状态。

等一段时间过后,商品卖完了,后台就必须将这两台服务器上的商品状态更新为无货状态。
因为是在分布式的环境下,商品状态的更新在服务器A上完成了,显示为无货状态。而服务器B的状态因为网络延迟的原因更新还未完成,还是显示着有货状态。
这时,恰好有两个用户使用着这个购物系统,先后发送了一个查询操作(Query Operation)到后台服务器中查询商品状态。
我们假设是用户A先查询的,这个查询操作A被发送到了服务器A上面,并且成功返回了商品是无货状态的。用户B在随后也对同一商品进行查询,而这个查询操作B被发送到了服务器B上面,并且成功返回了商品是有货状态的。

我们知道,对于整个系统来说,商品的系统状态应该为无货状态。而操作A又是在操作B之前发送并且成功完成的,所以如果这个系统有线性一致性这个属性的话,操作B所看到的系统状态理论上应该是无货状态。
但在我们这个例子中,操作B却返回了有货状态。所以我们说,这个分布式的购物系统并不满足论文里所讲到的线性一致性。
聊完了一致性,我们一起来看看可用性的含义。
A属性:可用性
可用性的概念比较简单,在这里指的是在分布式系统中,任意非故障的服务器都必须对客户的请求产生响应。
当系统满足可用性的时候,不管出现什么状况(除非所有的服务器全部崩溃),都能返回消息。

也就是说,当客户端向系统发送请求,只要系统背后的服务器有一台还未崩溃,那么这个未崩溃的服务器必须最终响应客户端。
P属性:分区容错性
在了解了可用性之后,你还需要了解分区容错性。它分为两个部分,“分区”和“容错”。
在一个分布式系统里,如果出现一些故障,可能会使得部分节点之间无法连通。由于这些故障节点无法联通,造成整个网络就会被分成几块区域,从而使数据分散在这些无法连通的区域中的情况,你可以认为这就是发生了分区错误。

如图所示,如果你要的数据只在Sever A中保存,当系统出现分区错误,在不能直接连接Sever A时,你是无法获取数据的。我们要“分区容错”,意思是即使出现这样的“错误”,系统也需要能“容忍”。也就是说,就算错误出现,系统也必须能够返回消息。
分区容错性,在这里指的是我们的系统允许网络丢失从一个节点发送到另一个节点的任意多条消息。
我们知道,在现代网络通信中,节点出现故障或者网络出现丢包这样的情况是时常会发生的。
如果没有了分区容错性,也就是说系统不允许这些节点间的通讯出现任何错误的话,那我们日常所用到的很多系统就不能再继续工作了。
所以在大部分情况下,系统设计都会保留P属性,而在C和A中二选一。
论文中论证了在任意系统中,我们最多可以保留CAP属性中的两种,也就是CP或者AP或者CA。关于具体的论证过程,如果你感兴趣的话,可以自行翻阅论文查看。
你可能会问,在我们平常所用到的开发架构中,有哪些系统是属于CP系统,有哪些是AP系统又有哪些是CA系统呢?我来给你介绍一下:
- CP系统:Google BigTable, Hbase, MongoDB, Redis, MemCacheDB,这些存储架构都是放弃了高可用性(High Availablity)而选择CP属性的。
- AP系统:Amazon Dynamo系统以及它的衍生存储系统Apache Cassandra和Voldemort都是属于AP系统
- CA系统:Apache Kafka是一个比较典型的CA系统。
我在上面说过,P属性在现代网络时代中基本上是属于一个必选项,那为什么Apache Kafka会放弃P选择CA属性呢?我来给你解释一下它的架构思想。
放弃了P属性的Kafka Replication
在Kafka发布了0.8版本之后,Kafka系统引入了Replication的概念。Kafka Relocation通过将数据复制到不同的节点上,从而增强了数据在系统中的持久性(Durability)和可用性(Availability)。在Kafka Replication的系统设计中,所有的数据日志存储是设计在同一个数据中心(Data Center)里面的,也就是说,在同一个数据中心里网络分区出现的可能性是十分之小的。
它的具体架构是这样的,在Kafka数据副本(Data Replication)的设计中,先通过Zookeeper选举出一个领导者节点(Leader)。这个领导者节点负责维护一组被称作同步数据副本(In-sync-replica)的节点,所有的数据写入都必须在这个领导者节点中记录。
我来举个例子,假设现在数据中心有三台服务器,一台被选为作为领导者节点,另外两台服务器用来保存数据副本,分别是Replication1和Replication2,它们两个节点就是被领导者节点维护的同步数据副本了。领导者节点知道它维护着两个同步数据副本。
如果用户想写入一个数据,假设是“Geekbang”
-
用户会发请求到领导者节点中想写入“Geekbang”。
-
领导者节点收到请求后先在本地保存好,然后也同时发消息通知Replication1和Replication2。
-
Replication1和Replication2收到消息后也保存好这条消息并且回复领导者节点写入成功。
-
领导者节点记录副本1和副本2都是健康(Healthy)的,并且回复用户写入成功。
红色的部分是领导者节点本地日志,记录着有哪些同步数据副本是健康的。

往后用户如果想查询写入的数据,无论是领导者节点还是两个副本都可以返回正确同步的结果。
那假如分区出现了该怎么办呢?例如领导者节点和副本1无法通讯了,这个时候流程就变成这样了。
-
用户会发请求到领导者节点中想写入“Geekbang”。
-
领导者节点收到请求后先在本地保存好,然后也同时发消息通知Replication1和Replication2。
-
只有Replication2收到消息后也保存好这条消息并且回复领导者节点写入成功。
-
领导者节点记录副本2是健康的,并且回复用户写入成功。
同样,红色的部分是领导者节点本地日志,记录着有哪些同步数据副本是健康的。

如果所有副本都无法通讯的时候,Apache Kafka允许系统只有一个节点工作,也就是领导者节点。这个时候所有的写入都只保存在领导者节点了。过程如下,
-
用户会发请求到领导者节点中想写入“Geekbang”。
-
领导者节点收到请求后先在本地保存好,然后也同时发消息通知Replication1和Replication2。
-
没有任何副本回复领导者节点写入成功,领导者节点记录无副本是健康的,并且回复用户写入成功。

当然,在最坏的情况下,连领导者节点也挂了,Zookeeper会重新去寻找健康的服务器节点来当选新的领导者节点。
小结
通过今天的学习,我们知道在CAP定理中,一致性,可用性和分区容错性这三个属性最多只能选择两种属性保留。CAP定理在经过了差不多20年的讨论与演化之后,大家对这三个属性可能会有着自己的一些定义。
例如在讨论一致性的时候,有的系统宣称自己是拥有C属性,也就拥有一致性的,但是这个一致性并不是论文里所讨论到的线性一致性。
在我看来,作为大规模数据处理的架构师,我们应该熟知自己的系统到底应该保留CAP中的哪两项属性,同时也需要熟知,自己所应用到的平台架构是保留着哪两项属性。
思考题
如果让你重新设计微博系统中的发微博功能,你会选择CAP的哪两个属性呢?为什么呢?
欢迎你把答案写在留言区,与我和其他同学一起讨论。
如果你觉得有所收获,也欢迎把文章分享给你的朋友。
精选留言
2019-05-06 14:41:31
比如:在以下的场景序列下,会出现数据写入丢失的情况,所以不能说kafka是有P属性
前提:leader和两个slave 1、2
序列:
1.机器leader跟两个slave之间发生partion
这是leader成为唯一服务节点,继续接受写入请求w1,但是w1只保存在了leader机器上,无法复制到slave1和2
2.leader和zookeeper之间发生partition,导致kafka选取slave 1为新leader,新leader接受新写入w1
这时候,上面1的w1写入丢失了。即使之后旧leader复活,w1的写入数据也不会被恢复出来。
参考:https://bit.ly/2VGKtu1
2019-05-10 07:03:42
2019-05-06 08:13:04
但是从后面的解释来看,即使出现分区(领导者节点和副本1无法通讯),整个系统也能正常工作,这种行为难道不是保持了P属性吗。您能否举一个P属性被放弃的例子?
2019-05-06 09:22:19
疑问一,mongodb采用CP,那么它在可用性方面有做什么事情吗?
疑问二,kafka这种通过选举leader的方式不就是分区容错性吗?为什么说放弃了P呢?
2019-06-03 07:55:23
首先我们要明确如下的事实:
1)对于一个分布式系统而言,节点故障和网络故障属于常态
2)如果出现网络故障,会造成节点分区
3)分布式系统在存在节点分区的情况下,C和A是冲突的
通过上面的事实我们可以推断出,如果想设计出一个CA系统,必须保证网络不出现分区才有可能,怎样保证网络不出现分区呢,一是单台机器,二是像例子中所述,将所有节点放在同个数据中心中可以假定网络出现分区的概率很低。这也是为什么例子中的情况可以假装称为CA。
还有一些需要辅助理解CAP的知识如下:
1)对于分布式系统而言,最简单可以分为两种,一是所有节点通过都可以通过某种策略对外提供服务,是对等的,二是所有节点通过一个master对外提供服务,甚至是一个单点的master
2)探讨系统CAP的前提应该是系统在能提供服务的情况下的CAP,如果存在master单点,但是有很多从属worker的话,这时的可用性探讨需要划分为worker故障和master故障来看。对于文中的例子master如果挂掉系统不可用则表名A其实也是勉强的
CAP Theorem is like the old joke about software projects: you can have it on TIME, in BUDGET, or CORRECT. Pick any two😀
CAP三者互相制衡,应该是看侧重哪两个,而不是选了哪两个,不是两个100分剩下的一个0分,本质上都要兼顾的。
2019-05-06 14:59:40
2019-08-11 09:55:29
CP类型的团队对外的形象相当于:我的团队不是完美的,但我的产品绝对不会出问题,只要你给我足够的时间让我们把问题排查清楚。
AP类型的团队给人的感觉就是:人非圣贤,孰能无过,我的队员会犯错,我的团队也有估计不足的时候,但是客户的需求我们总会最快响应。
CA类型的团队有个强人领袖(leader节点):任何事务无论大小都过问一遍,一旦发现手下有人犯错,立马剔除出团队,如果自己犯错,让出领袖地位,整个团队一定要保证最快最好完成任务。
2019-05-28 11:57:01
但对于同时满足CA还请老师再解释一下。文档里说,可以config availability over durability,也可以反之。
如果选择availability的话,设置acks=all,可以保证isr里登记在册的broker都接收到信息,但isr里也可能只有leader一个。所以当leader挂了之后到再选出新leader期间就有数据丢失的可能性。
如果选择durability的话可以设置min_insync_replicas,但如果小于这个threshold的时候,不是得等着某个broker恢复,这样不就牺牲availabilty了吗?
所以,到底C和A是如何都满足的?
2019-05-06 11:28:33
2019-05-06 09:26:07
2019-09-26 10:41:41
2019-05-14 01:27:15
2019-05-12 15:06:47
是这样理解吗?
2019-05-12 00:48:13
C:客户访问集群中任一服务端,返回的状态都是一致的.
P:集群内部机器通讯出现问题导致服务A的数据无法同步到其他节点时,客户端访问服务A,服务A扔能返回未同步到其他节点的数据.
2019-05-11 14:32:32
2019-05-06 11:24:42
2019-05-06 08:25:19
2019-05-15 10:35:26
看到留言有人说,发微博保证最终一致性就好,不知道这个跟CAP的线性一致性是不是一个意思?
2019-05-10 13:46:41
我来举个例子说明吧。假设现在有一个由两个节点组成的集群,这两个节点都可以独立运作也可以与对方通讯,而客户端是与这个集群通讯的。作为一个集群来说,Availability指的是不管这两个节点哪一个节点坏掉不能运作了,对于客户端来说还是可以继续与这个集群进行通讯的。Partition Tolerance指得是,本来这两个节点可能是需要互相通讯来同步数据的,而因为Network Partition使得它们之间不能通讯了,但是对于客户端来说还是可以继续与这个集群进行通讯的。
按照您这样说,我疑惑的是:
1. 节点是所有节点,包括主节点吧?
2. 两个节点之间,如果有数据分别写入的话,那不就是数据不一致吗?
如果node1写入A数据,node2被写入B数据,怎同步?那数据不是乱套了?读也出现不一的情况
比如是金钱类的,不能是负数,我请求node1花完了,我刷新一下又访问到node2发现还是原来,我又花完了,那我不是可以花双倍?一同步那不是出错?同步不了,因为扣双倍,已小于0
3. 如果是CA的话,P出问题,不是出现不一致吗,那么我怎么保证C?
2019-05-08 23:16:21