Seata 源码

360影视 2025-01-20 09:48 2

摘要:AbstractResourceManager 实现 ResourceManager 提供模板方法。DefaultResourceManager 适配所有的 ResourceManager,所有方法调用都委派给对应负责的 ResourceManager 处理。

ResourceManager 是 seata 的重要组件之一,RM 负责管理分支数据资源的事务。

AbstractResourceManager 实现 ResourceManager 提供模板方法。DefaultResourceManager 适配所有的 ResourceManager,所有方法调用都委派给对应负责的 ResourceManager 处理。

此为 AT 模式核心管理器,DataSourceManager 继承 AbstractResourceManager,管理数据库 Resouce 的注册,提交以及回滚等。

DataSourceManager 事务提交委派给 AsyncWorker 进行提交的,因为都成功了,无需回滚成功的数据,只需要删除生成的操作日志就行,采用异步方式,提高效率。

io.seata.rm.datasource.AsyncWorker#doBranchcommitsUndoLogManagerFactory.getUndoLogManager(dataSourceProxy.getDbType).batchDeleteUndoLog(xids, branchIds, conn);

TransactionManagerHolder 为创建单例 TransactionManager 的工厂,可以使用 EnhancedServiceLoader 的 spi 机制加载自定义的类,默认为DefaultTransactionManager。

GlobalTransaction 接口提供给用户开启事务,提交,回滚,获取状态等方法。

DefaultGlobalTransaction 是 GlobalTransaction 接口的默认实现,它持有 TransactionManager 对象,默认开启事务超时时间为 60 秒,默认名称为 default,因为调用者的业务方法可能多重嵌套创建多个 GlobalTransaction 对象开启事务方法,因此 GlobalTransaction 有 GlobalTransactionRole 角色属性,只有Launcher 角色的才有开启、提交、回滚事务的权利。

GlobalTransactionContext 为操作 GlobalTransaction 的工具类,提供创建新的 GlobalTransaction,获取当前线程有的 GlobalTransaction 等方法。

GlobalTransactionScanner 继承 AbstractAutoProxyCreator 类,即实现了 SmartInstantiationAwareBeanPostProcessor 接口,会在 spring 容器启动初始化bean 的时候,对 bean 进行代理操作。wrapIfNecessary 为继承父类代理 bean 的核心方法,如果配置了 service.disableGlobalTransaction 为 false 属性则注解不生效直接返回,否则对 GlobalTransactional 或 GlobalLock 的方法进行拦截代理。

GlobalTransactionalInterceptor 实现 aop 的 MethodInterceptor 接口,对有 @GlobalTransactional 或 Globallock 注解的方法进行代理。

TransactionalTemplate 模板类提供了一个开启事务,执行业务,成功提交和失败回滚的模板方法 execute(TransactionalExecutor business)。

try { // 2. If the tx role is 'GlobalTransactionRole.Launcher', send the request of beginTransaction to TC, // else do nothing. Of course, the hooks will still be triggered. beginTransaction(txInfo, tx); Object rs; try { // Do Your Business rs = business.execute; } catch (Throwable ex) { // 3. The needed business exception to rollback. completeTransactionAfterThrowing(txInfo, tx, ex); throw ex; } // 4. everything is fine, commit. commitTransaction(tx); return rs;} finally { //5. clear resumeGlobalLockConfig(previousConfig); triggerAfterCompletion; cleanUp;}Resource

Resource 能被 ResourceManager 管理并且能够关联 GlobalTransaction。

DataSourceProxy 实现 Resource 接口,BranchType 为 AT 自动模式。它继承 AbstractDataSourceProxy 代理类,所有的 DataSource 相关的方法调用传入的targetDataSource 代理类的方法,除了创建 connection 方法为创建 ConnectionProxy 代理类。对象初始化时获取连接的 jdbcUrl 作为 resourceId,并注册至DefaultResourceManager 进行管理。同时还提供获取原始连接不被代理的 getPlainConnection 方法。

ExecuteTemplate 为具体 statement 的 execute,executeQuery 和 executeUpdate 执行提供模板方法。

Executor

SQLRecognizer 识别 sql 类型,获取表名,表别名以及原生 sql

UndoExecutorFactory 根据 sqlType 生成对应的 AbstractUndoExecutor。

UndoExecutor 为生成执行 undoSql 的核心。如果全局事务回滚,它会根据 beforeImage 和 afterImage 以及 sql 类型生成对应的反向 sql 执行回滚数据,并添加脏数据校验机制,使回滚数据更加可靠。

DefaultCoordinator 即为 TC,全局事务默认的事务协调器。它继承 AbstractTCInboundHandler 接口,为 TC 接收 RM 和 TM 的 request 请求数据,是进行相应处理的处理器。实现 TransactionMessageHandler 接口,去处理收到的 RPC 信息。实现 ResourceManagerInbound 接口,发送至 RM 的 branchCommit,branchRollback 请求。

Core

Core 接口为 seata 处理全局事务协调器 TC 的核心处理器,它继承 ResourceManagerOutbound 接口,接受来自 RM 的 rpc 网络请求 (branchRegister,branchReport,lockQuery)。同时继承 TransactionManager 接口,接受来自 TM 的 rpc 网络请求(begin, commit,rollback,getStatus),另外提供提供 3 个接口方法。

GlobalSession 是 seata 协调器 DefaultCoordinator 管理维护的重要部件,当用户开启全局分布式事务,TM 调用 begin 方法请求至 TC,TC 则创建GlobalSession 实例对象,返回唯一的 xid。它实现 SessionLifecycle 接口,提供 begin,changeStatus,changeBranchStatus,addBranch,removeBranch 等操作 session 和 branchSession 的方法。

BranchSession 为分支 session,管理分支数据,受 globalSession 统一调度管理,它的 lock 和 unLock 方法由 lockManger 实现。

DefaultLockManager 是 LockManager 的默认实现,它获取 branchSession 的 lockKey,转换成 List,委派 Locker 进行处理。

来源:京东云开发者

相关推荐