seata学习笔记--使用篇

环境

• springboot 2.3.3

一、数据库环境准备

1.1 建立数据库

• 创建一个名为seata的数据库

• 要求：具有InnoDB引擎的MySQL。

1.2 seata数据库中创建三个表

 -- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `global_table`
(
    `xid`                       VARCHAR(128) NOT NULL,
    `transaction_id`            BIGINT,
    `status`                    TINYINT      NOT NULL,
    `application_id`            VARCHAR(32),
    `transaction_service_group` VARCHAR(32),
    `transaction_name`          VARCHAR(128),
    `timeout`                   INT,
    `begin_time`                BIGINT,
    `application_data`          VARCHAR(2000),
    `gmt_create`                DATETIME,
    `gmt_modified`              DATETIME,
    PRIMARY KEY (`xid`),
    KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
    KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(
    `branch_id`         BIGINT       NOT NULL,
    `xid`               VARCHAR(128) NOT NULL,
    `transaction_id`    BIGINT,
    `resource_group_id` VARCHAR(32),
    `resource_id`       VARCHAR(256),
    `branch_type`       VARCHAR(8),
    `status`            TINYINT,
    `client_id`         VARCHAR(64),
    `application_data`  VARCHAR(2000),
    `gmt_create`        DATETIME,
    `gmt_modified`      DATETIME,
    PRIMARY KEY (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
    `row_key`        VARCHAR(128) NOT NULL,
    `xid`            VARCHAR(96),
    `transaction_id` BIGINT,
    `branch_id`      BIGINT       NOT NULL,
    `resource_id`    VARCHAR(256),
    `table_name`     VARCHAR(32),
    `pk`             VARCHAR(36),
    `gmt_create`     DATETIME,
    `gmt_modified`   DATETIME,
    PRIMARY KEY (`row_key`),
    KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

1.3 在需要分布式事务的数据库中添加 undo_log表

-- 注意此处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;

---

二、客户端配置

• 客户端为windowns版本 1.4.0

2.1 file.conf文件配置

• 在conf文件夹中找到file.conf文件,选择数据存储类型

  

    ## store mode: file、db、redis
    mode = "db"
  

• 配置数据库，这里以mysql为例，数据库版本为 mysql 5.6

  

  ## database store property
    db {
      ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
      datasource = "druid"
      ## mysql/oracle/postgresql/h2/oceanbase etc.
      dbType = "mysql"
      driverClassName = "com.mysql.jdbc.Driver"
      url = "jdbc:mysql://127.0.0.1:3306/seata"
      user = "root"
      password = "tiger"
      minConn = 5
      maxConn = 100
      globalTable = "global_table"
      branchTable = "branch_table"
      lockTable = "lock_table"
      queryLimit = 100
      maxWait = 5000
    }
  

2.2 registry.conf文件配置，因为是基于eureka作为注册中心，因此只用配置与eureka相关的即可

• 选择注册类型

  

    # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
    type = "eureka"
    loadBalance = "RandomLoadBalance"
    loadBalanceVirtualNodes = 10
  
  

• 修改注册名

  

  eureka {
      serviceUrl = "http://localhost:8761/eureka"
      application = "ticket-seata"
      weight = "1"
    }
  

---

三、代码配置

3.1 引入依赖

• 注意
  • 由于seata是阿里的产品，因此需要进行单独的版本控制，可以选择在具体的依赖中加入版本号，也可以在dependencyManagement中对阿里的依赖进行统一管理

		 <!-- seata -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
            <version>2.2.3.RELEASE</version>
        </dependency>

    <dependencyManagement>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.2.3.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

3.2 配置文件

• 引入file.conf和registry.conf文件

  

  • file.conf

  service {
    #transaction service group mapping
    #修改，可不改,my_test_tx_group随便起名字。
    vgroup_mapping.my_test_tx_group = "default"
    #only support when registry.type=file, please don't set multiple addresses
    # 此服务的地址
    default.grouplist = "127.0.0.1:8091"
    #disable seata
    disableGlobalTransaction = false
  }
  ## transaction log store, only used in seata-server
  store {
    ## store mode: file、db、redis
    mode = "db"
  
    ## file store property
    file {
      ## store location dir
      dir = "sessionStore"
      # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
      maxBranchSessionSize = 16384
      # globe session size , if exceeded throws exceptions
      maxGlobalSessionSize = 512
      # file buffer size , if exceeded allocate new buffer
      fileWriteBufferCacheSize = 16384
      # when recover batch read size
      sessionReloadReadSize = 100
      # async, sync
      flushDiskMode = async
    }
  
    ## database store property
    db {
      ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
      datasource = "druid"
      ## mysql/oracle/postgresql/h2/oceanbase etc.
      dbType = "mysql"
      driverClassName = "com.mysql.cj.jdbc.Driver"
      url = "jdbc:mysql://127.0.0.1:3306/seata?useSSL=false&serverTimezone=UTC"
      user = "root"
      password = "tiger"
      minConn = 5
      maxConn = 30
      globalTable = "global_table"
      branchTable = "branch_table"
      lockTable = "lock_table"
      queryLimit = 100
      maxWait = 5000
    }
  
    ## redis store property
    redis {
      host = "127.0.0.1"
      port = "6379"
      password = ""
      database = "0"
      minConn = 1
      maxConn = 10
      queryLimit = 100
    }
  
  }
  

  • registry.conf

  registry {
    # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
    type = "eureka"
  
    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 = "ticket-seata"
      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 = "file"
  
    nacos {
      serverAddr = "127.0.0.1:8848"
      namespace = ""
      group = "SEATA_GROUP"
      username = ""
      password = ""
    }
    consul {
      serverAddr = "127.0.0.1:8500"
    }
    apollo {
      appId = "seata-server"
      apolloMeta = "http://192.168.1.204:8801"
      namespace = "application"
    }
    zk {
      serverAddr = "127.0.0.1:2181"
      sessionTimeout = 6000
      connectTimeout = 2000
      username = ""
      password = ""
    }
    etcd3 {
      serverAddr = "http://localhost:2379"
    }
    file {
      name = "file.conf"
    }
  }
  

• 配置文件为properties格式

  添加以下内容,与file.conf中的 vgroup_mapping.my_test_tx_group对应

  spring.cloud.alibaba.seata.tx-service-group=my_test_tx_group
  

注意：

• 每个要使用的seata的服务都要引入上述两个conf文件

• 由于在OpenFeign调用服务的时候默认的处理时间可能不够，因此要修改连接时间，在propertieswen文件中添加

feign.client.config.default.connectTimeout= 3000
feign.client.config.default.readTimeout= 12000

3.3 开始分布式事务

• 在具体的serverImpl类中的要进行事务控制的方法上添加@GlobalTransactional注解

  

3.4 启动

步骤:

• 应该先启动注册中心
• 到seata文件夹下的bin启动seata-server.bat文件
• 启动其余服务