ELK性能优化实战总结：kafka消费者分区分配策略

蔚落 2021-07-20 13:39 415阅读 0赞

# 背景知识 #

## CAP定理 ##

CAP定理，又被叫作布鲁尔定理。对于设计分布式系统来说(不仅仅是分布式事务)的架构师来说，CAP就是你的入门理论。

• C (一致性):对某个指定的客户端来说，读操作能返回最新的写操作。对于数据分布在不同节点上的数据上来说，如果在某个节点更新了数据，那么在其他节点如果都能读取到这个最新的数据，那么就称为强一致，如果有某个节点没有读取到，那就是分布式不一致。

• A (可用性)：非故障的节点在合理的时间内返回合理的响应(不是错误和超时的响应)。可用性的两个关键一个是合理的时间，一个是合理的响应。合理的时间指的是请求不能无限被阻塞，应该在合理的时间给出返回。合理的响应指的是系统应该明确返回结果并且结果是正确的，这里的正确指的是比如应该返回50，而不是返回40。

• P (分区容错性):当出现网络分区后，系统能够继续工作。打个比方，这里个集群有多台机器，有台机器网络出现了问题，但是这个集群仍然可以正常工作。

## BASE理论 ##

BASE 理论指的是基本可用 Basically Available，软状态 Soft State，最终一致性 Eventual Consistency，核心思想是即便无法做到强一致性，但应该采用适合的方式保证最终一致性，是对CAP中AP的一个扩展。

BASE，Basically Available Soft State Eventual Consistency 的简写：

BA：Basically Available 基本可用，分布式系统在出现故障的时候，允许损失部分可用性，即保证核心可用。

S：Soft State 软状态，允许系统存在中间状态，而该中间状态不会影响系统整体可用性。

E：Consistency 最终一致性，系统中的所有数据副本经过一定时间后，最终能够达到一致的状态。

BASE 理论本质上是对 CAP 理论的延伸，是对 CAP 中 AP 方案的一个补充。

## 柔性事务 ##

不同于 ACID 的刚性事务，在分布式场景下基于 BASE 理论，就出现了柔性事务的概念。要想通过柔性事务来达到最终的一致性，就需要依赖于一些特性，这些特性在具体的方案中不一定都要满足，因为不同的方案要求不一样；但是都不满足的话，是不可能做柔性事务的。

## 幂等操作 ##

在编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数，或幂等方法，是指可以使用相同参数重复执行，并能获得相同结果的函数。这些函数不会影响系统状态，也不用担心重复执行会对系统造成改变。例如，支付流程中第三方支付系统告知系统中某个订单支付成功，接收该支付回调接口在网络正常的情况下无论操作多少次都应该返回成功。

## 为什么需要分布式事务 ##

随着业务的发展及服务的SOA化，一些大的操作往往由不同的小操作组成，而这些小的操作分布在不同的服务器上，分布式事务需要保证这些小操作要么全部成功，要么全部失败。从本质上来说，分布式事务是为了保证不同数据库的数据一致性。可能应用分布式事务的场景有：

1.  数据库分库分表

当数据库单表数据达到千万级别，就要考虑分库分表，那么就会从原来的一个数据库变成多个数据库。例如如果一个操作即操作了01库，又操作了02库，而且又要保证数据的一致性，那么就要用到分布式事务。

1.  应用SOA化

所谓的SOA化，就是业务的服务化。例如电商平台下单操作就会产生调用库存服务扣减库存和订单服务更新订单数据，那么就会设计到订单数据库和库存数据库，为了保证数据的一致性，就需要用到分布式事务。

# 两套协议、四类常见方案 #

两套协议是指两阶段提交协议2PC和三阶段提交协议3PC

四类常见方案这里我们介绍以下分布式事务解决方案：Tcc、可靠消息最终一致性、最大努力通知、Saga

## 两套协议 ##

### 两阶段提交协议2PC ###

**两阶段提交（2PC）** 是 Oracle Tuxedo 系统提出的 XA 分布式事务协议的其中一种实现方式。

XA协议中有两个重要角色：**事务协调者**和**事务参与者**

#### 漫话图解 ####

2PC协议有两个阶段：Propose和Commit. **在无failure情况下**的2PC协议流程的画风是这样的:

• Propose阶段:

￮ coordinator: “昨夜验人有惊喜, 今天都投票出六娃”

￮ voter1/voter2/voter3: “好的女王大人!”

• Commit阶段

￮ coordinator: “投六娃”

￮ voter1/voter2/voter3: “投了女王大人!” (画外音: 六娃扑街)

![dc3fe81aaca88e3d7ff852c38317ecd4.png][]

