文章目錄

一、seata介紹
- 1. 什麼是 seata
- 2. seata 的基本原理
二、seata 環境搭建
- 1. 伺服器端環境搭建
- - 1.1 資料庫及表的建立
  - 1.2 修改伺服器端配置檔案
  - 1.3 同步config.txt檔案到nacos配置中心
- 2. 用戶端環境搭建
- - 2.1 引入pom依賴
  - 2.2 在application.yml檔案中配置seata資訊
  - 2.3 代理資料源配置
三、簡單測試

一、seata介紹

1. 什麼是 seata

seata 是一個分布式事務的解決方案，具有高性能和易用性的微服務架構。其前身是fescar。

seata給使用者提供了AT、TCC、XA和SAGA事務模型。

版本已經更新到了1.4.1，本文采用1.4.0版本進行搭建和測試。

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

文獻資料：http://seata.io

github位址：https://github.com/seata/seata/

2. seata 的基本原理

首先我們先看一張分布式環境下，服務與服務之間的調用關系圖：

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

其實分布式事務是由一批分支事務組成的全局事務，通常分支事務隻是本地事務。

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

seata的核心主要有三部分組成：

事務協調器（TC）：維護全局事務和分支事務的狀态，驅動全局事務送出或者復原。
事務管理器（TM）：定義全局事務的範圍：開啟全局事務，送出或復原全局事務（在分布式環境中相當于事務的發起方）。
資料總管（RM）：管理分支事務正在處理的資源，與TC進行對話以注冊分支事務并報告分支事務的狀态。并驅動分支事務的送出或者復原（在分布式環境中相當于事務的參與者）。

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試
seata管理的分布式事務的生命周期：
首先，需要建構一個全局事務的協調者TC。
發起方與參與方與全局事務協調者TC建立長連接配接。
發起方向全局事務協調者申請一個全局事務XID，緩存在本地線程中。
當發起方調用參與方的服務接口時，會将申請到的全局事務XID放入請求頭中。
參與方從請求頭中擷取XID，如果擷取成功，則會向全局事務協調者注冊(為參與方)，緩存XID到本地線程。執行完成之後送出本地事務，插入undo_log日志（後期用于復原使用）。
調用完成參與方服務接口，如果整個業務流程沒有異常，則會通知全局事務協調者，全局事務協調者通知所有的參與方送出事務。事務送出成功後，删除undo_log日志。
調用完成參與方服務接口，如果整個業務流程存在異常，則會通知全局事務協調者，全局事務協調者通知所有的參與方復原事務。事務復原時候，删除undo_log日志。

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

二、seata 環境搭建

seata環境搭建會使用到mysql及nacos環境。具體搭建步驟可參照之前釋出的文章，如有不詳細的地方，請指正。

1. 伺服器端環境搭建

下載下傳seata1.4.0：https://github.com/seata/seata/releases

下載下傳完成後解壓，找到seata\conf\README.md檔案，從下方擷取相應的用戶端配置及服務端資訊配置

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

[client] 主要是用戶端配置，undo_log日志等。
[server] 服務端部署腳本，比如使用db存儲模式的時候，會從這裡擷取建表語句。

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試
[config-center] 存儲配置中心的初始化腳本，将使用 配置.txt 作為初始配置

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

1.1 資料庫及表的建立

建立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(6),
    `gmt_modified`      DATETIME(6),
    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(128),
    `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;

在每一個資料庫中建立undo_log表

-- for AT mode you must to init this sql for you business database. the seata server not need it.
CREATE TABLE IF NOT EXISTS `undo_log`
(
    `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB
  AUTO_INCREMENT = 1
  DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';

建立業務庫user及表sys_user

