Seata入门系列【4】undo_log、global_table、branch_table、lock_table字段及作用详解

news2024/11/17 8:45:39

1 客户端

1.1 undo_log

在AT模式中，需要在参与全局事务的数据库中，添加一个undo_log表，建表语句如下：

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for undo_log
-- ----------------------------
DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log`  (
  `branch_id` bigint(20) NOT NULL COMMENT '分支事务ID',
  `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '全局事务ID',
  `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '上下文',
  `rollback_info` longblob NOT NULL COMMENT '回滚信息',
  `log_status` int(11) NOT NULL COMMENT '状态，0正常，1全局已完成',
  `log_created` datetime(6) NOT NULL COMMENT '创建时间',
  `log_modified` datetime(6) NOT NULL COMMENT '修改时间',
  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;

SET FOREIGN_KEY_CHECKS = 1;

在全局事务的一阶段中，分支事务在获取到全局锁提交事务时，会释放本地锁和连接资源，并在undo_log表中插入一条数据。

比如在更新时，会插入这样一条数据：
在这里插入图片描述
各字段详细说明如下：

在这里插入图片描述
其中重要的是rollback_info，比如在更新一条数据时set money = 97，会查询修改之前该条数据的及修改后的数据状态。
在这里插入图片描述
在rollback_info中，该数据修改之前是98:
在这里插入图片描述
修改之前，该数据是97:
在这里插入图片描述
在第二阶段中，如果全局事务成功，会收到 TC 的分支提交请求，把请求放入一个异步任务的队列中，马上返回提交成功的结果给 TC。异步任务阶段的分支提交请求将异步和批量地删除相应 UNDO LOG 记录。

在第二阶段中，如果全局事务失败，会收到 TC 的分支回滚请求，开启一个本地事务，执行如下操作。

  • 通过 XID 和 Branch ID 查找到相应的 UNDO LOG 记录。

  • 数据校验：拿 UNDO LOG 中的后镜与当前数据进行比较，如果有不同，说明数据被当前全局事务之外的动作做了修改。这种情况，需要根据配置策略来做处理，详细的说明在另外的文档中介绍。

  • 根据 UNDO LOG 中的前镜像和业务 SQL 的相关信息生成并执行回滚的语句。

  • 提交本地事务。并把本地事务的执行结果（即分支事务回滚的结果）上报给 TC。

在这里插入图片描述

2 服务端

2.1 事务会话信存储模式

在服务端，需要存储事务会话信息，支持一下几种方式：

  • file本地文件(不支持HA)

  • db数据库(支持HA)

  • redis(支持HA)

其中本地文件方式，效率最高，但是不支持集群，而且出现问题时，是无法格式化的查看当前数据的，所以推荐使用数据库或者缓存的方式。

使用数据库模式时，需要创建以下三张表：
在这里插入图片描述

  • global_table：全局事务

  • branch_table：分支事务

  • lock_table：全局锁

2.2 global_table

global_table记录了全局事务的信息，建表语句如下：

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for global_table
-- ----------------------------
DROP TABLE IF EXISTS `global_table`;
CREATE TABLE `global_table`  (
  `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '全局事务ID',
  `transaction_id` bigint(20) NULL DEFAULT NULL COMMENT '事务ID',
  `status` tinyint(4) NOT NULL COMMENT '状态',
  `application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '应用ID',
  `transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '事务分组名',
  `transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '执行事务的方法',
  `timeout` int(11) NULL DEFAULT NULL COMMENT '超时时间',
  `begin_time` bigint(20) NULL DEFAULT NULL COMMENT '开始时间',
  `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '应用数据',
  `gmt_create` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  `gmt_modified` datetime(0) NULL DEFAULT NULL COMMENT '修改时间',
  PRIMARY KEY (`xid`) USING BTREE,
  INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,
  INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

SET FOREIGN_KEY_CHECKS = 1;

比如，当前应用demo001发起了一个全局事务，会在这个表中存入以下信息：
在这里插入图片描述

2.3 branch_table

