第五章 Seata事务框架笔记

ゝ一世哀愁。 2023-02-16 04:14 21阅读 0赞

# **一、Seata概念介绍** #

## **1、Seata 是什么?** ##

Seata是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata将为用户提供了AT、TCC、SAGA和XA事务模式，为用户打造一站式的分布式解决方案。

**seata下载****：**http://seata.io/en-us/blog/download.html

选择自己的版本下载

**seat中文文档：**http://seata.io/zh-cn/docs/overview/what-is-seata.html

这里我们只介绍默认的AT模式与TCC模式。

## **2、Seata默认的AT模式介绍** ##

### **前提** ###

基于支持本地ACID事务的关系型数据库。

Java应用，通过JDBC访问数据库。

### **整体机制** ###

两阶段提交协议的演变：

### **一阶段：** ###

业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。

### **二阶段：** ###

提交异步化，非常快速地完成。

回滚通过一阶段的回滚日志进行反向补偿。

### **写隔离** ###

一阶段本地事务提交前，需要确保先拿到全局锁。拿不到全局锁，不能提交本地事务。拿全局锁的尝试被限制在一定范围内，超出范围将放弃，并回滚本地事务，释放本地锁。以一个示例来说明：

两个全局事务tx1和tx2，分别对a表的m字段进行更新操作，m的初始值1000。

tx1先开始，开启本地事务，拿到本地锁，更新操作m = 1000 - 100 = 900。本地事务提交前，先拿到该记录的全局锁，本地提交释放本地锁。tx2后开始，开启本地事务，拿到本地锁，更新操作m = 900 - 100 = 800。本地事务提交前，尝试拿该记录的全局锁，tx1全局提交前，该记录的全局锁被tx1持有，tx2需要重试等待全局锁。

tx1二阶段全局提交，释放**全局锁** 。tx2拿到**全局锁** 提交本地事务。

如果tx1的二阶段全局回滚，则tx1需要重新获取该数据的本地锁，进行反向补偿的更新操作，实现分支的回滚。

此时，如果tx2仍在等待该数据的全局锁，同时持有本地锁，则tx1的分支回滚会失败。分支的回滚会一直重试，直到tx2的全局锁等锁超时，放弃全局锁并回滚本地事务释放本地锁，tx1的分支回滚最终成功。

因为整个过程全局锁在tx1结束前一直是被tx1持有的，所以不会发生脏写的问题。

### **读隔离** ###

在数据库本地事务隔离级别读已提交（Read Committed）或以上的基础上，Seata（AT 模式）的默认全局隔离级别是读未提交（Read Uncommitted）。

如果应用在特定场景下，必需要求全局的读已提交 ，目前Seata的方式是通过SELECT FOR UPDATE语句的代理。

SELECT FOR UPDATE语句的执行会申请全局锁 ，如果 全局锁被其他事务持有，则释放本地锁（回滚 SELECT FOR UPDATE语句的本地执行）并重试。这个过程中，查询是被block住的，直到 全局锁拿到，即读取的相关数据是 已提交 的，才返回。

出于总体性能上的考虑，Seata目前的方案并没有对所有SELECT语句都进行代理，仅针对FOR UPDATE 的SELECT语句。

## **3、TCC模式** ##

回顾总览中的描述：一个分布式的全局事务，整体是**两阶段提交**的模型。全局事务是由若干分支事务组成的，分支事务要满足**两阶段提交**的模型要求，即需要每个分支事务都具备自己的：

*  一阶段prepare行为
 *  二阶段commit或rollback行为

根据两阶段行为模式的不同，我们将分支事务划分为Automatic (Branch) Transaction Mode和Manual (Branch) Transaction Mode。

**AT模式基于支持本地ACID事务的关系型数据库：**

*  一阶段prepare行为：在本地事务中，一并提交业务数据更新和相应回滚日志记录。
 *  二阶段commit行为：马上成功结束，自动异步批量清理回滚日志。
 *  二阶段rollback行为：通过回滚日志，自动生成补偿操作，完成数据回滚。

**相应的TCC模式，不依赖于底层数据资源的事务支持：**

*  一阶段prepare行为：调用自定义的prepare逻辑。
 *  二阶段commit行为：调用自定义的commit逻辑。
 *  二阶段rollback行为：调用自定义的rollback逻辑。

