【Spring Cloud】之 Seata

迷南。 2022-12-14 12:26 170阅读 0赞

# 一、Seata 简介 #

--------------------

### 1、分布式事务问题 ###

单体应用被拆分成微服务应用，比如原来的三个模块被拆分成三个**独立的应用**，分别使用**三个独立的数据源**，业务操作需要调用三个服务来完成，此时，**每个服务内部的数据由本地事务来保证，但全局的数据一致性问题没法保证**。

总结来说就是：一次业务操作需要跨多个数据源或需要跨多个系统进行远程调用，就会产生分布式事务问题。

分布式系统中实现一致性的 Raft 算法：[http://thesecretlivesofdata.com/raft/][http_thesecretlivesofdata.com_raft]

### 2、Seata 介绍 ###

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务，其官网地址为：[http://seata.io/zh-cn/][http_seata.io_zh-cn]

Seata 是一个典型的分布式事务过程，分布式事务过程由一个 ID + 三个组件模型组成：

*  Transaction ID(XID)：全局唯一的事务 id
 *  三组件概念：
    
     *  Transaction Coordinator( TC )：事务协调器，维护全局事务的运行状态，负责协调并驱动全局事务的提交或回滚
     *  Transaction Manager( TM )：控制全局事务的边界，负责开启一个全局事务，并最终发起全局提交或全局回滚的决议
     *  Resource Manager( RM )：控制分支事务，负责分支注册、状态汇报，并接受事务协调的指令，驱动分支(本地)事务的提交和回滚

其处理过程如下：

![在这里插入图片描述][20201013173615874.png_pic_center]

1.  TM 向 TC 申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的 XID；
2.  XID 在微服务调用链路的上下文中传播；
3.  RM 向 TC 注册分支事务，将其纳入 XID 对应全局事务的管辖；
4.  TM 向 TC 发起针对 XID 的全局提交或回滚决议；
5.  TC 调度 XID 下管辖的全部分支事务完成提交或回滚请求。

# 二、Seata 应用 #

--------------------

### 1、安装 Seata-Server ###

官网下载地址为：[https://github.com/seata/seata/releases][https_github.com_seata_seata_releases]

这里需要注意一下：只有 0.9 版本及以下才用 `db_store.sql` 和 `db_undo_log.sql` 文件。从 1.0 版本之后就移除了很多关键的文件。

### 2、修改 file.conf 配置文件 ###

找到 `seata/conf` 目录下的 `file.conf` 文件，修改之前先进行备份，主要修改内容为：自定义事务组名称 + 事务日志存储模式为db + 数据库连接

# 修改 service 模块的事务组名称 
    service { 
      #vgroup->rgroup
      vgroup_mapping.my_test_tx_group = "my_tx_group"
      #only support single node
      default.grouplist = "127.0.0.1:8091"
      #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"
    }
    
    store { 
      # 修改事务日志存储模式为 db
      mode = "db" 	
      
      # 修改数据库连接信息
      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://127.0.0.1:3306/seata"
        user = "root"
        password = "root"
        min-conn = 1
        max-conn = 3
        global.table = "global_table"
        branch.table = "branch_table"
        lock-table = "lock_table"
        query-limit = 100
      }
    }

### 3、建库建表 ###

在 MySQL 5.7 数据库新建数据库 seata，并运行 `seata/conf` 目录下的 `db_store.sql` 文件。

### 4、修改注册中心信息 ###

编辑 `seata/conf` 目录下的 `registry.conf` 配置文件：

registry { 
      # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
      type = "nacos"	# 修改注册类型为 nacos
    
      nacos { 
        serverAddr = "localhost:8848"	# 修改 nacos 注册中心地址
        namespace = ""
        cluster = "default"
      }
      ......
    }

目的是：指明注册中心为 nacos，及修改 nacos 连接信息

### 5、项目整合 Seata ###

1）、引入依赖：

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        <exclusions>
            <exclusion>
                <artifactId>seata-all</artifactId>
                <groupId>io.seata</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-all</artifactId>
        <version>0.9.0</version>
    </dependency>

2）、修改 YAML 配置文件：

spring:
      application:
        name: seata-order-service
      cloud:
        alibaba:
          seata:
            # 自定义事务组名称需要与seata-server中的对应
            tx-service-group: my_tx_group
        nacos:
          discovery:
            server-addr: localhost:8848
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata_order
        username: root
        password: 123456
    
    feign:
      hystrix:
        enabled: false
    
    logging:
      level:
        io:
          seata: info

3）、在各自业务数据库下执行 `seata/conf` 目录下的 `db_undo_log.sql` 脚本文件，同时把 `file.conf` 和 `registry.conf` 两个文件复制到项目中 `resource` 目录下。

4）、由于要使用 Seata 对数据源进行代理，所以需要在主启动类中排除默认数据源：

@EnableDiscoveryClient
    @EnableFeignClients
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class) // 取消数据源的自动创建
    public class SeataOrderMainApp { 
        public static void main(String[] args) { 
            SpringApplication.run(SeataOrderMainApp.class, args);
        }
    }

5）、添加数据源代理配置类：

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.beans.factory.annotation.Value;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import javax.sql.DataSource;
    
    /** * 使用Seata对数据源进行代理 */
    @Configuration
    public class DataSourceProxyConfig { 
    
        @Value("${mybatis.mapperLocations}")
        private String mapperLocations;
    
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource")
        public DataSource druidDataSource(){ 
            return new DruidDataSource();
        }
    
        @Bean
        public DataSourceProxy dataSourceProxy(DataSource dataSource) { 
            return new DataSourceProxy(dataSource);
        }
    
        @Bean
        public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception { 
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(dataSourceProxy);
            sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
            sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
            return sqlSessionFactoryBean.getObject();
        }
    
    }

6）、最后在需要进行实物操作的 Service 接口方法中添加 `@GlobalTransactional` 注解：

@GlobalTransactional(name = "my-create-order",rollbackFor = Exception.class)
    public void create(Order order)
    { 
        // do something
    }

### 6、总结分布式事务的执行流程 ###

1.  TM 开启分布式事务（TM 向 TC 注册全局事务记录）
2.  按业务场景，编排数据库、服务等事务内资源（RM向TC汇报资源准备状态）
3.  TM 结束分布式事务，事务一阶段结束（TM 通知 TC 提交/回滚分布式事务）
4.  TC 汇报事务信息，决定分布式事务是提交还是回滚
5.  TC 通知所有 RM 提交/回滚资源，事务二阶段结束

[http_thesecretlivesofdata.com_raft]: http://thesecretlivesofdata.com/raft/
[http_seata.io_zh-cn]: http://seata.io/zh-cn/
[20201013173615874.png_pic_center]: /images/20221123/a225129f995641aaaf40d3c565e0dbee.png
[https_github.com_seata_seata_releases]: https://github.com/seata/seata/releases