图1: 2PC, coordinator提议通过, voter\{1,2,3\}达成新的共识

如果有至少一个voter (比如voter3)在Propose阶段投了反对票, 那么propose通过失败. coordinator就会在Commit(or abort)阶段跟所有voter说, 放弃这个propose.

![31ba035dc559463294641c589975fa8e.png][]

图2: 2PC, coordinator提议没有通过, voter\{1,2,3\}保持旧有的共识

#### 具体流程 ####

分布式事务中2PC的具体流程是这样的：

**第一阶段**

• 顺利的情况

1.  事务协调者的节点会首先向所有的参与者节点发送 Prepare(预备) 请求。
2.  在接到 Prepare(预备) 请求之后，每一个参与者节点会各自执行与事务有关的数据更新，写入Undo Log和Redo Log。
3.  参与者执行成功，暂时不提交事务，向事务协调节点返回done(完成)消息。
4.  进入第二阶段

• 出错时

在XA的第一阶段，如果某个事务参与者反馈失败消息，说明该节点的本地事务执行不成功，必须回滚。

1.  事务协调者的节点会首先向所有的参与者节点发送 Prepare(预备) 请求。
2.  在接到 Prepare(预备) 请求之后，每一个参与者节点会各自执行与事务有关的数据更新，写入Undo Log和Redo Log。
3.  参与者执行失败，返回失败消息。
4.  协调者中断事务

**中断事务**

任何一个参与者向协调者反馈了 No 响应，或者在等待超时之后，协调者尚无法接收到所有参与者的反馈响应，那么就会中断事物。

1.  发送回滚请求。协调者向所有参与者节点发出 Rollback 请求。
2.  事物回滚。参与者收到Rollback请求之后，会利用其在阶段一种记录的 Undo 信息来执行事务回滚操作，并在完成回滚之后释放在整个事物执行期间占用的资源。
3.  反馈事物回滚结果。参与者在完成事物回滚之后，向协调者发送 Ack 消息。
4.  中断事务

**第二阶段**

在XA分布式事务的第二阶段，如果事务协调节点在之前所收到都是正向返回，那么它将会向所有事务参与者发出Commit请求。

接到Commit请求之后，事务参与者节点会各自进行本地的事务提交，并释放锁资源。当本地事务完成提交后，将会向事务协调者返回“完成”消息。

当事务协调者接收到所有事务参与者的“完成”反馈，整个分布式事务完成。

**优缺点**

**优点**

2PC是强一致（要打个问号）协议：

1.  预备、提交两个阶段保证了事务是原子的
2.  2PC是允许读-写隔离的，这意味着某个字段的变更在事务协调者提交之前是不可见的。

**缺点**

1.  同步阻塞：当参与事务者存在占用公共资源的情况，其中一个占用了资源，其他事务参与者就只能阻塞等待资源释放，处于阻塞状态。
2.  单点故障：一旦事务管理器出现故障，整个系统不可用
3.  数据不一致：在阶段二，如果事务管理器只发送了部分 commit 消息，此时网络发生异常，那么只有部分参与者接收到 commit 消息，也就是说只有部分参与者提交了事务，使得系统数据不一致。
4.  不确定性：当协事务管理器发送 commit 之后，并且此时只有一个参与者收到了 commit，那么当该参与者与事务管理器同时宕机之后，重新选举的事务管理器无法确定该条消息是否提交成功。

### 三阶段提交协议3PC ###

#### **漫话图解** ####

简单的说来, 3PC就是把2PC的Commit阶段拆成了PreCommit和Commit两个阶段. 通过进入增加的这一个PreCommit阶段, voter可以得到Propose阶段的投票结果, 但不会commit; 而通过进入Commit阶段, voter可以盘出其他每个voter也都打算commit了, 从而可以放心的commit.

**换言之**, 3PC在2PC的Commit阶段里增加了一个barrier(即相当于告诉其他所有voter, 我收到了Propose的结果啦). 在这个barrier之前coordinator掉线的话, 其他voter可以得出结论不是每个voter都收到Propose Phase的结果, 从而放弃或选出新的coordinator; 在这个barrier之后coordinator掉线的话, 每个voter会放心的commit, 因为他们知道其他voter也都做同样的计划.

![923d1ae1f9f9bed17b89671ffed6d071.png][]

图3: 3PC, coordinator提议通过, voter\{1,2,3\}达成新的共识

#### **具体流程** ####

**阶段一** **CanCommit**

