SEATA 分佈式事務入門DEMO

Simple Extensible Autonomous Transacation Architecture， seata是簡單的、可擴展、自主性高的分佈式架構

SEATA Server Configure

因咱們使用正式的1.0.0-GA 版本，網上大多數找到的說明都是0.X版本，有很多變更，好比，在server中取消了db_store.sql的腳本，如找不到相關內容，能夠經過源碼來查找，好比db腳本源碼： mysql db script

1. 下載 seata-server

2. 建立數據庫（seata）,可自定義，在file.conf中要用到。

   -- -------------------------------- 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;

3. 編輯file.conf配置文件

   service {
     #transaction service group mapping
     vgroup_mapping.sunrise_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
     #degrade current not support
     enableDegrade = false
     #disable
     disable = false
     #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
     max.commit.retry.timeout = "-1"
     max.rollback.retry.timeout = "-1"
   }
   
   ## transaction log store, only used in seata-server
   store {
     ## store mode: file、db
     mode = "db"
   
     ## file store property
     file {
       ## store location dir
       dir = "sessionStore"
     #degrade current not support
     enableDegrade = false
     #disable
     disable = false
     #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
     max.commit.retry.timeout = "-1"
     max.rollback.retry.timeout = "-1"
   }
   
   ## transaction log store, only used in seata-server
   store {
     ## store mode: file、db
     mode = "db"
   
     ## file store property
     file {
       ## store location dir
       dir = "sessionStore"
     }
   
     ## database store property
     db {
       ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
       datasource = "dbcp"
       ## mysql/oracle/h2/oceanbase etc.
       db-type = "mysql"
       driver-class-name = "com.mysql.jdbc.Driver"
       url = "jdbc:mysql://localhost:3306/seata"
       user = "wr"
       password = "wr"
       min-conn = 1
       max-conn = 3
       global.table = "global_table"
       branch.table = "branch_table"
       lock-table = "lock_table"
       query-limit = 100
     }
   }

4. 編輯conf/regiester.conf

   registry {
     # file 、nacos 、eureka、redis、zk、consul、etcd三、sofa
     # 更改1
     type = "eureka"
   
     nacos {
       serverAddr = "localhost"
       namespace = ""
       cluster = "default"
     }
     eureka {
         # 更改2
       serviceUrl = "http://localhost:21001/eureka"
       application = "default"
       weight = "1"
     }
     redis {
       serverAddr = "localhost:6379"
       db = "0"
     }
     zk {
       cluster = "default"
       serverAddr = "127.0.0.1:2181"
       session.timeout = 6000
       connect.timeout = 2000
     }
     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 = "localhost"
       namespace = ""
     }
     consul {
       serverAddr = "127.0.0.1:8500"
     }
     apollo {
       app.id = "seata-server"
       apollo.meta = "http://192.168.1.204:8801"
     }
     zk {
       serverAddr = "127.0.0.1:2181"
       session.timeout = 6000
       connect.timeout = 2000
     }
     etcd3 {
       serverAddr = "http://localhost:2379"
     }
     file {
       name = "file.conf"
     }
   }

   本次實現，咱們尚未添加configration的時候，所以只須要更改register塊中的相關屬性便可，在後續咱們實現了nacos config以後，再同步更新這裏。

5. 啓動服務端

   [root@localhost.localdomain /usr/local/geekplus/server/seata]# bin/seata-server.sh

在eureka中看到以下8091端口的服務以後，即啓動seata-server正常！

Client Configure

AT Model

須要在每個業務庫中添加數據表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;

Broadway-Demo

使用Springboot項目有一個小規律，我叫它爲使用三部曲。
依 broadway-ws-tally-service項目爲例：

• 第一步：加依賴

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

• 第二步：開啓註解

  @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)

  在這裏須要說明一下，咱們須要排除掉SpringBoot默認自動注入的DataSourceAutoConfigurationBean, 由於SEATA是基於數據源攔截來實現的分佈式事務，所以，咱們須要自定義數據源配置信息：

  package com.geekplus.broadway.ws.tally.application;
  
  import com.alibaba.druid.pool.DruidDataSource;
  import io.seata.rm.datasource.DataSourceProxy;
  import org.apache.ibatis.session.SqlSessionFactory;
  import org.mybatis.spring.SqlSessionFactoryBean;
  import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
  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 org.springframework.core.io.support.PathMatchingResourcePatternResolver;
  import javax.sql.DataSource;
  
  @Configuration
  public class DataSourceConfiguration {
      @Bean
      @ConfigurationProperties(prefix = "spring.datasource")
      public DataSource druidDataSource(){
          DruidDataSource druidDataSource = new DruidDataSource();
          return druidDataSource;
      }
  
      @Primary
      @Bean("dataSource")
      public DataSourceProxy dataSource(DataSource druidDataSource){
          return new DataSourceProxy(druidDataSource);
      }
  
      @Bean
      public SqlSessionFactory sqlSessionFactory(DataSourceProxy dataSourceProxy)throws Exception{
          SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
          sqlSessionFactoryBean.setDataSource(dataSourceProxy);
          sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                  .getResources("classpath*:/com/geekplus/*.xml"));
          sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
          return sqlSessionFactoryBean.getObject();
      }
  }

  該配置類，通常放在與啓動類相同的目錄便可！

