微服务中间件--分布式事务

分布式事务

    • a.理论基础
      • 1) CAP定理
      • 2) BASE理论
    • b.Seata
      • 1) XA模式
        • 1.a) 实现XA模式
      • 2) AT模式
      • 3) TCC模式
        • 3.a) 代码实现
      • 4) Saga模式
      • 5) 四种模式对比
      • 6) TC的异地多机房容灾架构

a.理论基础

1) CAP定理

分布式系统有三个指标：

  • Consistency（一致性）: 用户访问分布式系统中的任意节点，得到的数据必须一致
  • Availability（可用性）: 用户访问集群中的任意健康节点，必须能得到响应，而不是超时或拒绝
  • Partition tolerance （分区容错性）
    • Partition(分区): 因为网络故障或其它原因导致分布式系统中的部分节点与其它节点失去连接，形成独立分区
    • tolerance(容错): 在集群出现分区时，整个系统也要持续对外提供服务

分布式系统无法同时满足这三个指标，这个结论就叫做 CAP 定理。

在这里插入图片描述

2) BASE理论

BASE理论是对CAP的一种解决思路，包含三个思想：

  • Basically Available （基本可用）：分布式系统在出现故障时，允许损失部分可用性，即保证核心可用
  • **Soft State（软状态）：**在一定时间内，允许出现中间状态，比如临时的不一致状态
  • **Eventually Consistent（最终一致性）：**虽然无法保证强一致性，但是在软状态结束后，最终达到数据一致

而分布式事务最大的问题是各个子事务的一致性问题，因此可以借鉴CAP定理和BASE理论：

  • AP模式：各子事务分别执行和提交，允许出现结果不一致，然后采用弥补措施恢复数据即可，实现最终一致
  • CP模式：各个子事务执行后互相等待，同时提交，同时回滚，达成强一致。但事务等待过程中，处于弱可用状态。

b.Seata

Seata是 2019 年 1 月份蚂蚁金服和阿里巴巴共同开源的分布式事务解决方案。致力于提供高性能和简单易用的分布式事务服务，为用户打造一站式的分布式解决方案。官网地址：http://seata.io/，其中的文档、播客中提供了大量的使用说明、源码分析。

Seata架构

Seata事务管理中有三个重要的角色：

  • TC (Transaction Coordinator) - 事务协调者：维护全局和分支事务的状态，协调全局事务提交或回滚
  • TM (Transaction Manager) - 事务管理器：定义全局事务的范围、开始全局事务、提交或回滚全局事务
  • RM (Resource Manager) - 资源管理器：管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚

Seata提供了四种不同的分布式事务解决方案：

  • XA模式：强一致性分阶段事务模式，牺牲了一定的可用性，无业务侵入
  • TCC模式：最终一致的分阶段事务模式，有业务侵入
  • AT模式：最终一致的分阶段事务模式，无业务侵入，也是Seata的默认模式
  • SAGA模式：长事务模式，有业务侵入

1) XA模式

XA模式原理

XA 规范 是 X/Open 组织定义的分布式事务处理（DTP，Distributed Transaction Processing）标准，XA 规范 描述了全局的TM与局部的RM之间的接口，几乎所有主流的数据库都对 XA 规范 提供了支持。

seata的XA模式：seata的XA模式做了一些调整，但大体相似：

RM一阶段的工作：

  • 1.注册分支事务到TC
  • 2.执行分支业务sql，但不提交
  • 3.报告执行状态到TC

TC二阶段的工作：

  • TC检测各分支事务执行状态
    • a.如果都成功，通知所有RM提交事务
    • b.如果有失败，通知所有RM回滚事务

RM二阶段的工作：

  • 接收TC指令，提交或回滚事务

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-1fBJtCFn-1692258967052)(C:\Users\captaindeng\AppData\Roaming\Typora\typora-user-images\image-20230816073154114.png)]

XA模式的优点是什么？

  • 事务的强一致性，满足ACID原则。
  • 常用数据库都支持，实现简单，并且没有代码侵入

XA模式的缺点是什么？

  • 因为一阶段需要锁定数据库资源，等待二阶段结束才释放，性能较差
  • 依赖关系型数据库实现事务

1.a) 实现XA模式

Seata的starter已经完成了XA模式的自动装配，实现非常简单，步骤如下：

1.修改application.yml文件（每个参与事务的微服务），开启XA模式：

seata:data-source-proxy-mode: XA

2.给发起全局事务的入口方法添加@GlobalTransactional注解，本例中是OrderServiceImpl中的create方法：

