Seata 源码
💡
原文中文,约4200字,阅读约需10分钟。
📝
内容提要
ResourceManager 是 Seata 的核心组件,负责管理分支数据资源事务。它通过 AbstractResourceManager 和 DefaultResourceManager 实现,支持数据库资源的注册、提交和回滚。AsyncWorker 提升事务提交效率,GlobalTransaction 接口提供事务管理功能,GlobalSession 和 BranchSession 分别管理全局和分支事务。
🎯
关键要点
- ResourceManager 是 Seata 的核心组件,负责管理分支数据资源事务。
- AbstractResourceManager 提供模板方法,DefaultResourceManager 适配所有 ResourceManager。
- DataSourceManager 继承 AbstractResourceManager,管理数据库资源的注册、提交和回滚。
- AsyncWorker 提升事务提交效率,采用异步方式处理事务提交。
- GlobalTransaction 接口提供事务管理功能,包括开启、提交和回滚事务。
- DefaultGlobalTransaction 是 GlobalTransaction 接口的默认实现,支持事务超时和角色管理。
- GlobalTransactionContext 提供操作 GlobalTransaction 的工具类。
- GlobalTransactionScanner 在 Spring 容器初始化时对 bean 进行代理操作。
- GlobalTransactionalInterceptor 实现 AOP 的 MethodInterceptor 接口,对带有注解的方法进行代理。
- TransactionalTemplate 提供事务执行的模板方法,支持成功提交和失败回滚。
- DataSourceProxy 实现 Resource 接口,管理数据库连接。
- ExecuteTemplate 提供具体 SQL 执行的模板方法。
- UndoExecutorFactory 根据 SQL 类型生成对应的 UndoExecutor。
- DefaultCoordinator 是全局事务的默认协调器,处理 RM 和 TM 的请求。
- Core 接口为 Seata 处理全局事务协调器的核心处理器。
- GlobalSession 管理全局分布式事务,提供会话操作方法。
- BranchSession 管理分支数据,受 GlobalSession 统一调度。
- DefaultLockManager 是锁管理的默认实现,负责处理分支会话的锁。
➡️