分布式事物

news2024/10/6 16:29:36

Seata实践
XA模式
AT模式
TCC模式 性能
Saga模式
高可用------集群的形式

Seata实践

在这里插入图片描述

解决方案

在这里插入图片描述

  • 解决方式

在这里插入图片描述

  • Seata 引入服务协调者模式
    在这里插入图片描述

实践步骤：

  • 分布式事物的入口方法，会调用其他的微服务，每次调用的服务都是一个分支事物
  • 调用了多少个分支事物，全局事物就包含多少个分支事物
  • TM去代理入口方法，当入口方法执行时，TM会向TC发送请求，注册全局事物，去调用每一个微服务，RM代理分支服务，向TC注册当前分支事物，每一个微服务就会调用sql进行执行，报告分支事物的状态到TC
  • TM入口方法执行完毕，TC会检查当前分支事物是否错误，如果有失败情况，进行回滚方法
    在这里插入图片描述

搭建TC服务

在这里插入图片描述
在这里插入图片描述

xa模式

性能会出现问题
在这里插入图片描述
在这里插入图片描述

实现步骤

在这里插入图片描述
在这里插入图片描述

AT原理实现

高并发会出现问题
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

AT模式读写隔离问题

  • 问题：当事物1获取锁，提交快照，执行业务sql，提交事物，释放全局锁时，事物2开始执行操作，执行sql，任务超时，释放锁，执行1事物进行回滚时，就会出现问题。

  • Seata会引入全局锁，进行数据的独立

  • 全局锁只会对Seata有效，如果是别的操作，还是会出现问题

在这里插入图片描述
在这里插入图片描述
实现步骤

  • 导入表
-- ----------------------------
-- Table structure for undo_log
-- ----------------------------
DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log`  (
  `branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',
  `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'global transaction id',
  `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'undo_log context,such as serialization',
  `rollback_info` longblob NOT NULL COMMENT 'rollback info',
  `log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',
  `log_created` datetime(6) NOT NULL COMMENT 'create datetime',
  `log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',
  UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = 'AT transaction mode undo table' ROW_FORMAT = Compact;

-- ----------------------------
-- Records of undo_log
-- ----------------------------