@Override
@GlobalTransactional
public Long create(Order order) {// 创建订单orderMapper.insert(order);// 扣余额 ...略 // 扣减库存 ...略return order.getId();
}

3.重启服务并测试

2) AT模式

AT模式原理

AT模式同样是分阶段提交的事务模型，不过缺弥补了XA模型中资源锁定周期过长的缺陷。

阶段一RM的工作：

  • 1.注册分支事务
  • 2.记录undo-log（数据快照）
  • 3.执行业务sql并提交
  • 4.报告事务状态

阶段二提交时RM的工作：

  • 删除undo-log即可

阶段二回滚时RM的工作：

  • 根据undo-log恢复数据到更新前

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-9Jhwpq0e-1692258967053)(C:\Users\captaindeng\AppData\Roaming\Typora\typora-user-images\image-20230816083429256.png)]

AT模式与XA模式最大的区别是什么？

  • XA模式一阶段不提交事务，锁定资源；AT模式一阶段直接提交，不锁定资源。
  • XA模式依赖数据库机制实现回滚；AT模式利用数据快照实现数据回滚。
  • XA模式强一致；AT模式最终一致

AT模式的存在脏写问题

AT模式的优点：

  • 一阶段完成直接提交事务，释放数据库资源，性能比较好
  • 利用全局锁实现读写隔离
  • 没有代码侵入，框架自动完成回滚和提交

AT模式的缺点：

  • 两阶段之间属于软状态，属于最终一致
  • 框架的快照功能会影响性能，但比XA模式要好很多

3) TCC模式

TCC模式原理

TCC模式与AT模式非常相似，每阶段都是独立事务，不同的是TCC通过人工编码来实现数据恢复。需要实现三个方法：

  • Try：资源的检测和预留
  • Confirm：完成资源操作业务；要求 Try 成功 Confirm 一定要能成功
  • Cancel：预留资源释放，可以理解为try的反向操作

在这里插入图片描述

在这里插入图片描述

TCC的优点是什么？

  • 一阶段完成直接提交事务，释放数据库资源，性能好
  • 相比AT模型，无需生成快照，无需使用全局锁，性能最强
  • 不依赖数据库事务，而是依赖补偿操作，可以用于非事务型数据库

TCC的缺点是什么？

  • 有代码侵入，需要人为编写try、Confirm和Cancel接口，太麻烦
  • 软状态，事务是最终一致
  • 需要考虑Confirm和Cancel的失败情况，做好幂等处理

3.a) 代码实现

案例：改造account-service服务，利用TCC实现分布式事务

需求如下：

  • 修改account-service，编写try、confirm、cancel逻辑
  • try业务：添加冻结金额，扣减可用金额
  • confirm业务：删除冻结金额
  • cancel业务：删除冻结金额，恢复可用金额
  • 保证confirm、cancel接口的幂等性
  • 允许空回滚
  • 拒绝业务悬挂

TCC的空回滚和业务悬挂

当某分支事务的try阶段阻塞时，可能导致全局事务超时而触发二阶段的cancel操作。在未执行try操作时先执行了cancel操作，这时cancel不能做回滚，就是空回滚。

对于已经空回滚的业务，如果以后继续执行try，就永远不可能confirm或cancel，这就是业务悬挂。应当阻止执行空回滚后的try操作，避免悬挂

在这里插入图片描述

在这里插入图片描述

声明TCC接口

TCC的Try、Confirm、Cancel方法都需要在接口中基于注解来声明，语法如下：

在这里插入图片描述

在Account-service中的service下定义接口

@LocalTCC
public interface AccountTCCService {@TwoPhaseBusinessAction(name = "deduct", commitMethod = "confirm", rollbackMethod = "cancel")void deduct(@BusinessActionContextParameter(paramName = "userId") String userId,@BusinessActionContextParameter(paramName = "money") int money);boolean confirm(BusinessActionContext ctx);boolean cancel(BusinessActionContext ctx);
}

在Account-service中的service的impl下实现该方法

