seata at模式

深碍√TFBOYSˉ_ 2023-01-13 10:56 169阅读 0赞

**1.AT 模式**  
提供⽆侵⼊⾃动补偿的事务模式，⽬前已⽀持 MySQL、 Oracle 、PostgreSQL和 TiDB的AT模式，  
H2 开发中

**2.Seata 产品模块**

1.Seata 中有三⼤模块，分别是 TM、RM 和 TC。其中 TM 和 RM 是作为 Seata 的客户端与业务系统集  
成在⼀起，TC 作为 Seata 的服务端独⽴部署。

2.TC (Transaction Coordinator) - 事务协调者  
维护全局和分⽀事务的状态，驱动全局事务提交或回滚。  
3.TM (Transaction Manager) - 事务管理器  
定义全局事务的范围：开始全局事务、提交或回滚全局事务。  
4.RM (Resource Manager) - 资源管理器  
管理分⽀事务处理的资源，与TC交谈以注册分⽀事务和报告分⽀事务的状态，并驱动分⽀事务提交或  
回滚。

**3.AT模式原理**

1.  ⼀阶段  
    在⼀阶段，Seata 会拦截“业务 SQL”，⾸先解析 SQL 语义，找到“业务 SQL”要更新的业务数  
    据，在业务数据被更新前，将其保存成“before image”，然后执⾏“业务 SQL”更新业务数据，在业  
    务数据更新之后，再将其保存成“after image”，最后⽣成⾏锁。以上操作全部在⼀个数据库事务  
    内完成，这样保证了⼀阶段操作的原⼦性。
2.  ⼆阶段  
    。提交  
    ⼆阶段如果是提交的话，因为“业务 SQL”在⼀阶段已经提交⾄数据库， 所以 Seata 框架只需将  
    ⼀阶段保存的快照数据和⾏锁删掉，完成数据清理即可。  
    。回滚  
    ⼆阶段如果是回滚的话，Seata 就需要回滚⼀阶段已经执⾏的“业务 SQL”，还原业务数  
    据。回滚⽅式便是⽤“before image”还原业务数据；但在还原前要⾸先要校验脏写，对⽐“数  
    据库当前业务数据”和 “after image”，如果两份数据完全⼀致就说明没有脏写，可以还原业  
    务数据，如果不⼀致就说明有脏写，出现脏写就需要转⼈⼯处理

**AT 模式的⼀阶段、⼆阶段提交和回滚均由 Seata 框架⾃动⽣成，⽤户只需编写“业务  
SQL”，便能轻松接⼊分布式事务，AT 模式是⼀种对业务⽆任何侵⼊的分布式事务解决⽅案。**

**实战：**  
1.安装TC全局事务协调器  
Seata Server 就是 TC，直接从官⽅仓库下载启动即可，下载地址：https://github.com/seata/sea  
ta/releases  
1.1 registry.conf  
Seata Server 要向注册中⼼进⾏注册，这样，其他服务就可以通过注册中⼼去发现 Seata  
Server，与 Seata Server 进⾏通信。  
Seata ⽀持多款注册中⼼服务：nacos 、eureka、redis、zk、consul、etcd3、sofa。  
我们项⽬中要使⽤ nacos注册中⼼，nacos服务的连接地址、注册的服务名，这需要在  
seata/conf/registry.conf⽂件中进⾏配置：

registry {  #注册中⼼
     # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
     # 这⾥选择 nacos 注册配置
     type = "nacos"
     loadBalance = "RandomLoadBalance"
     loadBalanceVirtualNodes = 10
     nacos { 
     application = "seata-server" # 服务名称
     serverAddr = "127.0.0.1:8848" # 服务地址
     group = "SEATA_GROUP" # 分组
     namespace = ""
     cluster = "default" # 集群
     username = "nacos" # ⽤户名
     password = "nacos" # 密码
     }
     eureka { 
     serviceUrl = "http://localhost:8761/eureka"
     application = "default"
     weight = "1"
     }
     redis { 
     serverAddr = "localhost:6379"
     db = 0
     password = ""
     cluster = "default"
     timeout = 0
     }
     zk { 
     cluster = "default"
     serverAddr = "127.0.0.1:2181"
     sessionTimeout = 6000
     connectTimeout = 2000
     username = ""
     password = ""
     }
     consul { 
     cluster = "default"
     serverAddr = "127.0.0.1:8500"
     }
     etcd3 { 
     cluster = "default"
     serverAddr = "http://localhost:2379"
     }
     sofa { 
     serverAddr = "127.0.0.1:9603"
     application = "default"
     region = "DEFAULT_ZONE"
     datacenter = "DefaultDataCenter"
     cluster = "default"
     group = "SEATA_GROUP"
     addressWaitTime = "3000"
     }
     file { 
     name = "file.conf"
     }
    }
    config {  #配置中⼼
     # file、nacos 、apollo、zk、consul、etcd3
     type = "nacos"
     nacos { 
     serverAddr = "127.0.0.1:8848"
     namespace = ""
     group = "SEATA_GROUP"
     username = "nacos"
     password = "nacos"
     }
     consul { 
     serverAddr = "127.0.0.1:8500"
     }
     apollo { 
     appId = "seata-server"
     apolloMeta = "http://192.168.1.204:8801"
     namespace = "application"
     apolloAccesskeySecret = ""
     }
     zk { 
     serverAddr = "127.0.0.1:2181"
     sessionTimeout = 6000
     connectTimeout = 2000
     username = ""
     password = ""
     }
     etcd3 { 
     serverAddr = "http://localhost:2379"
     }
     file { 
     name = "file.conf"
     }
    }