**所谓TCC模式，是指支持把自定义的分支事务纳入到全局事务的管理中。**

# **二、seata服务端与nacos整合开发** #

## **1、配置seata的服务器端的数据库** ##

[https://github.com/seata/seata/tree/1.2.0/script][https_github.com_seata_seata_tree_1.2.0_script]

server端脚本如下，同时也支持docker、kubernatesa安装

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70][]

1）全局事务会话信息由3块内容构成，全局事务-->分支事务-->全局锁，对应表global\_table、branch\_table、lock\_table 1；建立一个数据库名字随意用来做seata服务端的库，存储全局事务的会话信息

2）拿到服务端数据库的脚本文件执行并且建立表第1步三张表

[https://github.com/seata/seata/tree/1.2.0/script/server/db][https_github.com_seata_seata_tree_1.2.0_script_server_db] 上面地址可以拿到数据库脚本，选择mysql然后自己执行。

## **2、修改服务端启动包的文件** ##

1）启动包: seata-->conf-->file.conf，修改store.mode="db"。

2）修改file.conf自己的db连接信息

*\#\# transaction log store, only used in seata-server*  
store \{   
  *\#\# store mode: file、db*  
*  *mode = "db"  
  *\#\# database store property*  
*  *db \{   
    *\#\# the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.*  
*    *datasource = "druid"  
    *\#\# mysql/oracle/postgresql/h2/oceanbase etc.*  
*    *dbType = "mysql"  
    driverClassName = "com.mysql.jdbc.Driver"  
    url = "jdbc:mysql://localhost:3306/seata?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true"  
    user = "root"  
    password = "root"  
    minConn = 5  
    maxConn = 1000  
    globalTable = "global\_table"  
    branchTable = "branch\_table"  
    lockTable = "lock\_table"  
    queryLimit = 100  
    maxWait = 5000  
  \}  
\}

这些信息是存在file.conf当中的也就是seata启动的时候会去读取这个配置文件；如果我们使用nacos可以把这些信息放到nacos的注册中心，从而实现动态更新。

如果你需要把这些信息放到nacos配置中心就需要修改seata-->conf-->registy.conf文件当中的注册中心和配置中心的信息，修改成为nacos；（为什么需要修改config和register呢？因为如果你的seata服务器想要去配置中心读取配置，那么一定到得把自己注册到nacos；所以registy.conf当中需要配置注册中心的地址也需要配置配置中心的地址） 这样我们如果后面启动seata就可以看到他是作为了一个nacos的客户端注册到了nacos的注册中心的；记住这点seata已经可以作为客户端注册到nacos了。

## **3、Seata部署指南** ##

Seata分TC、TM和RM三个角色，TC（Server端）为单独服务端部署，TM和RM（Client端）由业务系统集成。

资源目录介绍：[https://github.com/seata/seata/tree/1.2.0/script][https_github.com_seata_seata_tree_1.2.0_script]

Client：存放client端sql脚本，参数配置。

config-center：各个配置中心参数导入脚本，config.txt(包含server和client，原名nacos-config.txt)为通用参数文件。

Server：server端数据库脚本及各个容器配置。

**注意事项：**

**seata-spring-boot-starter**

内置GlobalTransactionScanner自动初始化功能，若外部实现初始化，请参考SeataAutoConfiguration保证依赖加载顺序

默认开启数据源自动代理，可配置seata.enable-auto-data-source-proxy: false关闭

**spring-cloud-alibaba-seata**

[查看版本说明][Link 1] 2.1.0内嵌seata-all 0.7.1，2.1.1内嵌seata-all 0.9.0，2.2.0内嵌seata-spring-boot-starter 1.0.0

2.1.0和2.1.1兼容starter解决方案:

2.1.0和2.1.1兼容starter解决方案: @SpringBootApplication注解内exclude掉spring-cloud-alibaba-seata内的com.alibaba.cloud.seata.GlobalTransactionAutoConfiguration

## **3、把配置信息上传到nacos配置中心** ##

**第一步：****启动nacos**

第二步：访问[https://github.com/seata/seata/tree/1.2.0/script/config-center][https_github.com_seata_seata_tree_1.2.0_script_config-center]到这个地址上面获取config.txt，然后把config.txt复制到idea当中去编辑，推荐使用idea编辑，因为可能有编码原因，保留自己想要的信息。

这里给出的是精简后的，你们需要自己对应修改自己的信息；主要是数据库配置信息。注意这些信息是服务器端和客户端都要使用的；由于上面我们已经把seata注册到了nacos；所以他的file.conf当中的信息可以直接从nacos读取；也就是下面我们配置的信息；换句话说如果你配置了seata作为nacos的一个客户端去读取配置那么file.conf可以不用配置了；这两步是重复的；这也是网上很多资料没有说明的；换成大白话的意思就是你如果配置了registy.conf那么file.conf当中的信息基本无效——都是从配置中心读取；甚至可以删了file.conf；你们可以自己测试；如果你不配置registy.conf，那么seata就会从file.conf当中读取配置；所以file.conf和registy.conf其实只需要配置一个。

### **3.1、精简后的配置如下：** ###

\#事务分组——my\_test\_tx\_group 这值会在我们客户端对应，需要注意  
service.vgroupMapping.my\_test\_tx\_group=default  
service.default.grouplist=127.0.0.1:8091  
store.mode=db  
store.db.datasource=druid  
store.db.dbType=mysql  
store.db.driverClassName=com.mysql.jdbc.Driver  
store.db.url=jdbc:mysql://ip::3306/seata?useUnicode=true  
store.db.user=root  
store.db.password=root  
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

**那么这些精简后的配置如何传到nacos呢？**

[https://github.com/seata/seata/tree/1.2.0/script/config-center][https_github.com_seata_seata_tree_1.2.0_script_config-center] **从上面这个地址下载nacos文件下面的****nacos-config.sh**文件然后执行sh 你下载后的路径/nacos-config.sh；当然如果你的nacos地址不是默认的，需要修改naocs-config.sh当中指定你的路径；也可以在sh命令后面指定；

[https://github.com/seata/seata/tree/1.2.0/script/config-center][https_github.com_seata_seata_tree_1.2.0_script_config-center]这个地址里面有个README.md文件有说明。

### **3.2、Nacos执行shell命令配置：** ###

*bash*  
*sh $\{SEATAPATH\}/script/config-center/nacos/nacos-config.sh -h localhost -p 8848 -g SEATA\_GROUP -t* *‘**namespace**’*

**参数说明：**

\-h: host, the default value is localhost

\-p: port, the default value is 8848

\-g: Configure grouping, the default value is 'SEATA\_GROUP'

\-t: Tenant information, corresponding to the namespace ID field of Nacos, the default value is ''

注意：

这里我们在Nacos配置里面创建一个namespace叫seata，ID为seata\_id

### **3.3、cd到Nacos文件夹所在目录执行命令：** ###

sh nacos-config.sh -h localhost -p 8848 -g SEATA\_GROUP -t seata\_id

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 1][]

如果使用的都是默认配置则可以不指定参数，因为nacos-config.sh脚本里面已经包含了默认参数。

if \[\[ -z $\{host\} \]\]; then

host=localhost

if \[\[ -z $\{port\} \]\]; then

port=8848

if \[\[ -z $\{group\} \]\]; then

group="SEATA\_GROUP"

if \[\[ -z $\{tenant\} \]\]; then

tenant=""

执行完成之后，你可以看到nacos的配置中心上面多了很多配置；注意这个时候seata服务器用的就是这些配置了。你可以修改一个错误的试试是不能启动seata服务器的。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 2][]

## **4、启动seata服务器** ##

讲道理可以启动成功——注意不要用jdk11(测试过有问题)

直接双击seata-server.bat就可以默认启动，默认端口为8091,如果想修改端口，也可以用配置项启动，参数如下：

Options:

--host, -h

The host to bind.

Default: 0.0.0.0

--port, -p

The port to listen.

Default: 8091

--storeMode, -m

log store mode : file、db

Default: file

--help

例如需要修改默认端口:

seata-server.bat -p 18091

sh seata-server.sh -p 18091

不过linux中默认不会后台启动，需要启动命令支持一下：

nohup sh seata-server.sh -p 18091 > catalina.out 2>&1 &

当我们看到如下日志信息代表启动成功：

:RegisterTMRequest\{applicationId='uni-meta-consumer', transactionServiceGroup='my\_test\_tx\_group'\},

channel:\[id: 0x8aedbc89, L:/192.168.41.241:8091 - R:/192.168.41.241:61720\]

# **三、新建seata客户端模块** #

## **1、建立微服务项目springcloudalibaba-seata** ##

**注意这里测试我们使用版本信息如下：**

Springcloud版本：Hoxton.SR3

spring-cloud-alibaba：2.2.0.RELEASE

Springboot版本：2.2.6.RELEASE

io.seata版本：1.2.0

### **1.1、添加pom依赖** ###

maven引入seata-spring-boot-starter、spring-cloud-alibaba-seata这两个jar其中seata-spring-boot-starter选择你对应的seata版本比如1.2。

但是spring-cloud-alibaba-seata这个jar当中自动依赖了seata-spring-boot-starter但是版本对应不上；比如spring-cloud-alibaba-seata当中依赖的seata-spring-boot-starter可能是0.9；所以需要剔除他。

<dependencyManagement>  
    <dependencies>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-dependencies</artifactId>  
            <version>Hoxton.SR3</version>  
            <type>pom</type>  
            <scope>import</scope>  
        </dependency>  
        <dependency>  
            <groupId>com.alibaba.cloud</groupId>  
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>  
            <version>2.2.0.RELEASE</version>  
            <type>pom</type>  
            <scope>import</scope>  
        </dependency>  
    </dependencies>  
</dependencyManagement>  
<dependencies>  
    <dependency>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-web</artifactId>  
    </dependency>  
    <dependency>  
        <groupId>com.alibaba.cloud</groupId>  
        <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>  
    </dependency>  
    <dependency>  
        <groupId>com.alibaba.cloud</groupId>  
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>  
    </dependency>  
    <dependency>  
        <groupId>org.springframework.cloud</groupId>  
        <artifactId>spring-cloud-starter-openfeign</artifactId>  
    </dependency>  
    **  
*    *<dependency>  
        <groupId>io.seata</groupId>  
        <artifactId>seata-spring-boot-starter</artifactId>  
        <version>1.2.0</version>  
    </dependency>  
    **  
*    *<dependency>  
        <groupId>com.alibaba.cloud</groupId>  
        <artifactId>spring-cloud-alibaba-seata</artifactId>  
        <exclusions>  
            <exclusion>  
                <groupId>io.seata</groupId>  
                <artifactId>seata-spring-boot-starter</artifactId>  
            </exclusion>  
        </exclusions>  
    </dependency>  
    <dependency>  
        <groupId>mysql</groupId>  
        <artifactId>mysql-connector-java</artifactId>  
    </dependency>  
</dependencies>

### **1.2、配置客户端的seata** ###

如果你的项目已经成为了nacos的客户端，那么直接可以从nacos读取第三步当中上传到nacos的各种配置；那么如何读取呢？ 首先得在客户端进行配置告诉seata客户端需要去nacos注册中心去读取seata的配置。

**配置客户端的yml读取nacos上的seata的配置**

打开这个地址[https://github.com/seata/seata/tree/1.2.0/script/client][https_github.com_seata_seata_tree_1.2.0_script_client] 找到spring文件夹，找到application.yml；这个yml是通用配置；你需要精简；我给出精简后的配置如下：

server:  
  port: 7100  
seata:  
  enabled: true  
  application-id: springcloudalibaba-seata  
  tx-service-group: my\_test\_tx\_group  
  enable-auto-data-source-proxy: true  
  use-jdk-proxy: true  
  config:  
    type: nacos  
    nacos:  
      namespace: 162ee4db-c19c-40df-8b90-3f6db9610bd1  
      serverAddr: 192.168.41.241:8848  
      group: SEATA\_GROUP  
      userName: ""  
      password: ""  
  registry:  
    type: nacos  
    nacos:  
      application: seata-server  
      server-addr: 192.168.41.241:8848  
      namespace: 162ee4db-c19c-40df-8b90-3f6db9610bd1  
      userName: ""  
      password: ""  
*\# The bean 'springcloudalibaba-provider-user.FeignClientSpecification' could not be registered.*  
*\# A bean with that name has already been defined and overriding is disabled.*  
spring:  
  main:  
    allow-bean-definition-overriding: true

bootstrap.yml配置信息：

spring:  
  cloud:  
    nacos:  
      discovery:  
        server-addr: 192.168.41.241:8848  
      config: *\#这里一定记得配置*  
*        *server-addr: 192.168.41.241:8848  
  application:  
    name: springcloudalibaba-seata

**特别注意：**

这个配置需要在你的每一个参与分布式事务的项目当中加上——直接写到项目的yml当中就可以了。这个配置的意思就是让我们的seata客户端直接从配置中心拉取配置；

## **2、分布式事务测试场景设计** ##

当然分布式事务肯定需要是至少两个项目，所以你在两个项目当中都加上这些依赖，如果你是nacos的自然还需要加上其他jar；详见下文。

建好项目之后，我们模拟一个分布式事务的场景 比如A调用B项目，在B项目里面操作数据库加上A项目当中的AController当中的a()；调用B项目当中的BController当中的b()；b方法操作数据库；那么则在A项目当中的AController的a()上面加上@GlobalTransactional这个注解

@RestController  
public class A\{   
   ** @GlobalTransactional**  
    @GetMapping("xxxxxx")  
    public string a()\{   
        通过feign调用b  
    \}  
\}

**注意：****@GlobalTransactional****注解就是分布式事务注解。**

### **2.1、服务消费端调用提供端/update接口** ###

springcloudalibaba-seata模块controller层入口代码如下：

@RestController  
@RefreshScope  
@RequestMapping("seata")  
public class IndexController \{   
    @Autowired  
    ProductService productService;  
    @GetMapping("/update")  
    public int update(@RequestParam String name)\{   
        int result =  productService.update(name);  
        return result;  
    \}  
\}

### **2.2、业务层代码实现** ###

**特别注意：**seata事务注解@GlobalTransactional 标注的方法将会被seata事务框架管理，方法调用我们通过feign的方式实现远程调用（访问springcloudalibaba-seata-provider模块的updata接口）

@Service  
public class ProductServiceImpl implements ProductService \{   
    @Autowired  
    SeataFeignClient userCenterFeignClient;  
    **@GlobalTransactional**** // seata事务注解**  
    public int update(String name) \{   
        *// 使用feign的方式实现调用*  
*        *int result = userCenterFeignClient.update(name);  
        System.*out*.println("ProductServiceImpl----update name==>"\+name+", result==="\+result);  
        if(name.equals("500"))  
            System.*out*.println("xxxxxxxxxxxx"+1/0);  
        return result;  
    \}  
\}

### **2.3、FeignClien接口层代码见：** ###

com.chj.feign.SeataFeignClient

*//@FeignClient(name = "springcloudalibaba-provider-user")*  
@FeignClient(name = "springcloudalibaba-seata-provider")  
*//@FeignClient(name = "springcloudalibaba-provider-user", configuration = UserFeignLogConfiguration.class) //细粒度代码方式配置*  
*//@FeignClient(name = "springcloudalibaba-provider-user", configuration = GlobalFeignConfiguration.class) // 代码方式全局配置*  
*//@FeignClient(name = "springcloudalibaba-provider-user"，*  
 *   fallback = UserCenterFeignClientFallback.class,*  
*//        fallbackFactory = UserCenterFeignClientFallbackFactory.class*  
*//)*  
public interface SeataFeignClient \{   
*    /\*\**  
*     \* http://springcloudalibaba-seata-provider/update?name=xxx*  
*     \*/*  
*    *@GetMapping("provider/update")  
    int update(@RequestParam String name);  
\}

至此seata client端的第一个业务调用端的代码实现已经ok，下面我们接着编写服务提供端代码。

# **四、服务提供端代码实现** #

## **1、新建seata业务端模块** ##

新建模块springcloudalibaba-seata-provider

### **1.1、添加pom依赖：** ###

注意这里测试我们使用版本信息如下：

Springcloud版本：Hoxton.SR3

spring-cloud-alibaba：2.2.0.RELEASE

Springboot版本：2.2.6.RELEASE

Mybatis通用版本：tk.mybatis-2.1.5

mybatis.generator：<version>1.3.6</version> --通过maven方式MGB

<parent>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-parent</artifactId>  
    <version>2.2.6.RELEASE</version>  
  </parent>  
  <dependencyManagement>  
    <dependencies>  
      <dependency>  
        <groupId>org.springframework.cloud</groupId>  
        <artifactId>spring-cloud-dependencies</artifactId>  
        <version>Hoxton.SR3</version>  
        <type>pom</type>  
        <scope>import</scope>  
      </dependency>  
      <dependency>  
        <groupId>com.alibaba.cloud</groupId>  
        <artifactId>spring-cloud-alibaba-dependencies</artifactId>  
        <version>2.2.0.RELEASE</version>  
        <type>pom</type>  
        <scope>import</scope>  
      </dependency>  
    </dependencies>  
  </dependencyManagement>  
  <dependencies>  
    <dependency>  
      <groupId>org.springframework.boot</groupId>  
      <artifactId>spring-boot-starter-web</artifactId>  
    </dependency>  
    **  
*    *<dependency>  
      <groupId>com.alibaba.cloud</groupId>  
      <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>  
    </dependency>  
    <dependency>  
      <groupId>com.alibaba.cloud</groupId>  
      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>  
      <exclusions>  
        <exclusion>  
          <groupId>com.alibaba.nacos</groupId>  
          <artifactId>nacos-client</artifactId>  
        </exclusion>  
      </exclusions>  
    </dependency>  
    <dependency>  
      <groupId>com.alibaba.nacos</groupId>  
      <artifactId>nacos-client</artifactId>  
    </dependency>  
    <dependency>  
      <groupId>org.springframework.cloud</groupId>  
      <artifactId>spring-cloud-starter-openfeign</artifactId>  
    </dependency>  
    **  
*    *<dependency>  
      <groupId>io.github.openfeign</groupId>  
      <artifactId>feign-httpclient</artifactId>  
    </dependency>  
    **  
*   ** *<dependency>  
      <groupId>io.seata</groupId>  
      <artifactId>seata-spring-boot-starter</artifactId>  
      <version>1.2.0</version>  
    </dependency>  
    **  
*    *<dependency>  
      <groupId>com.alibaba.cloud</groupId>  
      <artifactId>spring-cloud-alibaba-seata</artifactId>  
      <exclusions>  
        <exclusion>  
          <groupId>io.seata</groupId>  
          <artifactId>seata-spring-boot-starter</artifactId>  
        </exclusion>  
      </exclusions>  
    </dependency>  
    **  
*    *<dependency>  
      <groupId>tk.mybatis</groupId>  
      <artifactId>mapper-spring-boot-starter</artifactId>  
      <version>2.1.5</version>  
    </dependency>  
    **  
*    *<dependency>  
      <groupId>mysql</groupId>  
      <artifactId>mysql-connector-java</artifactId>  
      <version>5.1.29</version>  
    </dependency>  
    <dependency>  
      <groupId>org.projectlombok</groupId>  
      <artifactId>lombok</artifactId>  
      <optional>true</optional>  
    </dependency>  
  </dependencies>  
  **  
*  *<build>  
    <plugins>  
      <plugin>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-maven-plugin</artifactId>  
      </plugin>  
      **  
*      *<plugin>  
        <groupId>org.mybatis.generator</groupId>  
        <artifactId>mybatis-generator-maven-plugin</artifactId>  
        <version>1.3.6</version>  
        <configuration>  
          <configurationFile>  
            $\{basedir\}/src/main/resources/generator/generatorConfig.xml  
          </configurationFile>  
          <overwrite>true</overwrite>  
          <verbose>true</verbose>  
        </configuration>  
        <dependencies>  
          <dependency>  
            <groupId>mysql</groupId>  
            <artifactId>mysql-connector-java</artifactId>  
            <version>5.1.29</version>  
          </dependency>  
          <dependency>  
            <groupId>tk.mybatis</groupId>  
            <artifactId>mapper</artifactId>  
            <version>4.1.5</version>  
          </dependency>  
        </dependencies>  
      </plugin>  
    </plugins>  
  </build>  
</project>

### **1.2、添加配置信息** ###

application.yml

server:  
  port: 7200  
spring:  
  datasource:  
    driverClassName: com.mysql.jdbc.Driver  
    url: jdbc:mysql://localhost:3306/seata\_provider?characterEncoding=utf8&serverTimezone=UTC  
    username: root  
    password: root  
*  *main:  
    allow-bean-definition-overriding: true  
seata:  
  enabled: true  
  application-id: springcloudalibaba-seata-provider  
  tx-service-group: my\_test\_tx\_group  
  enable-auto-data-source-proxy: true  
  use-jdk-proxy: true  
  config:  
    type: nacos  
    nacos:  
      namespace: 162ee4db-c19c-40df-8b90-3f6db9610bd1  
      serverAddr: 192.168.41.241:8848  
      group: SEATA\_GROUP  
      userName: ""  
      password: ""  
  registry:  
    type: nacos  
    nacos:  
      application: seata-server  
      server-addr: 192.168.41.241:8848  
      namespace: 162ee4db-c19c-40df-8b90-3f6db9610bd1  
      userName: ""  
      password: ""  
management:  
  endpoints:  
    web:  
      exposure:  
        include: '\*'  
  endpoint:  
    health:  
      show-details: always  
*\# mybatis配置mapper 可以通过注解代替 @MapperScan(basePackages = "扫描包")*

bootstrap.yml

### **1.3、启动来代码** ###

注意添加Nacos服务发现注解@EnableDiscoveryClient与mybatis扫描注解

@MapperScan(basePackages = "com.chj.dao")  
@SpringBootApplication  
@EnableDiscoveryClient  
public class SeataProviderApplication \{   
    public static void main(String\[\] args) \{   
        SpringApplication.*run*(SeataProviderApplication.class, args);  
    \}  
\}

### **1.4、业务端代码实现** ###

控制访问代码如下：com.chj.controller.SeataController

@Slf4j  
@RestController  
@RefreshScope  
@RequestMapping("provider")  
public class SeataController \{   
    @Autowired  
    ProductService productService;  
    @GetMapping("/update")  
    public int update(@RequestParam String name)\{   
        int result =  productService.update(name);  
        *log*.info("springcloudalibaba-provider-user--update--result===="\+result);  
        return result;  
    \}  
\}

**注意：该接口是暴露给服务消费端（springcloudalibaba-seata）调用的**

# **五、启动服务测试** #

需要在你的客户端操作的数据库当中建立undo\_log表；这个表用来实现sql反向补偿也就是回滚的信息，这个表的见表语句——[https://github.com/seata/seata/tree/1.2.0/script/client/at/db][https_github.com_seata_seata_tree_1.2.0_script_client_at_db] 注意是建立在你的微服务所对应的库中；比如你的B服务链接了X库；那么则在x库中建立这个表；如果你的A服务链接了Y库；则Y库也需要这个表

## **1、环境准备** ##

首先启动Nacos服务端与seata服务端

然后分别启动seata的服务提供端与服务消费端

## **2、访问接口测试** ##

### **2.1、正常参数结果测试** ###

因为我们代码中设置了当参数值为500的时候，会抛出异常，然后数据库数据应该回滚。

访问：[http://localhost:7100/seata/update?name=200][http_localhost_7100_seata_update_name_200]

数据可以正常修改，查看数据库如下所示：

![20200607223642481.png][]

### **2.2、异常情况测试** ###

这次我们参数值设为500，再次访问结果如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 3][]

我们可以通过debug模式，在事务方式抛出异常前查看数据库信息：

![20200607223542508.png][]

可以看到在代码执行结束前，数据库数据已经别修改了，接着我们让代码执行结束，再次查看数据库：

![20200607223527152.png][]

发现数据有回到了200，说明我们的代码确实回滚了这个事务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 4][]

**查看undo\_log表信息：**

![20200607223449405.png][]

其中字段rollback字段的内ring信息如下：

INSERT INTO seata\_provider.undo\_log ( id, branch\_id, xid, context, rollback\_info, log\_status, log\_created, log\_modified ) VALUES ( 7, 2012067280, '192.168.41.241:8091:2012067277', 'serializer=jackson', 0 x7B7D, 1, '2020-05-19 16:34:21', '2020-05-19 16:34:21' );

# **六、Seata源码方式配置服务** #

## **1、下载源码构建环境** ##

第一步：GitHub下载源码：这里我们选择develop版本：

下载地址：[http://seata.io/en-us/blog/download.html][http_seata.io_en-us_blog_download.html]

第二步：执行mvnw.cmd --下载构建maven环境，统一maven环境配置管理（自带）

备注：mvnw.cmd里面配置会下载maven3.6.0建立自己的maven仓库，这里我们可以自己配置指定maven地址：在seata-1.2.0\\.mvn\\wrapper\\maven-wrapper.properties文件中可以指定maven安装包地址。

distributionUrl=https://repo1.maven.org/maven2/org/apache/maven/apache-maven/3.6.0/apache-maven-3.6.0-bin.zip

这里我们改为自己下载好的maven地址：

distributionUrl=file://D:/tools/maven/apache-maven-3.6.3-bin.zip

第三步：maven环境准备过程会很漫长，构建好之后我们可以找到server项目里面的启动来Server，执行里面的main方法即可启动代码。

第四步：在启动之前先要修改配置

file.conf与registry.conf

## **2、新建业务端模块测试** ##

**Seata之所以可以完成分布式事务是因为——它的数据源需要去代理**

Seata客户端配置文件application.yml中的数据源代理配置如下所示：

seata:  
  enabled: true  
  application-id: springcloudalibaba-seata  
  tx-service-group: my\_test\_tx\_group  
  enable-auto-data-source-proxy: true *\# 开启数据源代理（实现分布式事务的原因）*  
*  *use-jdk-proxy: true

在seata1.0之前需要代码里面配置数据源代理代码实现，但是在1.0之后，spring帮助seata代理了数据源，所以我们只需要配置enable-auto-data-source-proxy: true代码里面注入数据源的时候可以直接注入：

代码示例如下：

@Configuration  
@MapperScan(basePackages = "com.chj.dao.user", sqlSessionFactoryRef = "test1SqlSessionFactory")  
public class DataSource1Config \{   
    @Bean(name = "test1DataSource")  
    @Primary  
    public DataSource testDataSource(DBConfig1 dbConfig1) \{   
        DruidDataSource druidDataSource = new DruidDataSource();  
        druidDataSource.setDriverClassName(dbConfig1.getDriverClassName());  
        druidDataSource.setUrl(dbConfig1.getJdbcUrl());  
        druidDataSource.setPassword(dbConfig1.getPassword());  
        druidDataSource.setUsername(dbConfig1.getUsername());  
        return druidDataSource;  
    \}  
    *// 代理数据源*  
*//    @Bean*  
*//    public DataSourceProxy dataSourceProxy(DataSource dataSource)\{*   
*//        return new DataSourceProxy(dataSource);*  
*//    \}*  
*    *@Bean(name = "test1SqlSessionFactory")  
    @Primary  
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)  
            throws Exception \{   
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();  
        bean.setDataSource(dataSource);  
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/\*.xml"));  
        return bean.getObject();  
    \}

**备注：**

File.conf 与registry.conf其实是重复的配置，如果是使用了配置中心则file的方式就不需要了。

[https_github.com_seata_seata_tree_1.2.0_script]: https://github.com/seata/seata/tree/1.2.0/script
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200607224122151.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4,size_16,color_FFFFFF,t_70
[https_github.com_seata_seata_tree_1.2.0_script_server_db]: https://github.com/seata/seata/tree/1.2.0/script/server/db
[Link 1]: https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E
[https_github.com_seata_seata_tree_1.2.0_script_config-center]: https://github.com/seata/seata/tree/1.2.0/script/config-center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200607224025261.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200607223923990.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4,size_16,color_FFFFFF,t_70
[https_github.com_seata_seata_tree_1.2.0_script_client]: https://github.com/seata/seata/tree/1.2.0/script/client
[https_github.com_seata_seata_tree_1.2.0_script_client_at_db]: https://github.com/seata/seata/tree/1.2.0/script/client/at/db
[http_localhost_7100_seata_update_name_200]: http://localhost:7100/seata/update?name=200
[20200607223642481.png]: https://img-blog.csdnimg.cn/20200607223642481.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/2020060722360124.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4,size_16,color_FFFFFF,t_70
[20200607223542508.png]: https://img-blog.csdnimg.cn/20200607223542508.png
[20200607223527152.png]: https://img-blog.csdnimg.cn/20200607223527152.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200607223509896.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NjYxNDU4,size_16,color_FFFFFF,t_70
[20200607223449405.png]: https://img-blog.csdnimg.cn/20200607223449405.png
[http_seata.io_en-us_blog_download.html]: http://seata.io/en-us/blog/download.html