CREATE TABLE `sys_user` (
  `id` int(11) NOT NULL,
  `user_name` varchar(32) DEFAULT NULL,
  `post` varchar(32) DEFAULT NULL,
  `is_delete` char(2) DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

建立業務庫member及表sys_member

CREATE TABLE `sys_member` (
  `id` int(11) NOT NULL,
  `member_name` varchar(32) DEFAULT NULL,
  `integral` decimal(11,0) DEFAULT NULL,
  `is_delete` char(2) DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

1.2 修改伺服器端配置檔案

修改seata\conf\file.conf檔案

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

修改seata\conf\registry.conf檔案

修改注冊類型為nacos

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

修改配置中心為nacos

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

上述配置說明：

nacos.serverAddr：注冊中心/配置中心位址
nacos.namespace：命名空間，如果不填寫預設為public
nacos.gorup：組
nacos.username：nacos使用者名
nacos.password：nacos密碼

1.3 同步config.txt檔案到nacos配置中心

将nacos-config.sh(下載下傳位址： [config-center] ) copy到seata\conf\目錄下

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

将config.txt（下載下傳位址： [config-center]）copy到seata\目錄下

copy到seata目錄下的原因是能夠使nacos-config.sh腳本讀取到

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

修改config.txt檔案，主要修改的幾個位置：

## 事務組，之後在用戶端配置時，要和這個一樣
service.vgroupMapping.my_test_tx_group=default
## seata伺服器位址
service.default.grouplist=192.168.0.130:8091 

##與 伺服器端中file.conf中相同
store.mode=db 
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://192.168.137.128:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123456
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000

執行建立指令。在gitbash中執行

sh nacos-config.sh -h 192.168.0.241 -p 8848 -g SEATA_GROUP -t 839c4f2a-612d-417a-9a7d-a4c60fc6bc33 -u nacos -w nacos

建立成功之後，在nacos的配置為：

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

config.txt原檔案内容如下：

transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
service.vgroupMapping.my_test_tx_group=default
service.default.grouplist=127.0.0.1:8091
service.enableDegrade=false
service.disableGlobalTransaction=false
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000
store.mode=file
store.publicKey=
store.file.dir=file_store/data
store.file.maxBranchSessionSize=16384
store.file.maxGlobalSessionSize=512
store.file.fileWriteBufferCacheSize=16384
store.file.flushDiskMode=async
store.file.sessionReloadReadSize=100
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=username
store.db.password=password
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
store.redis.mode=single
store.redis.single.host=127.0.0.1
store.redis.single.port=6379
store.redis.maxConn=10
store.redis.minConn=1
store.redis.maxTotal=100
store.redis.database=0
store.redis.password=
store.redis.queryLimit=100
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

2. 用戶端環境搭建

建立兩個項目分别為springboot-user和springboot-member。下方配置引入為共有的，兩個項目中都要引入。沒有貼出代碼配置為項目中私有的代碼，會在文章末尾給出下載下傳位址。

2.1 引入pom依賴

<dependency>
   <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    <version>2.2.0.RELEASE</version>
    <exclusions>
        <exclusion>
            <groupId>io.seata</groupId>
            <artifactId>seata-spring-boot-starter</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.4.0</version>
</dependency>

2.2 在application.yml檔案中配置seata資訊

seata:
    enabled: true
    enable-auto-data-source-proxy: true #代理資料源
    tx-service-group: my_test_tx_group #要與config.txt中的一緻
    registry:
        type: nacos #注冊類型
        nacos:
            application: seata-server
            server-addr: 192.168.0.241:8848
            username: nacos
            password: nacos
            namespace: 839c4f2a-612d-417a-9a7d-a4c60fc6bc33
    config:
        type: nacos # 配置中心類型
        nacos:
            server-addr: 192.168.0.241:8848
            group: SEATA_GROUP
            username: nacos
            password: nacos
            namespace: 839c4f2a-612d-417a-9a7d-a4c60fc6bc33
    service:
        vgroup-mapping:
            my_test_tx_group: default # 預設值，如果在使用事務注解時不指定，采用該預設值
        disable-global-transaction: false
    client:
        rm:
            report-success-enable: false

2.3 代理資料源配置

package com.lee.config;

/**
 * @author zfl_a
 * @date 2021/4/5
 * @project springboot_user
 */

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 DataSourceConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource() {
        // 或者使用其他資料源
        return new DruidDataSource();
    }

    @Primary
    @Bean
    public DataSource dataSource(DruidDataSource druidDataSource) {
        return new DataSourceProxy(druidDataSource);
    }
}

三、簡單測試

使用@GlobalTransactional注解，斷點打在調用積分成功之後

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

這時檢視資料庫是否插入成功

member表

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

undo_log表

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

放行之後發起方報錯，會向全局事務協調者彙報目前狀态，全局事務協調者通知參與方復原事務

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

復原之後，member表資料清空了

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

同樣undo_log表也清空了

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

項目位址：https://gitee.com/enthusiasts/springboot-seata.git

seata 分布式事務的環境搭建與使用一、seata介紹二、seata 環境搭建三、簡單測試

文章目錄

一、seata介紹

1. 什麼是 seata

2. seata 的基本原理

二、seata 環境搭建

1. 伺服器端環境搭建

1.1 資料庫及表的建立

1.2 修改伺服器端配置檔案

1.3 同步config.txt檔案到nacos配置中心

2. 用戶端環境搭建

2.1 引入pom依賴

2.2 在application.yml檔案中配置seata資訊

2.3 代理資料源配置

三、簡單測試

繼續閱讀

set define off關閉替代變量功能

報錯：'mysql' 不是内部或外部指令，也不是可運作的程式或批處理檔案。

android SQLite事務和kotlin協程

Linxu常用指令技巧彙總

ERROR 1 (HY000): Can't create/write to file '/tmp/#sql_4188_1.MYI' (Errcode: 28)

艱難安裝LDAP,SSL認證

《Linux指令行與Shell腳本程式設計大全第2版.布盧姆》pdf

MySQL的4種隔離級别？出現問題

XX系統實施過程問題總結

無元件上傳圖檔到資料庫中，最完整解決方案

【MySQL資料庫】資料庫索引事務1.索引2.事務

neo4j之cypher使用文檔

NOSQL安全攻擊

mybatis_入門程式Mybatis入門

登入plsql 報錯 the account is locked --使用者被鎖

SequoiaDB巨杉資料庫C++驅動概述