【SpringCloud】08 分布式事务 seata

news2024/12/23 14:56:57

文章目录

seata
一、seata服务端的搭建
- （1）下载seata服务端
- （2）解压
- （3）配置seata的存储方式
- （4）创建seata数据库并导入相关表
- （5）把mysql的驱动jar放入到seata服务的lib目录下
- （6）seata的注册中心
- （7）指定seata哪些配置内容放入到nacos配置中心
- （8）开启seata服务
二、微服务连接到seata服务端
- （1）在每个数据库中添加一张日志表
- （2）在每个微服务中引入seata的依赖
- （3）修改微服务的配置

seata

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。
在这里插入图片描述
TC: 分布式事务管理器—理解为seata服务端

TM: 事务的发起者

RM: 分支事务。独立的connection

A[Order]服务的TM[队长:]向TC[seata]申请开启一个全局事务，TC就会创建一个全局事务并返回一个唯一的XID

A服务的RM[连接数据库]向TC注册分支事务，并将其纳入XID对应全局事务的管辖

A服务事务执行分支，向数据库做操作

A服务开始远程调用B服务，此时XID会在微服务的调用链上传播

B服务的RM向TC注册分支事务，并将其纳入XID对应的全局事务的管辖

B服务执行分支事务，向数据库做操作

全局事务调用链处理完毕，TM根据有无异常向TC发起全局事务的提交或者回滚

TC协调其管辖之下的所有分支事务，决定是否回滚

一、seata服务端的搭建

（1）下载seata服务端

https://github.com/seata/seata/releases/tag/v1.3.0

（2）解压

在这里插入图片描述

（3）配置seata的存储方式

在这里插入图片描述

（4）创建seata数据库并导入相关表

在这里插入图片描述

表结构：从seata源码中获取

把seata源码中script目录放置到seata服务的目录下

（5）把mysql的驱动jar放入到seata服务的lib目录下

在这里插入图片描述

（6）seata的注册中心

因为微服务客户端可以通过注册中心访问seata集群
在这里插入图片描述

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  type = "nacos"
  nacos {
    application = "seata-server"
    serverAddr = "127.0.0.1:8848"
    group = "SEATA_GROUP"
    namespace = ""
    cluster = "default"
    username = "nacos"
    password = "nacos"
  }
}

config {
  # file、nacos 、apollo、zk、consul、etcd3
  type = "nacos"
  nacos {
    serverAddr = "127.0.0.1:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
  }
}

在这里插入图片描述

（7）指定seata哪些配置内容放入到nacos配置中心

在这里插入图片描述
修改config.txt内容

通过nacos的脚本把上面config.txt中的配置导入到nacos配置中心

因为是shell脚本，windows不能直接操作
：

结果：

（8）开启seata服务

注意: 先开nacos 在开seata服务
在这里插入图片描述

如果是一闪而过的话，需要在seata目录下创建一个logs目录

可以通过打开cmd然后执行seata-server.bat，查看是否是因为日志相关的问题。

在这里插入图片描述

二、微服务连接到seata服务端

（1）在每个数据库中添加一张日志表

-- 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(20)   NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(100) 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';

在这里插入图片描述

此表记录修改前的镜像和修改后的镜像

（2）在每个微服务中引入seata的依赖

<!--引入seata的依赖-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

（3）修改微服务的配置

在这里插入图片描述

spring:
  cloud:
    alibaba:
      seata:
        tx-service-group: guangzhou
seata:
  #注册中心的地址
  registry:
    type: nacos
    nacos:
      server-addr: localhost:8848
      username: nacos
      password: nacos
      group: SEATA_GROUP
      application: seata-server
  #配置中心的地址
  config:
    type: nacos
    nacos:
      server-addr: localhost:8848
      username: nacos
      password: nacos
      group: SEATA_GROUP