【Seata】微服务集成seata

淡淡的烟草味﹌ 2023-10-13 23:26 108阅读 0赞

#### 文章目录 ####

*  1、Seata介绍
 *  2、Seata架构
 *  3、部署TC服务
 *  4、微服务集成seata

## 1、Seata介绍 ##

Seata是 2019 年 1 月份蚂蚁金服和阿里巴巴共同**开源的分布式事务解决方案。** 官网[http://seata.io/][http_seata.io]

![在这里插入图片描述][3bba6c43e2a24d7e825f99bd5f34bf2c.png]

## 2、Seata架构 ##

Seata事务管理有三个角色：

*  **TC (Transaction Coordinator) - 事务协调者**：`维护全局和分支事务的状态`，协调全局事务提交或回滚。
 *  **TM (Transaction Manager) - 事务管理器**：`定义全局事务的范围`、开始全局事务、提交或回滚全局事务。
 *  **RM (Resource Manager) - 资源管理器**：管理分支事务处理的资源，`与TC交谈以注册分支事务和报告分支事务的状态`，并驱动分支事务提交或回滚。

![在这里插入图片描述][cb4d4b5d783646c580fa26faa9371c67.png]

Seata提供了4种不同的分布式事务的解决方案：

*  XA模式
 *  TCC模式
 *  AT模式
 *  SAGA模式

<table> 
 <thead> 
  <tr> 
   <th>解决方案</th> 
   <th>内容</th> 
   <th>是否有业务侵入</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>XA模式</td> 
   <td>强一致性分阶段事务模式，牺牲了一定的可用性</td> 
   <td>无业务侵入</td> 
  </tr> 
  <tr> 
   <td>TCC模式</td> 
   <td>最终一致的分阶段事务模式</td> 
   <td>有业务侵入</td> 
  </tr> 
  <tr> 
   <td>AT模式</td> 
   <td>最终一致的分阶段事务模式</td> 
   <td>无业务侵入</td> 
  </tr> 
  <tr> 
   <td>SAGA模式</td> 
   <td>长事务模式</td> 
   <td>有业务侵入</td> 
  </tr> 
 </tbody> 
</table>

其中，AT模式是Seata的默认模式。

## 3、部署TC服务 ##

*  下载seata-server包，地址 [http://seata.io/zh-cn/blog/download.html][http_seata.io_zh-cn_blog_download.html]

![在这里插入图片描述][4e3cc11e25044660a6c111c55364b5e7.png]

*  在非中文目录解压缩这个zip包，其目录结构如下:

![在这里插入图片描述][9420b5fd82404de585983c3020652bda.png]

*  修改conf目录下的registry.conf配置文件：

![在这里插入图片描述][b86551da95ad4b62b642f1e9779ff301.png]

// 打开可以看到registry.conf文件内容主要有两大块：
    
    registry {
        
    ...
    }
    
    config {
        
    }

*  TC服务的注册中心类，这里选择nacos，那eureka、zookeeper的配置就删除了。registry.conf文件最终内容如下：

registry {
        
      # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
      type = "nacos"
    
      nacos {
        
        # seata tc 服务注册到 nacos上后的服务名称，可以自定义
        application = "seata-tc-server"
        serverAddr = "127.0.0.1:8848"
        group = "DEFAULT_GROUP"  # 我的微服务在这个分组，所以seata tc服务也注册到这个分组！！
        namespace = ""  # 即public
        cluster = "SH"  # 上海集群
        username = "nacos"  # nacos的登录账户
        password = "nacos"
      }
    }
    
    config {
        
      # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
      type = "nacos"  # 选file，即本地的conf目录下的file.conf文件
      # 配置nacos地址等信息
      nacos {
        
        serverAddr = "127.0.0.1:8848"
        namespace = ""
        group = "SEATA_GROUP"  # 配置文件的分组，写SEATA_GROUP分组也行
        username = "nacos"
        password = "nacos"
        dataId = "seataServer.properties"  # 即将来nacos配置列表有个叫seataServer.properties的文件
      }
    }

*  在nacos中新建seataServer.properties文件，以便让tc服务的集群可以共享配置

![在这里插入图片描述][e77a98f54c83494f8924317dfd69aca1.png]

# 即分支事务，全局事务这些信息存储的位置，可以redis，可以mysql
    # 数据存储方式，db代表数据库
    store.mode=db
    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=root
    store.db.password=123
    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
    # 事务、日志等配置
    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
    server.undo.logSaveDays=7
    server.undo.logDeletePeriod=86400000
    
    # 客户端与服务端传输方式
    transport.serialization=seata
    transport.compressor=none
    # 关闭metrics功能，提高性能
    metrics.enabled=false
    metrics.registryType=compact
    metrics.exporterList=prometheus
    metrics.exporterPrometheusPort=9898

*  创建数据库表

/*
     Navicat Premium Data Transfer
    
     Source Server         : local
     Source Server Type    : MySQL
     Source Server Version : 50622
     Source Host           : localhost:3306
     Source Schema         : seata_demo
    
     Target Server Type    : MySQL
     Target Server Version : 50622
     File Encoding         : 65001
    
     Date: 20/06/2021 12:38:37
    */
    
    SET NAMES utf8mb4;
    SET FOREIGN_KEY_CHECKS = 0;
    
    -- ----------------------------
    -- Table structure for branch_table
    -- ----------------------------
    DROP TABLE IF EXISTS `branch_table`;
    CREATE TABLE `branch_table`  (
      `branch_id` bigint(20) NOT NULL,
      `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
      `transaction_id` bigint(20) NULL DEFAULT NULL,
      `resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `status` tinyint(4) NULL DEFAULT NULL,
      `client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `gmt_create` datetime(6) NULL DEFAULT NULL,
      `gmt_modified` datetime(6) NULL DEFAULT NULL,
      PRIMARY KEY (`branch_id`) USING BTREE,
      INDEX `idx_xid`(`xid`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
    
    -- ----------------------------
    -- Records of branch_table
    -- ----------------------------
    
    -- ----------------------------
    -- Table structure for global_table
    -- ----------------------------
    DROP TABLE IF EXISTS `global_table`;
    CREATE TABLE `global_table`  (
      `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
      `transaction_id` bigint(20) NULL DEFAULT NULL,
      `status` tinyint(4) NOT NULL,
      `application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `timeout` int(11) NULL DEFAULT NULL,
      `begin_time` bigint(20) NULL DEFAULT NULL,
      `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `gmt_create` datetime NULL DEFAULT NULL,
      `gmt_modified` datetime NULL DEFAULT NULL,
      PRIMARY KEY (`xid`) USING BTREE,
      INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,
      INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
    
    -- ----------------------------
    -- Records of global_table
    -- ----------------------------
    
    
    -- ----------------------------
    -- Records of lock_table
    -- ----------------------------
    
    SET FOREIGN_KEY_CHECKS = 1;

*  进入bin目录，运行其中的seata-server.bat即可启动TC服务

![在这里插入图片描述][f72a7ee8dc9849bda88a631dd48e77e3.png]

*  启动成功后，seata-server应该已经注册到nacos注册中心了。

![在这里插入图片描述][3d1772c3d80244bdbc5e43a288f23bc0.png]

## 4、微服务集成seata ##

*  引入依赖

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        <exclusions>
            
            <exclusion>
                <artifactId>seata-spring-boot-starter</artifactId>
                <groupId>io.seata</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
        <version>${seata.version}</version>
    </dependency>

*  修改微服务的配置文件application.yaml，让微服务通过注册中心找到上面的seata-tc-server服务：

seata:
      registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
        # 参考tc服务自己的registry.conf中的配置
        type: nacos
        nacos: # tc
          server-addr: 127.0.0.1:8848
          namespace: ""
          group: DEFAULT_GROUP
          application: seata-tc-server # tc服务在nacos中的服务名称
          cluster: SH
      tx-service-group: seata-demo # 事务组，根据这个获取tc服务的cluster名称
      service:
        vgroup-mapping: # 事务组与TC服务cluster的映射关系
          seata-demo: SH

![在这里插入图片描述][6b4ccda52d854d549238cd4d046d6b79.png]

*  重启该微服务，查看TC服务的控制台（seata-server.bat的运行页面），可以看到集成成功了

![在这里插入图片描述][11817b24ea7245aaadbbfe0654266c1b.png]

注意：

在nacos中找一个微服务需要：namespace + group + serviceName + cluster，而seata客户端获取tc的cluster名称方式是以tx-group-service的值为key到vgroupMapping中查找

[http_seata.io]: http://seata.io/
[3bba6c43e2a24d7e825f99bd5f34bf2c.png]: https://img-blog.csdnimg.cn/3bba6c43e2a24d7e825f99bd5f34bf2c.png
[cb4d4b5d783646c580fa26faa9371c67.png]: https://img-blog.csdnimg.cn/cb4d4b5d783646c580fa26faa9371c67.png
[http_seata.io_zh-cn_blog_download.html]: http://seata.io/zh-cn/blog/download.html
[4e3cc11e25044660a6c111c55364b5e7.png]: https://img-blog.csdnimg.cn/4e3cc11e25044660a6c111c55364b5e7.png
[9420b5fd82404de585983c3020652bda.png]: https://img-blog.csdnimg.cn/9420b5fd82404de585983c3020652bda.png
[b86551da95ad4b62b642f1e9779ff301.png]: https://img-blog.csdnimg.cn/b86551da95ad4b62b642f1e9779ff301.png
[e77a98f54c83494f8924317dfd69aca1.png]: https://img-blog.csdnimg.cn/e77a98f54c83494f8924317dfd69aca1.png
[f72a7ee8dc9849bda88a631dd48e77e3.png]: https://img-blog.csdnimg.cn/f72a7ee8dc9849bda88a631dd48e77e3.png
[3d1772c3d80244bdbc5e43a288f23bc0.png]: https://img-blog.csdnimg.cn/3d1772c3d80244bdbc5e43a288f23bc0.png
[6b4ccda52d854d549238cd4d046d6b79.png]: https://img-blog.csdnimg.cn/6b4ccda52d854d549238cd4d046d6b79.png
[11817b24ea7245aaadbbfe0654266c1b.png]: https://img-blog.csdnimg.cn/11817b24ea7245aaadbbfe0654266c1b.png