两阶段提交(Two-phase Commit)协议

2024-03-23 19:20

本文主要是介绍两阶段提交(Two-phase Commit)协议,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、简介

两阶段提交Two-phase Commit(2PC)协议是一种分布式一致性(consistency)协议,常被用于分布式系统中,用于保证各个参与节点数据一致性,即各节点事务一致性,即分布式系统整体事务原子性(atomic)。简单来说,就是分布式系统中的所有参与者,对于请求的事务要不所有参与者都提交,要不所有参与者都回退。两阶段提交 (2PC) 是一个标准协议用于原子性(atomic)提交(commit)和终止(abort)。

二、相关术语

Coordinator 协调事务提交的组件
Participant 可以被事务T访问的资源管理器(resource manager)
直到所有的Participant都准备好了提交,Coordinator才会决定提交;最终的目标是要么在所有资源管理器上提交,要么在所有资源管理器上终止

三、两阶段提交协议

阶段一 (phase 1)

1、 coordinator 发送Request-to-Prepare 消息到每一个 participant
2、 coordinator 等待所有participant去投票(vote)
3、每个participant:
- 如果准备好了就会投票 Prepared
- 也会因为其他原因投票No
- 也许会延迟投票

阶段二 (phase 2)

1、如果coordinator 收到所有participant的Prepared消息,则会决定去提交该事务;否则会决定终止该事务
2、coordinator 发送他的决定到每一个participant(Commit or Abort)
3、participant通过回复Done来确认收到的Commit 或者Abort

在决定被做之前,2PC需要3轮消息通信

  • Request-to-prepare
  • Votes
  • Decision
    Done消息只是为了做登记使用,不会影响响应时间,可以批量处理。
    相关流程如下:
    在这里插入图片描述

四、Uncertainty (2PC中的不确定性) 和 Failure Handling

1、coordinator 发送Request-to-Prepare 消息到participant 超时(timeout),即coordinator 无法连接participant
coordinator 会中断(放弃)该事务
2、coordinator等待participant 的投票超时
coordinator 会中断(放弃)该事务
3、在投票前,参与者可以单方面中止投票
4、在participant 投票Prepared之后,在接收到Commit之前,这段时间因各种原因,比如网络中断、coordinator 故障等,是最不确定的,它不能单方面提交或中止事务,
在这里插入图片描述
这种情况该如何解决呢?
首先该participant 是blocked(阻塞的),可以设置当这种情况出现时的应急处理方案,比如一直阻塞,直到收到Commit。

五、优缺点

优点

1、逻辑简单,实现简单
2、保证分布式事务原子性

缺点

1、在事务提交之前,资源都会处于被锁状态,这应该属于事务的特点不应该算是缺点
2、性能问题
因为协调者要等到所有参与者都投票之后才会做决定,耗时较高,会影响性能;
3、单节点故障
由于协调者的重要性,一旦协调者发生故障。参与者会一直阻塞下去。尤其在第二阶段,协调者发生故障,那么所有的参与者还都处于锁定事务资源的状态中,而无法继续完成事务操作。(虽然协调者挂掉,可以重新选举一个协调者,但是无法解决因为协调者宕机导致的参与者处于阻塞状态的问题)

六、单点问题的两种情况

1、协调者发起COMMIT之前

(1) 协调者正常,参与者宕机

​ 由于协调者无法收集到所有参与者 的反馈,会陷入阻塞情况。
解决方案: 引入超时机制,如果协调者在超过指定的时间还没有收到参与者的反馈,事务就失败,向所有节点发送终止事务请求。

(2) 协调者宕机,参与者正常

无论处于哪个阶段,由于协调者宕机,无法发送提交请求,所有处于执行了操作但是未提交状态的参与者都会陷入阻塞情况;也可以在剩余参与者中重新选择一个协调者用于协调
解决方案:引入协调者备份,同时协调者需记录操作日志.当检测到协调者宕机一段时间后,协调者备份取代协调者,并读取操作日志,向所有参与者询问状态。

(3) 协调者宕机,参与者宕机

在剩余参与者中重新选择一个协调者用于协调。

2、协调者发起COMMIT之后

(1) 协调者正常,参与者宕机

​ 由于协调者无法收集到所有参与者 的反馈,会陷入阻塞情况。
解决方案: 引入超时机制,如果协调者在超过指定的时间还没有收到参与者的反馈,事务就失败,向所有节点发送终止事务请求。

(2) 协调者宕机,参与者正常

