时间：   |   分类：       | 字数： 2044 字 | 阅读约： 5分钟 | 阅读次数：

Seata AT模式

一. 案例创建

创建示例工程 parent-seata-demo: https://gitee.com/ixinglan/parent-seata-demo.git

初始化4个sql仓库 seata_bussiness/seata_order/seata_points/seata_storage

启动4个服务, 测试(测试时调用demo-bussiness的接口)

http://localhost:8000/test1正常访问数据分别⼊库

http://localhost:8000/test2访问出错库存不⾜,导致服务调⽤失败.则观察数据库,经发现订单与积分数据库都已改变,⽽库存数据库没有减少库存,所以不满⾜事务的特性.

二. AT模式介绍

AT模式是⼀种⽆侵⼊的分布式事务解决⽅案。在AT模式下，⽤户只需关注⾃⼰的“业务SQL”，⽤户的“业务SQL”作为⼀阶段，Seata框架会⾃动⽣成事务的⼆阶段提交和回滚操作。

三. AT模式原理

  • 一阶段

    在⼀阶段，Seata会拦截“业务SQL”，⾸先解析SQL语义，找到“业务SQL”要更新的业务数据，在业务数据被更新前，将其保存成“beforeimage”，然后执⾏“业务SQL”更新业务数据，在业务数据更新之后，再将其保存成“afterimage”，最后⽣成⾏锁。以上操作全部在⼀个数据库事务内完成，这样保证了⼀阶段操作的原⼦性。

  • 二阶段

    • 提交

      ⼆阶段如果是提交的话，因为“业务SQL”在⼀阶段已经提交⾄数据库，所以Seata框架只需将⼀阶段保存的快照数据和⾏锁删掉，完成数据清理即可。

    • 回滚

      ⼆阶段如果是回滚的话，Seata就需要回滚⼀阶段已经执⾏的“业务SQL”，还原业务数据。回滚⽅式便是⽤“beforeimage”还原业务数据；但在还原前要⾸先要校验脏写，对⽐“数据库当前业务数据”和“afterimage”，如果两份数据完全⼀致就说明没有脏写，可以还原业务数据，如果不⼀致就说明有脏写，出现脏写就需要转⼈⼯处理。

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

四. AT模式改造

4.1 TC全局事务协调器

SeataServer就是TC，直接从官⽅仓库下载启动即可，下载地址：https://github.com/seata/sea ta/releases

下载后作以下修改

  • registry.conf修改(/conf目录下)

    registry type=“nacos”

    config type=“nacos”

  • 向nacos中添加配置信息

    • 下载配置config.txt https://github.com/seata/seata/tree/develop/script/config-center

    • 将config.txt放置在与 /bin文件同级目录下

    • 修改config.txt配置信息

      store.mode = db

      store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true

      store.db.user=root

      store.db.password=root

    • 注意要创建seata数据库: 初始化sql从 https://github.com/seata/seata/tree/develop/script/server/db 获取

    • 全局事务分组配置

      service.vgroupMapping.default_tx_group=default #我们可以修改key中default_tx_group为自定义名称, value值:default也可修改
service.default.grouplist=127.0.0.1:8091 #如果上面value值修改,则此配置中key值 default也与上面value值个同

# 用法在下面有说明

    • 使⽤nacos-config.sh⽤于向Nacos中添加配置

      下载地址:https://github.com/seata/seata/tree/develop/script/config-center/nacos

      放置在conf目录下,并执行,即可将config.txt中的配置配置到nacos中

    • 执行 sh nacos-config.sh -h 127.0.0.1

    • 登录nacos查看配置信息

    • 启动seata-server, 即可看到seata-server自身的注册信息

4.2 TM/RM端整合seata

  • 在三个业务库中分别添加 undo_log表

    来记录每个RM的事务信息,主要包含数据修改前,后的相关信息,⽤于回滚处理,所以在所有数据库中分别执⾏

    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;

  • 整合步骤图

  • 事务分组

  • 整合步骤

    • Parent pom中引入seata依赖管理

      <dependencyManagement>
        <dependencies>
            <!-- seata版本管理, ⽤于锁定⾼版本的seata-->
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
                <version>1.3.0</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    • demo-common-db中添加seata依赖

      因为我们抽出来demo-common-db,其他模块依赖了demo-common-db,所以只需这儿添加即可

       <!--seata依赖-->
<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-alibaba-seata</artifactId>
  <!--排除低版本seata依赖-->
  <exclusions>
    <exclusion>
      <groupId>io.seata</groupId>
      <artifactId>seata-all</artifactId>
    </exclusion>
  </exclusions>
</dependency>
<!--添加⾼版本seata依赖-->
<dependency>
  <groupId>io.seata</groupId>
  <artifactId>seata-all</artifactId>
  <version>1.3.0</version>
</dependency>

    • demo-common-db中添加registry.conf(把seata-server中的复制过来即可)

    • demo-common-db 添加公共配置 application-seata.yml

      logging:
  level:
    io.seata: debug

spring:
  cloud:
    alibaba:
      seata:
        tx-service-group: default_tx_group

    • 在其他每个模块中引入配置文件

      profiles
 active: seata

      也可次上一步中的配置信息分别添加到每个模块中

    • 创建数据源代理

      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;

/**
 * 数据源代理
 *
 * @author zhaojianqiang
 */
@Configuration
public class DataSourceConfiguration {

    /**
     * 使⽤druid连接池
     *
     * @return
     */
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource() {
        return new DruidDataSource();
    }

    /**
     * 设置数据源代理-,完成分⽀事务注册/事务提交与回滚等操作
     *
     * @param druidDataSource
     * @return
     */
    @Primary //设置⾸选数据源对象
    @Bean("dataSource")
    public DataSourceProxy dataSource(DataSource druidDataSource) {
        return new DataSourceProxy(druidDataSource);
    }
}

    • 启动扫描配置类,分别加载每个⼯程的启动类中

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

    • TM端service方法添加 @GlobalTransactional 注解

      @GlobalTransactional(rollbackFor = Exception.class, timeoutMills = 6000, name = "sale")

    • 启动各个服务,我们发现分布式事务生效了

    • 可以将事务timeoutMills设置时间长一点, debug观察各个表数据变化

0%