1.  事务询问：Coordinator 向各参与者发送 CanCommit 的请求，询问是否可以执行事务提交操作，并开始等待各参与者的响应；
2.  参与者向 Coordinator 反馈询问的响应：参与者收到 CanCommit 请求后，正常情况下，如果自身认为可以顺利执行事务，那么会反馈 Yes 响应，并进入预备状态，否则反馈 No。

**阶段二** **PreCommit**

**执行事务预提交**：如果 Coordinator 接收到各参与者反馈都是Yes，那么执行事务预提交：

1.  发送预提交请求：Coordinator 向各参与者发送 preCommit 请求，并进入 prepared 阶段；
2.  事务预提交：参与者接收到 preCommit 请求后，会执行事务操作，并将 Undo 和 Redo 信息记录到事务日记中；
3.  各参与者向 Coordinator 反馈事务执行的响应：如果各参与者都成功执行了事务操作，那么反馈给协调者 ACK 响应，同时等待最终指令，提交 commit 或者终止 abort，结束流程；

**中断事务**：如果任何一个参与者向 Coordinator 反馈了 No 响应，或者在等待超时后，Coordinator 无法接收到所有参与者的反馈，那么就会中断事务。

1.  发送中断请求：Coordinator 向所有参与者发送 abort 请求；
2.  中断事务：无论是收到来自 Coordinator 的 abort 请求，还是等待超时，参与者都中断事务。

**阶段三** **doCommit**

**执行提交**

1.  发送提交请求：假设 Coordinator 正常工作，接收到了所有参与者的 ack 响应，那么它将从预提交阶段进入提交状态，并向所有参与者发送 doCommit 请求；
2.  事务提交：参与者收到 doCommit 请求后，正式提交事务，并在完成事务提交后释放占用的资源；
3.  反馈事务提交结果：参与者完成事务提交后，向 Coordinator 发送 ACK 信息；
4.  完成事务：Coordinator 接收到所有参与者 ack 信息，完成事务。

**中断事务**：假设 Coordinator 正常工作，并且有任一参与者反馈 No，或者在等待超时后无法接收所有参与者的反馈，都会中断事务

1.  发送中断请求：Coordinator 向所有参与者节点发送 abort 请求；
2.  事务回滚：参与者接收到 abort 请求后，利用 undo 日志执行事务回滚，并在完成事务回滚后释放占用的资源；
3.  反馈事务回滚结果：参与者在完成事务回滚之后，向 Coordinator 发送 ack 信息；
4.  中断事务：Coordinator 接收到所有参与者反馈的 ack 信息后，中断事务。

**优缺点**

• 优化单点故障：相比二阶段提交，三阶段提交降低了阻塞范围，在等待超时后协调者或参与者会中断事务。避免了协调者单点问题。阶段 3 中协调者出现问题时，参与者会继续提交事务。

• 一致性问题：

## **四种方案** ##

### **Saga** ###

1987年普林斯顿大学的Hector Garcia-Molina和Kenneth Salem发表了一篇Paper Sagas，讲述的是如何处理long lived transaction（长活事务）。Saga是一个长活事务可被分解成可以交错运行的子事务集合。其中每个子事务都是一个保持数据库一致性的真实事务。

分布式事务执行过程中，依次执行各参与者的正向操作，如果所有正向操作均执行成功，那么分布式事务提交。如果任何一个正向操作执行失败，那么分布式事务会去退回去执行前面各参与者的逆向回滚操作，回滚已提交的参与者，使分布式事务回到初始状态。

![dd5dad5057c5292d691d61007c8ec54d.png][]

Saga 模式用一种非常纯朴的方式来处理一致性：补偿。上图左侧是正常的事务流程，当执行到 T3 时发生了错误，则开始执行右边的事务补偿流程，反向执行T3、T2、T1 的补偿服务，其中 C3 是 T3 的补偿服务、C2 是 T2 的补偿服务、C1 是 T1 的补偿服务，将T3、T2、T1 已经修改的数据补偿掉。

### **Tcc** ###

TCC是Try、Confirm、Cancel三个词语的缩写，TCC要求每个分支事务实现三个操作:预处理Try、确认Confirm、撤销Cancel。

• Try操作做业务检查及资源预留，

• Confirm做业务确认操作，

• Cancel实现一个与Try相反的操作即回滚操作。

TM首先发起所有的分支事务的try操作，任何一个分支事务的try操作执行失败，TM将会发起所有分支事务的Cancel操作，若try操作全部成功，TM将会发起所有分支事务的Confirm操作，其中Confirm/Cancel 操作若执行失败，TM会进行重试。

![54c4342d1f6e1113fab85ce0e3ca8cdb.png][]

分支事务失败的情况:

![f22a524432b9f8dff89d3759e3fa45d7.png][]

TCC分为三个阶段:

1.  Try 阶段是做业务检查(一致性)及资源预留(隔离)，此阶段仅是一个初步操作，它和后续的Confirm 一起才能 真正构成一个完整的业务逻辑。
2.  Confirm 阶段是做确认提交，Try阶段所有分支事务执行成功后开始执行 Confirm。通常情况下，采用TCC则 认为 Confirm阶段是不会出错的。即:只要Try成功，Confirm一定成功。若Confirm阶段真的出错了，需引 入重试机制或人工处理。
3.  Cancel 阶段是在业务执行错误需要回滚的状态下执行分支事务的业务取消，预留资源释放。通常情况下，采 用TCC则认为Cancel阶段也是一定成功的。若Cancel阶段真的出错了，需引入重试机制或人工处理。

TM事务管理器可以实现为独立的服务，也可以让全局事务发起方充当TM的角色，TM独立出来是为了成为公用组件，是为了考虑系统结构和软件复用。

TM在发起全局事务时生成全局事务记录，全局事务ID贯穿整个分布式事务调用链条，用来记录事务上下文， 追踪和记录状态，由于Confirm 和cancel失败需进行重试，因此需要实现为幂等，幂等性是指同一个操作无论请求 多少次，其结果都相同。

### **可靠消息最终一致性** ###

可靠消息最终一致性方案是指当事务发起方执行完成本地事务后并发出一条消息，事务参与方(消息消费者)一定能够接收消息并处理事务成功，此方案强调的是只要消息发给事务参与方最终事务要达到一致。

此方案是利用消息中间件完成，如下图:

![bff2fe3bea2d8aaf7e00e5b73a449d4b.png][]

事务发起方(消息生产方)将消息发给消息中间件，事务参与方从消息中间件接收消息，事务发起方和消息中间件之间，事务参与方(消息消费方)和消息中间件之间都是通过网络通信，由于网络通信的不确定性会导致分布式事务问题。

因此可靠消息最终一致性方案要解决以下几个问题:

1.  本地事务与消息发送的原子性问题

本地事务与消息发送的原子性问题即:事务发起方在本地事务执行成功后消息必须发出去，否则就丢弃消息。即实现本地事务和消息发送的原子性，要么都成功，要么都失败。本地事务与消息发送的原子性问题是实现可靠消息最终一致性方案的关键问题。

**面试资料整理汇总**

![成功从小公司跳槽进蚂蚁定级P7，只因刷了七遍这些面试真题][P7]

![成功从小公司跳槽进蚂蚁定级P7，只因刷了七遍这些面试真题][P7 1]

这些面试题是我朋友进阿里前狂刷七遍以上的面试资料，由于面试文档很多，内容更多，没有办法一一为大家展示出来，所以只好为大家节选出来了一部分供大家参考，需要全部文档的，关注小编后，[点击这里即可免费领取][Link 1]。

面试的本质不是考试，而是告诉面试官你会做什么，所以，这些面试资料中提到的技术也是要学会的，不然稍微改动一下你就凉凉了

外链图片转存中…(img-bwSBgUvD-1625732829800)\]

\[外链图片转存中…(img-yl6xde9i-1625732829800)\]

面试的本质不是考试，而是告诉面试官你会做什么，所以，这些面试资料中提到的技术也是要学会的，不然稍微改动一下你就凉凉了

**在这里祝大家能够拿到心仪的offer！**

[dc3fe81aaca88e3d7ff852c38317ecd4.png]: /images/20210720/193155ca3da2460597971ecdd8fe7f40.png
[31ba035dc559463294641c589975fa8e.png]: /images/20210720/ce74465bf2b14f10a6d2ee3244ae36c3.png
[923d1ae1f9f9bed17b89671ffed6d071.png]: /images/20210720/b62067563a614909841a82d78b77c8bc.png
[dd5dad5057c5292d691d61007c8ec54d.png]: /images/20210720/fceadde0ffde4f35a3ba879d7c5ca4a6.png
[54c4342d1f6e1113fab85ce0e3ca8cdb.png]: /images/20210720/162eb30a4e5e41be8cf9d062272a9f02.png
[f22a524432b9f8dff89d3759e3fa45d7.png]: /images/20210720/2b503bb694814616bbf1b719aff2dfea.png
[bff2fe3bea2d8aaf7e00e5b73a449d4b.png]: /images/20210720/3da71b0620674d56ab9ccf7c1b92b080.png
[P7]: /images/20210720/4b462932317544569d69052ec3b6538a.png
[P7 1]: /images/20210720/ff0ef1f6aa9a40e79f27ba2d3b79018c.png
[Link 1]: https://gitee.com/vip204888/java-p7