解决方案:引入协调者备份,同时协调者需记录操作日志.当检测到协调者宕机一段时间后,协调者备份取代协调者,并读取操作日志,向所有参与者询问状态。

(3) 协调者宕机,参与者宕机

这种情况可能会造成数据不一致的情况,2PC无法解决该类问题。

引用

CSE593 Transaction Processing

这篇关于两阶段提交(Two-phase Commit)协议的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/839288

相关文章

作业提交过程之HDFSMapReduce

作业提交全过程详解 (1)作业提交 第1步:Client调用job.waitForCompletion方法,向整个集群提交MapReduce作业。 第2步:Client向RM申请一个作业id。 第3步:RM给Client返回该job资源的提交路径和作业id。 第4步:Client提交jar包、切片信息和配置文件到指定的资源提交路径。 第5步:Client提交完资源后,向RM申请运行MrAp

【Linux】应用层http协议

一、HTTP协议 1.1 简要介绍一下HTTP        我们在网络的应用层中可以自己定义协议,但是,已经有大佬定义了一些现成的,非常好用的应用层协议,供我们直接使用,HTTP(超文本传输协议)就是其中之一。        在互联网世界中,HTTP(超文本传输协议)是一个至关重要的协议,他定义了客户端(如浏览器)与服务器之间如何进行通信,以交换或者传输超文本(比如HTML文档)。

HTML提交表单给python

python 代码 from flask import Flask, request, render_template, redirect, url_forapp = Flask(__name__)@app.route('/')def form():# 渲染表单页面return render_template('./index.html')@app.route('/submit_form',

Python3 BeautifulSoup爬虫 POJ自动提交

POJ 提交代码采用Base64加密方式 import http.cookiejarimport loggingimport urllib.parseimport urllib.requestimport base64from bs4 import BeautifulSoupfrom submitcode import SubmitCodeclass SubmitPoj():de

查看提交历史 —— Git 学习笔记 11

查看提交历史 查看提交历史 不带任何选项的git log-p选项--stat 选项--pretty=oneline选项--pretty=format选项git log常用选项列表参考资料 在提交了若干更新,又或者克隆了某个项目之后,你也许想回顾下提交历史。 完成这个任务最简单而又有效的 工具是 git log 命令。 接下来的例子会用一个用于演示的 simplegit

form表单提交编码的问题

浏览器在form提交后,会生成一个HTTP的头部信息"content-type",标准规定其形式为Content-type: application/x-www-form-urlencoded; charset=UTF-8        那么我们如果需要修改编码,不使用默认的,那么可以如下这样操作修改编码,来满足需求: hmtl代码:   <meta http-equiv="Conte

js异步提交form表单的解决方案

1.定义异步提交表单的方法 (通用方法) /*** 异步提交form表单* @param options {form:form表单元素,success:执行成功后处理函数}* <span style="color:#ff0000;"><strong>@注意 后台接收参数要解码否则中文会导致乱码 如:URLDecoder.decode(param,"UTF-8")</strong></span>

【Go】go连接clickhouse使用TCP协议

离开你是傻是对是错 是看破是软弱 这结果是爱是恨或者是什么 如果是种解脱 怎么会还有眷恋在我心窝 那么爱你为什么                      🎵 黄品源/莫文蔚《那么爱你为什么》 package mainimport ("context""fmt""log""time""github.com/ClickHouse/clickhouse-go/v2")func main(

2024.9.8 TCP/IP协议学习笔记

1.所谓的层就是数据交换的深度,电脑点对点就是单层,物理层,加上集线器还是物理层,加上交换机就变成链路层了,有地址表,路由器就到了第三层网络层,每个端口都有一个mac地址 2.A 给 C 发数据包,怎么知道是否要通过路由器转发呢?答案:子网 3.将源 IP 与目的 IP 分别同这个子网掩码进行与运算****,相等则是在一个子网,不相等就是在不同子网 4.A 如何知道,哪个设备是路由器?答案:在 A

husky 工具配置代码检查工作流:提交代码至仓库前做代码检查

提示:这篇博客以我前两篇博客作为先修知识,请大家先去看看我前两篇博客 博客指路:前端 ESlint 代码规范及修复代码规范错误-CSDN博客前端 Vue3 项目开发—— ESLint & prettier 配置代码风格-CSDN博客 husky 工具配置代码检查工作流的作用 在工作中,我们经常需要将写好的代码提交至代码仓库 但是由于程序员疏忽而将不规范的代码提交至仓库,显然是不合理的 所