@Service
@Slf4j
public class AccountTCCServiceImpl implements AccountTCCService {@Autowiredprivate AccountMapper accountMapper;@Autowiredprivate AccountFreezeMapper freezeMapper;@Override@Transactionalpublic void deduct(String userId, int money) {// 0.获取事务idString xid = RootContext.getXID();// 1.判断freeze中是否有冻结金额，如果有，一定是CANCEL执行过，要拒绝业务AccountFreeze oldFreeze = freezeMapper.selectById(userId);if (oldFreeze != null){// CANCEL执行过，要拒绝业务return;}// 1.扣减可用余额accountMapper.deduct(userId, money);// 2.记录冻结金额，记录事务状态AccountFreeze freeze = new AccountFreeze();freeze.setUserId(userId);freeze.setFreezeMoney(money);freeze.setState(AccountFreeze.State.TRY);freeze.setXid(xid);freezeMapper.insert(freeze);}@Overridepublic boolean confirm(BusinessActionContext ctx) {// 1.获取事务idString xid = ctx.getXid();// 2.根据事务id删除冻结记录int count = freezeMapper.deleteById(xid);return count == 1;}@Overridepublic boolean cancel(BusinessActionContext ctx) {// 0.查询冻结记录String xid = ctx.getXid();String userId = ctx.getActionContext("userId").toString();AccountFreeze freeze = freezeMapper.selectById(xid);// 1.空回滚的判断，判断freeze是否为null，为Null证明try没执行，需要空回滚if (freeze == null){// 证明try没执行，需要空回滚freeze = new AccountFreeze();freeze.setUserId(userId);freeze.setFreezeMoney(0);freeze.setState(AccountFreeze.State.CANCEL);freeze.setXid(xid);freezeMapper.insert(freeze);}// 2.幂等判断if (freeze.getState().equals(AccountFreeze.State.CANCEL)){// 已经处理过一次CANCEL，无需重复处理return true;}// 1.恢复可用余额accountMapper.refund(freeze.getUserId(), freeze.getFreezeMoney());// 2.将冻结金额清零，将状态改为CANCELfreeze.setFreezeMoney(0);freeze.setState(AccountFreeze.State.CANCEL);int count = freezeMapper.updateById(freeze);return count == 1;}
}

4) Saga模式

Saga模式是Seata提供的长事务解决方案。也分为两个阶段：

  • 一阶段：直接提交本地事务
  • 二阶段：成功则什么都不做；失败则通过编写补偿业务来回滚

Saga模式优点：

  • 事务参与者可以基于事件驱动实现异步调用，吞吐高
  • 一阶段直接提交事务，无锁，性能好
  • 不用编写TCC中的三个阶段，实现简单

缺点：

  • 软状态持续时间不确定，时效性差
  • 没有锁，没有事务隔离，会有脏写

在这里插入图片描述

5) 四种模式对比

XAATTCCSAGA
一致性强一致弱一致弱一致最终一致
隔离性完全隔离基于全局锁隔离基于资源预留隔离无隔离
代码侵入无无有，要编写三个接口有，要编写状态机和补偿业务
性能差好非常好非常好
场景对一致性、隔离性有高要求的业务基于关系型数据库的大多数分布式事务场景都可以对性能要求较高的事务。有非关系型数据库要参与的事务。业务流程长、业务流程多参与者包含其它公司或遗留系统服务，无法提供 TCC 模式要求的三个接口

6) TC的异地多机房容灾架构

TC服务作为Seata的核心服务，一定要保证高可用和异地容灾。

在这里插入图片描述

现在，将seata目录复制一份，起名为seata2

1.修改seata2/conf/registry.conf内容如下：

registry {# tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等type = "nacos"nacos {# seata tc 服务注册到 nacos的服务名称，可以自定义application = "seata-tc-server"serverAddr = "127.0.0.1:8848"group = "DEFAULT_GROUP"namespace = ""cluster = "HZ"username = "nacos"password = "nacos"}
}config {# 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置type = "nacos"# 配置nacos地址等信息nacos {serverAddr = "127.0.0.1:8848"namespace = ""group = "SEATA_GROUP"username = "nacos"password = "nacos"dataId = "seataServer.properties"}
}

进入seata2/bin目录，然后运行命令：

seata-server.bat -p 8092

打开nacos控制台，查看服务列表：

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-DnkkrX41-1692258967053)(F:\itheima\4.微服务开发框架\1.微服务开发框架\2.高级篇\day02-分布式事务\资料\assets\image-20210624151150840.png)]

点进详情查看：

image-20210624151221747

2.将事务组映射配置到nacos

接下来，我们需要将tx-service-group与cluster的映射关系都配置到nacos配置中心。

新建一个配置：

image-20210624151507072

配置的内容如下：

# 事务组映射关系
service.vgroupMapping.seata-demo=SHservice.enableDegrade=false
service.disableGlobalTransaction=false
# 与TC服务的通信配置
transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
# RM配置
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
# TM配置
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000# undo日志配置
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
client.log.exceptionRate=100