• 第三部：改配置

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

  TIPS:
  tx-service-group 必定要server，client都要保持一致，不然能坑死你！
  tx-service-group 必定要server，client都要保持一致，不然能坑死你！
  tx-service-group 必定要server，client都要保持一致，不然能坑死你！

以上三步是大多數SpringBoot 項目的通用作法，固然咱們的SEATA暫時還不是那麼完善，配置信息目前還不支持在application.yml中配置徹底，所以，咱們須要2個核心的client 配置文件file.conf和register.conf.

• file.conf 該文件主要是用於鏈接RM的，咱們只須要關注上面所說的tx-service-group就行，其餘配置默認就能夠。

  transport {
    # tcp udt unix-domain-socket
    type = "TCP"
    #NIO NATIVE
    server = "NIO"
    #enable heartbeat
    heartbeat = true
    # the client batch send request enable
    enable-client-batch-send-request = true
    #thread factory for netty
    thread-factory {
      boss-thread-prefix = "NettyBoss"
      worker-thread-prefix = "NettyServerNIOWorker"
      server-executor-thread-prefix = "NettyServerBizHandler"
      share-boss-worker = false
      client-selector-thread-prefix = "NettyClientSelector"
      client-selector-thread-size = 1
      client-worker-thread-prefix = "NettyClientWorkerThread"
      # netty boss thread size,will not be used for UDT
      boss-thread-size = 1
      #auto default pin or 8
      worker-thread-size = 8
    }
    shutdown {
      # when destroy server, wait seconds
      wait = 3
    }
    serialization = "seata"
    compressor = "none"
  }
  
  service {
    #transaction service group mapping
    vgroup_mapping.sunrise_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
  }
  
  client {
    rm {
      async.commit.buffer.limit = 10000
      lock {
        retry.internal = 10
        retry.times = 30
        retry.policy.branch-rollback-on-conflict = true
      }
      report.retry.count = 5
      table.meta.check.enable = false
      report.success.enable = true
    }
    tm {
      commit.retry.count = 5
      rollback.retry.count = 5
    }
    undo {
      data.validation = true
      log.serialization = "jackson"
      log.table = "undo_log"
    }
    log {
      exceptionRate = 100
    }
    support {
      # auto proxy the DataSource bean
      spring.datasource.autoproxy = false
    }
   }

• register.conf該文件是用於指定註冊中心相關配置的，它有2個核心block：

  • registry塊
    此模板代表咱們的註冊中心使用類型，須要根據type設置來同步更新使用的配置信息，好比咱們使用的eureka，所以咱們更新eureka.serviceUrl="http://172.16.1.187:21001/eureka".
  • config 塊
    該模塊用來設置咱們的配置中心相關配置（此處後續更新，咱們會選擇apollo）

  registry {
    # file 、nacos 、eureka、redis、zk、consul、etcd三、sofa
    type = "eureka"
  
    nacos {
      serverAddr = "localhost"
      namespace = ""
      cluster = "default"
    }
    eureka {
      serviceUrl = "http://172.16.1.187:21001/eureka"
      application = "default"
      weight = "1"
    }
    redis {
      serverAddr = "localhost:6379"
      db = "0"
    }
    zk {
      cluster = "default"
      serverAddr = "127.0.0.1:2181"
      session.timeout = 6000
      connect.timeout = 2000
    }
    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 = "localhost"
      namespace = ""
    }
    consul {
      serverAddr = "127.0.0.1:8500"
    }
    apollo {
      app.id = "seata-server"
      apollo.meta = "http://192.168.1.204:8801"
    }
    zk {
      serverAddr = "127.0.0.1:2181"
      session.timeout = 6000
      connect.timeout = 2000
    }
    etcd3 {
      serverAddr = "http://localhost:2379"
    }
    file {
      name = "file.conf"
    }
  }