branch_table记录了分支事务的信息，建表语句如下：

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for branch_table
-- ----------------------------
DROP TABLE IF EXISTS `branch_table`;
CREATE TABLE `branch_table`  (
  `branch_id` bigint(20) NOT NULL COMMENT '分支事务ID',
  `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '全局事务ID',
  `transaction_id` bigint(20) NULL DEFAULT NULL COMMENT '全局事务ID，不带TC地址',
  `resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '资源分组ID',
  `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '资源ID',
  `branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '事务模式，AT、XA等',
  `status` tinyint(4) NULL DEFAULT NULL COMMENT '状态',
  `client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '客户端ID',
  `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '应用数据',
  `gmt_create` datetime(6) NULL DEFAULT NULL COMMENT '创建时间',
  `gmt_modified` datetime(6) NULL DEFAULT NULL COMMENT '修改时间',
  PRIMARY KEY (`branch_id`) USING BTREE,
  INDEX `idx_xid`(`xid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

-- ----------------------------
-- Records of branch_table
-- ----------------------------

SET FOREIGN_KEY_CHECKS = 1;

当一个服务调用另一个服务进行全局事务时，可以看到，在该表中插入了当前两个服务分支事务的相关信息，其中重要的有ID、事务模式、客户端地址、数据库连接地址等。

INSERT INTO `branch_table` VALUES (99302990136565280, '192.168.58.1:8091:99302990136565278', 99302990136565278, NULL, 'jdbc:mysql://127.0.0.1:3306/db_account', 'AT', 0, 'demo001:192.168.58.1:2116', NULL, '2022-01-25 16:56:58.092953', '2022-01-25 16:56:58.092953');
INSERT INTO `branch_table` VALUES (99302990136565283, '192.168.58.1:8091:99302990136565278', 99302990136565278, NULL, 'jdbc:mysql://127.0.0.1:3306/db_order', 'AT', 0, 'demo002:192.168.58.1:2617', NULL, '2022-01-25 16:56:58.551257', '2022-01-25 16:56:58.551257');

2.4 lock_table

lock_table记录了锁相关的信息，建表语句如下：

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- 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 COMMENT '行键',
  `xid` varchar(96) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '全局事务ID',
  `transaction_id` bigint(20) NULL DEFAULT NULL COMMENT '全局事务ID，不带TC 地址',
  `branch_id` bigint(20) NOT NULL COMMENT '分支ID',
  `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '资源ID',
  `table_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '表名',
  `pk` varchar(36) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '主键对应的值',
  `gmt_create` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  `gmt_modified` datetime(0) NULL DEFAULT NULL COMMENT '修改时间',
  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;

SET FOREIGN_KEY_CHECKS = 1;

比如下图：

在这里插入图片描述
关于TC 端事务交互的详细流程，后续会分析

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

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

相关文章

20比较类的一种内在逻辑

20比较类的一种内在逻辑

我们平时会直接在idle里面去写类似于 10>6,但是其实仔细思考一下，10和6是int的实例对象，感觉学逻辑真的比单纯学代码有用，参照之前的那个图，多去想一下逻辑其实真的很好！ python3其实是这样不支持的~（…
阅读更多...
2023年9月Web3行业月度发展报告区块链篇 | 陀螺科技会员专享

2023年9月Web3行业月度发展报告区块链篇 | 陀螺科技会员专享

9月是加密市场的活动月，斯坦福区块链周、Token2049等大型活动相继举办，后者更是创下超过1万人的历史最高纪录，成为了全球最大的Web3活动。在本次Token2049上，RWA、支付以及出入金成为了讨论度最多的活动。尽管活动如火如荼&#x…
阅读更多...
Ps：画布大小

Ps：画布大小

Ps菜单：图像/画布大小 Image/Canvas Size 快捷键：Ctrl Alt C 画布 Canvas是存放图像的容器，所以改变画布大小对原来的图像大小不会造成影响。除了画布大小 Canvas Size命令，画板工具、裁剪工具等也可以改变画布的大小&#xff…
阅读更多...
金和OA C6任意文件读取漏洞 复现[附POC]

金和OA C6任意文件读取漏洞 复现[附POC]

文章目录 金和OA C6任意文件读取漏洞 复现[附POC]0x01 前言0x02 漏洞描述0x03 影响版本0x04 漏洞环境0x05 漏洞复现1.访问漏洞环境2.构造POC3.复现 0x06 修复建议 金和OA C6任意文件读取漏洞 复现[附POC] 0x01 前言 免责声明：请勿利用文章内的相关技术从事非法测试…
阅读更多...
无人机控制的研究现状及关键技术

无人机控制的研究现状及关键技术

无人机作为一种新型的航空器具，已经在军事、民用和科研等领域得到了广泛的应用。本文综述了无人机控制的研究现状及关键技术，包括无人机的应用领域、无人机的控制算法等方面。最后，对未来无人机控制的发展趋势进行了展望。 关键词&#xff1…
阅读更多...
适用于Windows的远程传输大文件软件！

适用于Windows的远程传输大文件软件！

​AnyViewer可在设备之间快速的远程传输文件，并支持远程传输大文件，传输速度可达10MB/S，同时，还可以传输单个文件不超过1TB的文件，并它基于椭圆曲线加密（ECC）加密，可保护您的文件不被…
阅读更多...
【AI】Interesting Applications

【AI】Interesting Applications

文章目录 【盘古】【嗜睡检测】【3D AI 生成】多模态——指哪打哪【AlphaDev：汇编版 AlphaZero】【ChatExcel】 【盘古】 2023年7月，华为正式发布盘古大模型3.0，并提出3层模型架构。 L0：基础大模型，包括自然语言、视觉…
阅读更多...
Qt中常用容器组控件介绍和实操

Qt中常用容器组控件介绍和实操

目录 常用容器组控件(Containers)： 1.Group Box 2.Scroll Area 3.Tab Widget 4.Frame 5.Dock Widget 常用容器组控件(Containers)： 控件名称依次解释如下(常用的用红色标出）: Group Box: 组合框: 提供带有标题的组合框框架Scroll Area…
阅读更多...
【RabbitMQ 实战】11 队列的结构和惰性队列

【RabbitMQ 实战】11 队列的结构和惰性队列

一、 队列的结构 队列的组成： 队列由 rabbit_amgqueue_process 和 backing_queue两部分组成。rabbit_amqqueue_process负责协议相关的消息处理，即接收生产者发布的消息、向消费者交付消息、处理消息的确认 (包括生产端的 confirm 和消费端的 ack) 等。…
阅读更多...
Android Studio Flutter真机调试错误

Android Studio Flutter真机调试错误

错误：Could not locate aapt. Please ensure you have the Android buildtools installed. No application found for TargetPlatform.android_arm64. Is your project missing an android/app/src/main/AndroidManifest.xml? Consider running "flutter crea…
阅读更多...
Anaconda prompt中使用conda下载pytorch，一直卡在solving environment解决方案

Anaconda prompt中使用conda下载pytorch，一直卡在solving environment解决方案

关闭梯子 清空镜像源： conda config --remove-key channels 在pytorch官网找到对应的版本与命令：PyTorch conda install pytorch torchvision torchaudio pytorch-cuda12.1 -c pytorch -c nvidia（我的电脑CUDA版本为12.1.103，…
阅读更多...
vscode 资源管理器移动到右边

vscode 资源管理器移动到右边

目录 vscode 资源管理器移动到右边 vscode 资源管理器移动到右边 点击 文件》首选项》设置》工作台》外观》 找到这个配置下拉选择左右
阅读更多...
【合集】Spring Cloud 组件——架构进化史话 Nacos，OpenFeign，Ribbon，Sentinel，Gateway . . .

【合集】Spring Cloud 组件——架构进化史话 Nacos，OpenFeign，Ribbon，Sentinel，Gateway . . .

前言 Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智能路由，微代理，控制总线，一次性令牌，全局锁，领导选举&…
阅读更多...
文件上传 [MRCTF2020]你传你呢1

文件上传 [MRCTF2020]你传你呢1

题目来源：buuctf [MRCTF2020]你传你🐎呢1 打开题目 我们随便上传个木马文件上去 我们bp抓包看看
阅读更多...
Linux Find 备忘清单

Linux Find 备忘清单

文章目录 引言一、入门1.1 简介1.2 命令用法 二、基本使用2.1 根据文件大小查找2.2 根据文件类型查找2.3 根据文件名查找2.4 指定搜索目录层级/深度2.5 根据权限查找2.6 根据属主/属组查找2.7 多个文件名2.8 多个目录2.9 根据时间戳查找 三、进阶使用3.1 查找和删除3.2 查找和移…
阅读更多...
tomcat服务tomcat多实例部署

tomcat服务tomcat多实例部署

tomcat服务&&tomcat多实例部署 文章目录 tomcat服务&&tomcat多实例部署1.简介2.优缺点优点：缺点： 3.工作原理4.工作流程5.tomcat服务部署5.1.java环境安装5.2.拉取tomcat软件包5.3.解压部署5.4.启动tomcat服务5.5.访问tomcat的web页面5.…
阅读更多...
java 常量、变量、数据类型

java 常量、变量、数据类型

常量 * 指在程序执行期间其值不能发生变化的数据。例如数学中的π 3.1415……又如：整数123，小 数1.23，字符’A’，布尔常量 true、false等，程序开发中，常量名一般规则全部大写，声明常量时必 须赋…
阅读更多...
排序算法-希尔排序法（ShellSort）

排序算法-希尔排序法（ShellSort）

排序算法-希尔排序法（ShellSort） 1、说明 我们知道当原始记录的键值大部分已排好序的情况下插入排序法非常有效，因为它不需要执行太多的数据搬移操作。希尔排序法是D.L.Shell在1959年7月发明的一种排序法，可以减少插入排序法中数…
阅读更多...
tomcat 问题

tomcat 问题

一、start up.bat 闪退 在命令窗口run 看看是缺少了哪个环境变量 二、控制台输出乱码 logging.properties 底部添加 java.util.logging.ConsoleHandler.encoding GBK 三、缓存不足 context.xml配置 <Resources cachingAllowed"false" cacheMaxSize"100…
阅读更多...
从字节码文件理解 ++i 和 i++ 的区别_i++ 与 ++i 底层

从字节码文件理解 ++i 和 i++ 的区别_i++ 与 ++i 底层

jvm内存模型 jvm 内存模型&#xff1a;Java 代码是运行在 Java 虚拟机之上的&#xff0c;由 Java 虚拟机通过解释执行 (解释器)或编译执行 (即时编译器) 来完成&#xff0c;故 Java 内存模型&#xff0c;也就是指 Java 虚拟机的运行时内存模型。 运行时内存模型&#xff0c;分…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023