-- ----------------------------
-- Table structure for lock_table
-- ----------------------------
DROP TABLE IF EXISTS `lock_table`;
CREATE TABLE `lock_table`  (
  `row_key` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `xid` varchar(96) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `transaction_id` bigint(20) NULL DEFAULT NULL,
  `branch_id` bigint(20) NOT NULL,
  `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `table_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `pk` varchar(36) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `gmt_create` datetime NULL DEFAULT NULL,
  `gmt_modified` datetime NULL DEFAULT NULL,
  PRIMARY KEY (`row_key`) USING BTREE,
  INDEX `idx_branch_id`(`branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

在这里插入图片描述

  • 修改事物的模式
    在这里插入图片描述- 添加注解
    在这里插入图片描述

TCC模式

在这里插入图片描述
在这里插入图片描述
会出现的问题

  • 业务悬挂
  • 空回滚

Tcc的实现步骤

在这里插入图片描述

@Service
@Slf4j
public class AccountTCCServiceImpl implements AccountTCCService {

    @Autowired
    private AccountMapper accountMapper;
    @Autowired
    private AccountFreezeMapper freezeMapper;

    @Override
    @Transactional // 往表中添加数据
    public void deduct(String userId, int money) {
        // 0.获取事务id
        String xid = RootContext.getXID();
        // 1. 判断freeze中是否有冻结数据，如果有的话，拒绝业务
        AccountFreeze accountFreeze = new AccountFreeze();
        if (accountFreeze != null){
            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);
    }

    @Override // 操作成功，根据id删除
    public boolean confirm(BusinessActionContext ctx) {
        // 1.获取事务id
        String xid = ctx.getXid();
        // 2.根据id删除冻结记录
        int count = freezeMapper.deleteById(xid);
        return count == 1;
    }

    @Override // 回滚操作
    public boolean cancel(BusinessActionContext ctx) {
        // 0.查询冻结记录
        String xid = ctx.getXid();
        String userId = ctx.getActionContext("userId").toString();

        AccountFreeze freeze = freezeMapper.selectById(xid);

        // 1.空回滚
        if (freeze == null){
            freeze = new AccountFreeze();
            freeze.setUserId(userId);
            freeze.setFreezeMoney(0);
            freeze.setState(AccountFreeze.State.CANCEL);// 状态
            freeze.setXid(xid);
        }
        // 2. 幂的处理
        if (freeze.getState() == AccountFreeze.State.CANCEL){
            return true ;
        }

        // 1.恢复可用余额
        accountMapper.refund(freeze.getUserId(), freeze.getFreezeMoney());
        // 2.将冻结金额清零，状态改为CANCEL
        freeze.setFreezeMoney(0);
        freeze.setState(AccountFreeze.State.CANCEL);
        int count = freezeMapper.updateById(freeze);
        return count == 1;
    }
}

Sage 模式 时效性差，可能会出现脏写

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

高可用

  1. 将文件抽取到配置中心
# 事务组映射关系
service.vgroupMapping.seata-demo=SH

service.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
  1. 配置微服务，让其动态读取文件
seata:
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      username: nacos
      password: nacos
      group: SEATA_GROUP
      data-id: client.properties
  1. 由client.properties配置文件统一决定集群
    在这里插入图片描述

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

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

相关文章

SpringSecurity 认证实现

SpringSecurity 认证实现

在之前一篇 博客 已经说明了 SpringSecurity 认证与授权的原理。这篇用来具体实现一下。 1、新建SecurityConfig 并创建认证管理器 Bean public AuthenticationManager authenticationManager() {... }2、新建认证提供者 Configuration public class SystemUserPasswordAuth…
阅读更多...
Oracle项目管理之PrimaveraUnifier组织-业主/合作伙伴公司

Oracle项目管理之PrimaveraUnifier组织-业主/合作伙伴公司

目录 一、业主公司 二、合作伙伴公司 三、成员公司 Oracle Primavera Unifier 是企业项目协同管理系统，在国际化项目管理中，在进行常规的业务管理之外，对合同公司/EPC或分包供应商也有一定的管理要求，在Unifier中为了更好的实现…
阅读更多...
sja1000 CAN驱动学习、调试记录（基于PeliCan Mode）

sja1000 CAN驱动学习、调试记录（基于PeliCan Mode）

一、基础知识 网上讲sja1000 CAN总线控制器的资料很多，这里放一个引路贴：(151条消息) CAN总线控制器SJA1000_FATE的博客-CSDN博客_sja1000 BasicCAN Mode：仅支持11位的ID。 PeliCan Mode：在扩展模式下，允许使用 11 位 …
阅读更多...
找出DataFrame中指定数据类型的列：select_dtypes()函数

找出DataFrame中指定数据类型的列：select_dtypes()函数

【小白从小学Python、C、Java】 【计算机等级考试500强双证书】 【Python-数据分析】 找出DataFrame中指定数据类型的列 select_dtypes()函数 选择题 下列说法错误的是? import pandas as pd myDF pd.DataFrame({A:[1,2],B:[1.0,2.0],C:[a,b]}) print("【显示】myDF&qu…
阅读更多...
leecode#同构字符串#反转链表

leecode#同构字符串#反转链表

题目描述： 给定两个字符串 s 和 t ，判断它们是否是同构的。 如果 s 中的字符可以按某种映射关系替换得到 t ，那么这两个字符串是同构的。 每个出现的字符都应当映射到另一个字符，同时不改变字符的顺序。不同字符不能映射到同一…
阅读更多...
ReentrantLock详解

ReentrantLock详解

JUC中的锁API 在juc中有一个Lock接口他的作用和synchronized相似都是为了保证线程安全性提供的解决方案 Lock中定义了一系列释放锁和抢占锁相关的API lock() 抢占锁资源 如果当前线程没有抢占到锁 则阻塞 tryLock() 尝试抢占锁资源 如果抢占成功则返回true 否则返回false unlo…
阅读更多...
简单的深度活体智能记忆模型

简单的深度活体智能记忆模型

🍿*★,*:.☆欢迎您/$:*.★* 🍿 正文
阅读更多...
基于Antd Input组件自定义Input的成功状态

基于Antd Input组件自定义Input的成功状态

前言 Ant Design的Input组件的有一个状态的Api 需求 公司自研UI组件，在Antd的基础上进行开发。其中Input组件除了警告与错误状态外，还增加了成功的状态。如下图⬇️ 开发实现 方案一：覆盖CSS样式 一开始准备通过判断状态来增加类名&am…
阅读更多...
软件工程习题

软件工程习题

软件工程第一章 软件与软件工程作业第二章 可行性研究作业第三章 需求分析作业第四章 总体设计作业第五章 详细设计作业第六章 软件编码测验第七章 软件测试作业选择判断简答题第一章 软件与软件工程作业 一、单选题（共7题，58.1分） 1、软件是…
阅读更多...
刷题13-左右两边子数组的和相等

刷题13-左右两边子数组的和相等

题目012-左右两边子数组的和相等 思路：用到了三个循环，从头到尾遍历数组，比较左右两边数组的和是否相等，当然这种思路时间复杂度也比较高 核心代码： class Solution {public int pivotIndex(int[] nums) {int sum1,…
阅读更多...
6.2 、MyBatis 高级映射（resultMap 标签多表联查 ， 一对多，多对一关系）

6.2 、MyBatis 高级映射（resultMap 标签多表联查 ， 一对多，多对一关系）

文章目录一、实现多表联查（association 标签）1、实现多对一关系结果集映射二、实现多表联查（collection 标签）一、实现多表联查（association 标签） association 标签： 实现一对一，多…
阅读更多...
因果推断1--基本方法介绍（个人笔记）

因果推断1--基本方法介绍（个人笔记）

目录 一、因果推断介绍 1.1 什么是因果推断 1.2为什么研究因果推断 1.3因果推断阶梯 1.4因果推断问题分类 二、因果推断理论框架 2.1 定义（这些定义后面会经常用到） 2.2 Assumptions（三大基本假设） 三、因果效应估计 3.1 因果效应…
阅读更多...
JavaEE【Spring】：SpringBoot 配置文件

JavaEE【Spring】：SpringBoot 配置文件

文章目录一、配置文件的作用二、配置文件的格式1、注意2、说明三、properties 配置文件说明1、基本语法2、读取配置文件① 注意3、优缺点四、yml 配置文件说明1、基本语法2、yml 使用进阶① yml 配置不同数据类型及 nullⅠ. yml 配置读取Ⅱ. 练习a. 值为 null 的配置b. 根本不存…
阅读更多...
利用云服务器发布项目

利用云服务器发布项目

前言 平时开发我会写一些小demo，我自己觉得有用的会集中起来形成一个项目，本来想利用gitee的gitee page直接部署出来，但后面了解了下，它只支持官网之类的静态页面，无法与后台数据交互，想要完整的服务还是得…
阅读更多...
数据分析业务场景 | 用户画像

数据分析业务场景 | 用户画像

一.概况 定义 是根据用户的一系列行为和意识过程建立起来的多维度标签；是根据用户人口学特征，网络浏览内容，网络社交活动和消费行为等信息而抽象出的一个标签化的用户模型；首要任务：根据业务需求整理和数据情况分析建…
阅读更多...
Springboot redirect重定向使用RedirecAtrributes传递数据

Springboot redirect重定向使用RedirecAtrributes传递数据

参考资料 【转载】关于重定向RedirectAttributes的用法RedirectAttributes 的使用 目录前期准备一. RedirecAtrributes重定向传参三. 重定向目标页面接收参数前期准备 ⏹配置文件 server:servlet:context-path: /jmw⏹访问url http://localhost:8080/jmw/test16/init?name…
阅读更多...
NX二次开发（C#）-UI Styler-选择对象TaggedObject转换为Body、Face等对象

NX二次开发（C#）-UI Styler-选择对象TaggedObject转换为Body、Face等对象

文章目录 1、前言2、选择对象的过滤器2、选择对象类型为TaggedObject3、TaggedObject转换为Face类型1、前言 前面的博客中已经写过了UI Styler中选择对象（selection)的一些内容，但是依然有读者不知道运用，本文将在前文的基础上更加深入的介绍选择对象的应用（建议与https:/…
阅读更多...
DevExpress Universal添加对.NET 7的支持

DevExpress Universal添加对.NET 7的支持

DevExpress Universal添加对.NET 7的支持 DevExpress已经发布了整个产品系列的主要更新。 CodeRush Ultimate 22.2-为许多重构添加了核心性能优化和增强。 DevExpress.NET MAUI 22.2-添加了对Material Design 3指南的支持，以及对数据网格的自定义过滤、排序和分组。…
阅读更多...
PCB封装

PCB封装

目录 1.PCB元器件库分类及命名 1.2PCB封装图形要求 2.封装制作 手工制作封装的操作步骤 1.PCB元器件库分类及命名 元器件采用大写字母表示，PCB元器件库分类及命名如表。 2.PCB封装图形要求 （1）外形：指元器件的最大外形尺寸。封…
阅读更多...
【微电网优化】基于粒子群实现微网经济调度，环境友好调度附matlab代码

【微电网优化】基于粒子群实现微网经济调度，环境友好调度附matlab代码

✅作者简介：热爱科研的Matlab仿真开发者，修心和技术同步精进，matlab项目合作可私信。 🍎个人主页：Matlab科研工作室 🍊个人信条：格物致知。 更多Matlab仿真内容点击👇 智能优化算法 …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023