网站登录验证码不正确,广州注册个体户流程及费用,哪个网站网页做的好看,天津通用网站建设方案文章目录 前言参考目录版本说明分析整理1、全局锁的引入说明2、全局锁相关源码整理2.1、流程简图2.2、事务分支注册前的 SQL 相关操作2.3、注册分支#xff08;获取全局锁#xff09; 前言
上一篇文章介绍了 AT 模式的调用流程#xff0c;但是有个比较重要的概念没有提及到… 文章目录 前言参考目录版本说明分析整理1、全局锁的引入说明2、全局锁相关源码整理2.1、流程简图2.2、事务分支注册前的 SQL 相关操作2.3、注册分支获取全局锁 前言
上一篇文章介绍了 AT 模式的调用流程但是有个比较重要的概念没有提及到所以这一篇来展开说明一下——全局锁。
参考目录
Seata 官方文档Seata 官方 Demo seata-xaSeata AT 模式
版本说明
由于官方 Demo 版本较低本文使用的版本如下
SeataV1.7.0druid-spring-boot-starterV1.2.16
分析整理
1、全局锁的引入说明
在官方文档对于 AT 模型的篇章中有进行关于读写隔离的示例说明这其中就涉及到了全局锁。 截图自官方文档 在 Demo 里面业务主要是进行了写隔离因此下面的分析也是以此为基础进行展开。
上图简明扼要提出了全局锁的获取时机以及应用场景下面结合源码来看下。
2、全局锁相关源码整理
2.1、流程简图
上篇文章有根据输出记录按照时序步骤绘制了流程图对关键的信息进行提取后加上全局锁的内容绘制了新的流程图 简单说明一下
这张简图主要是事务分支相关的操作因此没有绘制 TM 相关的内容。虚线方框内是同一个方法的操作。主要的方法也一并贴出来方便后续查找。
2.2、事务分支注册前的 SQL 相关操作
这一部分在上一篇文章也有提及这里再简单带过一下。
在分支注册前回先执行业务逻辑生成前后镜像再贴一下堆栈信息图 io.seata.rm.datasource.exec.AbstractDMLBaseExecutor#executeAutoCommitFalse 得到前后镜像是为了生成 UndoLog 方便后续回滚操作。SQL 执行之后还没有 Commit需要获取到全局锁并且在数据库表中写入 UndoLog 后才会提交。
完成这一步骤之后继续分支事务操作方法 io.seata.rm.datasource.ConnectionProxy#processGlobalTransactionCommit 完成了三个重要步骤
注册分支包含获取全局锁undo_log 记录插入SQL 提交 本文的分析要点集中在步骤 1 中对于步骤 2 上一篇博客已经进行了详细的分析也贴出了相关的 UndoLog 内容本文就不再进行说明。
2.3、注册分支获取全局锁
来到 Client 端RM注册分支的底层方法
io.seata.rm.AbstractResourceManager#branchRegister 来到 Server 端TC的分支注册方法
io.seata.server.coordinator.AbstractCore#branchRegister 该方法的主要逻辑
使用 xid 获取到全局会话。锁定会话并在事务上下文进行操作。全局会话状态检查。全局会话添加会话生命周期监听器。新建全局事务分支获得分支会话对象。锁定分支会话。将分支会话添加到全局会话中如果出现异常解锁分支并抛出异常。打印日志并返回分支id。
下面来看看底层是如何实现的
branchSessionLock(globalSession, branchSession);io.seata.server.transaction.at.ATCore#branchSessionLock 根据打印的日志记录来看应用数据 applicationData 是 null因此直接进入到子方法。
io.seata.server.session.BranchSession#lock io.seata.server.lock.AbstractLockManager#acquireLock 这个方法会从分支会话中获取所有行锁信息。
// get locks of branch
ListRowLock locks collectRowLocks(branchSession);io.seata.server.lock.AbstractLockManager#collectRowLocks 上图以其中一个事务分支为例对方法进行了简单的逻辑梳理。该方法根据分支注册请求信息构建了锁对象集合并返回。
顺便说一下transactionId 实际上就是 xid 中 IP 端口后面的那一长串数字
xid192.168.2.117:8091:2252230319988862988transactionId2252230319988862988branchId2252230319988862990 回到上一层继续往下深入获取锁。
io.seata.server.storage.db.lock.DataBaseLocker#acquireLock io.seata.server.storage.db.lock.LockStoreDataBaseDAO#acquireLock
这是获取全局锁的主要方法方法逻辑如下 首先该方法获取数据库连接 conn并设置自动提交属性为 false。同时创建 PreparedStatement 对象 ps 和 ResultSet 对象 rs以及一个用于存储已存在行键的 HashSet 集合 dbExistedRowKeys。 如果传入的锁对象列表 lockDOs 的大小大于1则通过过滤去除重复的行键将其赋值给 lockDOs。这样可以确保锁对象列表中不会存在重复的行键。 如果 skipCheckLock 参数为 false说明需要进行锁的检查。即先查询数据库中的锁表判断是否有其他事务正在持有或正在回滚相同的全局锁。 创建一个查询检查锁的 SQL 语句 checkLockSQL并将锁对象数量作为参数传递给该语句。通过 PreparedStatement 对象 ps 执行 checkLockSQL并将锁对象的行键作为参数设置到 PreparedStatement 对象中。执行查询并遍历 ResultSet 对象 rs。对于每一行记录检查是否存在其他事务持有相同的全局锁。 如果存在其他事务持有相同的全局锁则设置 canLock 标志为 false并终止循环。同时将查询到的数据库中已存在的行键添加到 dbExistedRowKeys 集合中。 如果 canLock 标志为 false表示无法获取锁执行回滚操作并根据 autoCommit 参数和锁的状态判断是否需要抛出异常。如果 dbExistedRowKeys 集合不为空表示锁在数据库中已存在因此需要将这些行键从 lockDOs 列表中移除。 如果经过锁的检查后lockDOs 列表为空表示锁已全部存在于数据库中无需再次获取锁直接提交事务并返回 true。 接下来执行锁的获取操作。如果 lockDOs 列表中只有一个锁对象调用 doAcquireLock 方法进行单个锁的获取。如果获取失败执行回滚操作并返回 false。 如果 lockDOs 列表中存在多个锁对象调用 doAcquireLocks 方法进行批量锁的获取。如果获取失败执行回滚操作并返回 false。 最后提交事务关闭 ResultSet、PreparedStatement 对象根据原始的自动提交属性设置连接的 autoCommit 属性并关闭数据库连接。
io.seata.server.storage.db.lock.LockStoreDataBaseDAO#doAcquireLock
获取到全局锁后会把锁信息保存到数据库表 lock_table 中在释放锁后记录也会删除。
完