3.微服务读取nacos配置

接下来，需要修改每一个微服务的application.yml文件，让微服务读取nacos中的client.properties文件：

seata:config:type: nacosnacos:server-addr: 127.0.0.1:8848username: nacospassword: nacosgroup: SEATA_GROUPdata-id: client.properties

重启微服务，现在微服务到底是连接tc的SH集群，还是tc的HZ集群，都统一由nacos的client.properties来决定了。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/46623.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

opencv-人脸关键点定位

opencv-人脸关键点定位

#导入工具包 from collections import OrderedDict import numpy as np import argparse import dlib import cv2#https://ibug.doc.ic.ac.uk/resources/facial-point-annotations/ #http://dlib.net/files/# 参数 ap argparse.ArgumentParser() ap.add_argument("-p&quo…
阅读更多...
【Java】常见面试题：HTTP/HTTPS、Servlet、Cookie、Linux和JVM

【Java】常见面试题：HTTP/HTTPS、Servlet、Cookie、Linux和JVM

文章目录 1. 抓包工具（了解）2. 【经典面试题】GET和POST的区别：3. URL中不是也有这个服务器主机的IP和端口吗，为啥还要搞个Host？4. 补充5. HTTP响应状态码6. 总结HTTPS工作过程（经典面试题）7. H…
阅读更多...
vue3 清空/重置reactive

vue3 清空/重置reactive

序： 1、适用场景：表单切换验证如下图。 我举个例子，如果下拉选银行卡，提交表单的时候所属银行是要必填验证，但是如果选支付宝，那所属银行就非必填了，然而很多时候from的rules是以props来传的&a…
阅读更多...
飞书小程序开发

飞书小程序开发

1.tt.showModal后跳转页面 跳转路径要为绝对路径，相对路径跳转无响应。 2.手机息屏后将不再进入onload()生命周期，直接进入onshow()生命周期。 onLoad()在页面初始化的时候触发，一个页面只调用一次。 onShow()在切入前台时就会触发&#x…
阅读更多...
springBoot 配置文件 jpa 相关参数的作用

springBoot 配置文件 jpa 相关参数的作用

在Spring Boot应用中，可以通过配置文件来配置JPA（Java Persistence API）相关的参数。下面是一些常用的JPA配置参数及其作用： spring.jpa.database: 指定JPA使用的数据库类型，默认为自动检测。可选值有HSQL、H2、DERBY…
阅读更多...
开放网关架构演进

开放网关架构演进

作者：庄文弘（弘智） 淘宝开放平台是阿里与外部生态互联互通的重要开放途径，通过开放的产品技术把阿里经济体一系列基础服务，像水、电、煤一样输送给我们的商家、开发者、社区媒体以及其他合作伙伴，推动行业的…
阅读更多...
企业网三层架构实验

企业网三层架构实验

一、实验拓扑 二、实验要求 1、内网IP地址172.16.0.0/16合理分配； 2、SW1/2之间互为备份； 3、VRRP/STP/VLAN/TRUNK均使用； 4、所有PC通过DHCP获取IP地址； 三、实验思路 1、配置ISP的IP地址； 2、配置R1的IP地址&…
阅读更多...
＜指针进阶＞指针数组和数组指针傻傻分不清？

＜指针进阶＞指针数组和数组指针傻傻分不清？

✨Blog：🥰不会敲代码的小张:)🥰 🉑推荐专栏：C语言🤪、Cpp😶‍🌫️、数据结构初阶💀 💽座右铭：“記住，每一天都是一個新的開始&#x1…
阅读更多...
Mac发现有的软件不能上网的破解之法

Mac发现有的软件不能上网的破解之法

1、Mac上打开终端 terminal ，获取 root 权限。 sudo -i 2、编辑 hosts 文件 vim /private/etc/hosts 3、找到被禁止软件的数据请求域名，然后删除相关行，快捷件dd，然后:wq保存退出 比如百度 127.0.0.1 pan.baidu.com ##sec 印…
阅读更多...
深入完整的带你了解java对象的比较

深入完整的带你了解java对象的比较

目录 元素的比较 1.基本类型的比较 2.对象比较的问题 1.运行结果 2.疑问 3.原因 对象的比较 1.覆写基类的equals 2.基于Comparble接口类的比较 3.基于比较器比较 4.三种方式对比 元素的比较 1.基本类型的比较 在Java 中，基本类型的对象可以直接比较大…
阅读更多...
LVS-DR模式以及其中ARP问题

