分布式通信协议

快来打我* 2022-06-09 07:00 367阅读 0赞

## 分布式基础通信协议:paxos,totem和gossip ##

### 背景： ###

在分布式中，最难解决的一个问题就是多个节点间数据同步问题。为了解决这样的问题，涌现出了各种奇思妙想。只有在解决了如何进行信息同步的基础之上才衍生出形形色色的应用。这里开始介绍几种分布式通信协议。

### 简单即有效——totem协议: ###

totem协议也许你还比较陌生，但是corosync就是totem协议的一个开源实现。比较火的HA软件pacemaker就是基于corosync来提供各种服务的。

说起totem协议，最简单的形象就是，他将多个节点组成一个**令牌环**。多个节点手拉手形成一个圈，大家依次的传递token。只有获取到token的节点才有发送消息的权利。简单有效的解决了在分布式系统中各个节点的同步问题，因为只有一个节点会在一个时刻发送消息，不会出现冲突。当然，如果有节点发生意外时，令牌环就会断掉，此时大家不能够通信，而是重新组建出一个新的令牌环。

### 进化的二段提交——paxos协议： ###

说起paxos，需要稍微提提二段提交。简单来说，二阶段提交就是

一个节点询问其他节点，我是不是可以进行消息提交。

如果收到所有人的同意，则告诉大家，开始提交吧。

这个协议在实际中并不能很好的解决分布式中信息同步问题。例如只要有节点失效，就会发生得不到所有人同意的结果，在超时后，这一次提交失败，等一系列问题。但是paxos在对二段提交进行了优化后，得到了一个比较好的解决办法。

paxos协议引入了**多数派**，以及消息编号的概念。在1准备时，询问2/n+1的参与者，要求他们保证不会接受小于编号n的提交。如果得到了2/n+1的回复，则可以开始告诉2/n+1的参与者进行消息的提交。

可以明显的看出，这就是对二段提交的一个优化版。就是这么一个比较巧妙的思想，解决了一些二阶段提交带来的问题。

顺便说一句，这个协议的作者LeslieLamport。他获得2013年图灵奖。

### 奇思妙想——gossip协议： ###

gossip协议是一个神奇的协议。它常用于P2P的通信协议，这个协议就是模拟人类中**传播谣言**的行为而来。

简单的描述下这个协议，首先要传播谣言就要有种子节点。种子节点每秒都会随机向其他节点发送自己所拥有的节点列表，以及需要传播的消息。任何新加入的节点，就在这种传播方式下很快地被全网所知道。

这个协议的神奇就在于它从设计开始就没想到信息一定要传递给所有的节点，但是随着时间的增长，在最终的某一时刻，全网会得到相同的信息。当然这个时刻可能仅仅存在于理论，永远不可达。

### 基础协议的对比： ###

简单的介绍了这几种协议，下面我们来看看他们的对比：

<table style="margin:auto auto auto -0.05pt"> 
 <tbody> 
 <tr style="height:13.5pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:13.5pt; background-color:transparent"> 基础协议 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:13.5pt; background-color:transparent"> paxos </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:13.5pt; background-color:transparent"> totem </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:13.5pt; background-color:transparent"> gossip </td> 
 </tr> 
 <tr style="height:364.5pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:364.5pt; background-color:transparent"> 数据同步 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:364.5pt; background-color:transparent"> 第一阶段： &nbsp; proposer 选择一个提案编号 n 并将 prepare请求发送给acceptors 中的一个多数派；acceptor收到 prepare 消息后，如果提案的编号大于它已经回复的所有 prepare消息，则 acceptor 将自己上次的批准回复给 proposer并承诺不再批准小于 n的提案。 第二阶段： 当一个 proposor 收到了多数 acceptors 对 prepare 的回复后，就进入批准阶段。它要向回复 prepare请求的acceptors 发送 accept 请求，包括编号 n 和根据 P2c 决定的 value（如果根据 P2c没有决定 value，那么它可以自由决定 value）。在不违背自己向其他 proposer的承诺的前提下，acceptor 收到 accept 请求后即批准这个请求。 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:364.5pt; background-color:transparent"> 1.通信方式。 当集群有节点要发起通信时，需要等待token。当拿到token后，先广播这次需要发送的数据，然后传递token来确认所有人都接收到消息。 如果确认成功，释放token。 2.节点的加入和退出。 当集群中有节点加入时，加入的节点广播一个加入信息，所有人都开始广播自己的信息，当所有人都获得同伴信息，开始由id最小的人提交一个token，交由所有节点确认。 如果都确认后，则节点正式加入，开始正常运行。 当集群有节点退出时，由于令牌环断链，触发token超时，则同样开始广播信息，然后由最小id提交token，经过确认后恢复正常。 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:364.5pt; background-color:transparent"> gossip协议有多种实现，这里说一个例子当节点启动时，读配置文件，然后向一个seed发送信息，进行信息同步，然后开始没秒都随机选择一个seed节点来同步信息 1、随机取一个当前活着的节点，并向它发送同步请求 2、向随机一台不可达的机器发送同步请求 3、如果第一步中所选择的节点不是seed，或者当前活着的节点数少于seed数，则向随意一台seed发送同步请求 </td> 
 </tr> 
 <tr style="height:13.5pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:13.5pt; background-color:transparent"> 数据一致性&nbsp; </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:13.5pt; background-color:transparent"> 强一致性 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:13.5pt; background-color:transparent"> 强一致性 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:13.5pt; background-color:transparent"> 最终一致性 </td> 
 </tr> 
 <tr style="height:13.5pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:13.5pt; background-color:transparent"> 相关应用 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:13.5pt; background-color:transparent"> zookeeper </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:13.5pt; background-color:transparent"> corosync </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:13.5pt; background-color:transparent"> Cassandra </td> 
 </tr> 
 <tr style="height:40.5pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:40.5pt; background-color:transparent"> 优点 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:40.5pt; background-color:transparent"> 可以很好的解决通信一致性问题，在集群规模上比corosync要略大一些 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:40.5pt; background-color:transparent"> 简单方便，按照协议实现后就可以直接使用 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:40.5pt; background-color:transparent"> 协议本身简单，组网规模几乎不受限制，通信性能好 </td> 
 </tr> 
 <tr style="height:27pt"> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:41.95pt; height:27pt; background-color:transparent"> 缺点 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:180.25pt; height:27pt; background-color:transparent"> 理论性太强，如果要实际使用，还是需要进行优化 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:159.95pt; height:27pt; background-color:transparent"> 使用了广播包，对于跨域传送有影响，而且令牌环本身带来的问题使得组网规模不大 </td> 
 <td style="padding:0.75pt; border:rgb(0,0,0); width:123.1pt; height:27pt; background-color:transparent"> 不能提供传统的数据一致性服务，在传输中占用较多的网络流量 </td> 
 </tr> 
 </tbody> 
</table>