1.2. 向nacos中添加配置信息  
下载配置config.txt https://github.com/seata/seata/tree/develop/script/config-center  
https://seata.io/zh-cn/docs/user/configurations.html针对每个⼀项配置介绍  
将config.txt⽂件放⼊seata⽬录下⾯  
修改config.txt信息  
Server端存储的模式（store.mode）现有file,db,redis三种。主要存储全局事务会话信息,  
分⽀事务信息, 锁记录表信息,seata-server默认是file模式。file只能⽀持单机模式, 如果想要  
⾼可⽤模式的话可以切换db或者redis. （db模式下需要创建配置文件中的数据库和对应的表）  
1.3 创建seata数据库  
需要创建global\_table/branch\_table/lock\_table三张表,seata1.0以上就不⾃带数  
据库⽂件了，要⾃⼰去github下载，https://github.com/seata/seata/tree/develop/scr  
ipt/server/db  
1.4使⽤nacos-config.sh ⽤于向 Nacos 中添加配置  
下载地址:https://github.com/seata/seata/tree/develop/script/config-center/nacos  
。将nacos-config.sh放在seata/conf⽂件夹中  
命令如下：

sh  nacos-config.sh 所在目录及文件  -h localhost -p 8848 -g SEATA_GROUP -t 5a3c7d6c-f497-4d68-a71a-2e5e3340b3ca -u username -w password

\-h： 主机，默认值为localhost。

\-p： 端口，默认值为8848。

\-g： 配置分组，默认值为“SEATA\\u GROUP”。

\-t： 租户信息，对应于Nacos的命名空间ID字段，默认值为’’。

\-u： 用户名，nacos 1.2.0+，在权限控制上，默认值为’’。

\-w： 密码，nacos 1.2.0+，在权限控制上，默认值为’’。

1.5 以上做完就可以启动seata server了

**2.TM/RM端整合Seata**  
AT 模式在RM端需要 UNDO\_LOG 表,来记录每个RM的事务信息,主要包含数据修改前,后的相关信息,  
⽤于回滚处理,所以在所有数据库中分别执⾏

-- 注意此处0.3.0+ 增加唯⼀索引 ux_undo_log
    CREATE TABLE `undo_log` (
     `id` bigint(20) NOT NULL AUTO_INCREMENT,
     `branch_id` bigint(20) NOT NULL,
     `xid` varchar(100) NOT NULL,
     `context` varchar(128) NOT NULL,
     `rollback_info` longblob NOT NULL,
     `log_status` int(11) NOT NULL,
     `log_created` datetime NOT NULL,
     `log_modified` datetime NOT NULL,
     `ext` varchar(100) DEFAULT NULL,
     PRIMARY KEY (`id`),
     UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

2.1 添加相关依赖（涉及分布式事物的项目都需要添加）

<dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-seata</artifactId>
                <version>2.1.0.RELEASE</version>
                <exclusions>
                    
                    <exclusion>
                        <groupId>io.seata</groupId>
                        <artifactId>seata-all</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
                 <version>1.3.0</version>
            </dependency>

2.2 项目resources目录添加registry.conf（涉及分布式事物的项目都需要添加）。注：这个是为了TM/RM 可以找到seata服务器。和seata server的registry.conf 保持一致(如果不一致会报诸如此类的错误no available service ‘null’ found, please make sure registry config correct)  
2.3 添加seata分类（涉及分布式事物的项目都需要添加）分组的值要和nacos中配置的key一样。如  
service.vgroupMapping.my\_test\_tx\_group 最后一个点后面的字符串就是分组的值。分组是为了资源之间相互隔离。

spring.cloud.alibaba.seata.tx-service-group=my_test_tx_group
    logging.level.seata=debug

2.4 在事物发起方添加@GlobalTransactional(rollbackFor = Exception.class,timeoutMills = 60000,name = “事物名称”)  
2.5 设置数据源代理（涉及到分布式事物的项目都需要添加）

package com.yyj.common_db;
    import com.alibaba.druid.pool.DruidDataSource;
    import io.seata.rm.datasource.DataSourceProxy;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    
    import javax.sql.DataSource;
    
    /** * 数据源代理 */
    @Configuration
    public class DataSourceConfiguration { 
    
        /** * 生成原来的数据源 * @return */
        @Bean
        @ConfigurationProperties("spring.datasource")
        public DataSource druidDataSource(){ 
            return new DruidDataSource();
        }
    
        /** * 设置代理数据源 * @param druidDataSource * @return */
        @Primary // 设置首选数据源
        @Bean("dataSource")
        public DataSourceProxy dataSource(DataSource druidDataSource){ 
            return new DataSourceProxy(druidDataSource);
        }
    }

2.6 启动类注解添加数据源代理的包扫描 和数据源自动配置的排除（涉及到分布式事物的项目都需要添加）

@SpringBootApplication(scanBasePackages = "com.yyj",
            exclude = DataSourceAutoConfiguration.class)