LVS-DR模式以及其中ARP问题

目录 LVS_DR LVS_DR数据包流向分析 LVS-DR中ARP问题 问题一 问题二 解决ARP的两个问题的设置方法 LVS-DR特点 LVS-DR优缺点 优点 缺点 LVS-DR集群构建 1.配置负载调度器 2.部署共享存储 3.配置节点服务器 4.测试 LVS 群集 LVS_DR LVS_DR数据包流向分析 客户端…
阅读更多...
JVM基础了解

JVM基础了解

JVM 是java虚拟机。 作用：运行并管理java源码文件锁生成的Class文件；在不同的操作系统上安装不同的JVM，从而实现了跨平台的保证。一般在安装完JDK或者JRE之后，其中就已经内置了JVM，只需要将Class文件交给JVM即可 写好的…
阅读更多...
爬虫工作中代理失效了怎么处理？

爬虫工作中代理失效了怎么处理？

Hey！亲爱的爬虫小伙伴们，是不是经常在爬虫的工作中遇到代理IP失效的问题？别着急，今天我来分享一些应对代理失效的妙招！这些方法简单易行，让你爬虫顺利进行. 一、为什么代理会失效？ 在爬虫过程…
阅读更多...
vue3+ts+vite项目页面初始化loading加载效果

vue3+ts+vite项目页面初始化loading加载效果

简介 一分钟实现 vue-pure-admin 同款项目加载时的 loading 效果 一、先看效果 1.1 静态效果 1.2 动态效果 二、上代码 核心代码在body里面&#xff0c;代码中已标明。找到你项目的 index.html &#xff0c;复制粘贴进去即可 <!DOCTYPE html> <html lang"en…
阅读更多...
每天一道leetcode：1306. 跳跃游戏 III（图论中等广度优先遍历）

每天一道leetcode：1306. 跳跃游戏 III（图论中等广度优先遍历）

今日份题目&#xff1a; 这里有一个非负整数数组 arr&#xff0c;你最开始位于该数组的起始下标 start 处。当你位于下标 i 处时&#xff0c;你可以跳到 i arr[i] 或者 i - arr[i]。 请你判断自己是否能够跳到对应元素值为 0 的 **任一** 下标处。 注意&#xff0c;不管是什…
阅读更多...
spring依赖注入详解（上）

spring依赖注入详解（上）

一、Bean销毁的过程 如果bean销毁时会执行的场景 1、设置DestroyMethodName为(inferred) // 先把DestroyMethodName设置为(inferred) Component public class TestBeanPostProcessor implements MergedBeanDefinitionPostProcessor {Overridepublic void postProcessMergedBe…
阅读更多...
根据Dockerfile创建容器案例讲解

根据Dockerfile创建容器案例讲解

-f为dokerfile的路径&#xff0c; -t为新镜像的名称及版本。 后面这个点是寻址路径。
阅读更多...
阿里面试官常问的TCP和UDP，你真的弄懂了吗？

阿里面试官常问的TCP和UDP，你真的弄懂了吗？

♥ 前 言 作为软件测试&#xff0c;大家都知道一些常用的网络协议是我们必须要了解和掌握的&#xff0c;面试的时候面试官也非常喜欢问一些协议相关的问题&#xff0c;其中有两个协议因为非常基础&#xff0c;出现的频率非常之高&#xff0c;分别是 ”TCP 协议“ 和 ”UDP 协…
阅读更多...
漏洞指北-VulFocus靶场专栏-中级03

漏洞指北-VulFocus靶场专栏-中级03

漏洞指北-VulFocus靶场专栏-初级03 中级009 &#x1f338;gxlcms-cve_2018_14685&#x1f338;step1&#xff1a;安装系统 密码rootstep2 进入后台页面 账号密码&#xff1a;admin amdin888step3 查看详细 有phpinfo() 中级010 &#x1f338;dedecms-cnvd_2018_01221&#x1f3…
阅读更多...
2023国赛数学建模C题思路模型代码 高教社杯

2023国赛数学建模C题思路模型代码 高教社杯

本次比赛我们将会全程更新思路模型及代码&#xff0c;大家查看文末名片获取 之前国赛相关的资料和助攻可以查看 2022数学建模国赛C题思路分析_2022国赛c题matlab_UST数模社_的博客-CSDN博客 2022国赛数学建模A题B题C题D题资料思路汇总 高教社杯_2022国赛c题matlab_UST数模社…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023