当前位置：首页 > news >正文

SpringCloud-Seata

news 来源：原创 2025/6/17 9:17:21

Seata分布式事务

Seata（Simple Extensible Autonomous Transaction Architecture）是一个开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将分布式事务拆分为全局事务和分支事务，通过 TC（Transaction Coordinator）、TM（Transaction Manager）和 RM（Resource Manager）三个组件的协作，实现了分布式事务的 ACID 特性。

官网地址：Apache Seatahttps://seata.apache.org/?spm=5176.29160081.0.0.74805c72agUsGU

Seata 的核心组件

TC (Transaction Coordinator): 事务协调者，维护全局和分支事务的状态，驱动全局事务提交或回滚。
TM (Transaction Manager): 事务管理器，定义全局事务的边界，申请开启、提交或回滚全局事务。
RM (Resource Manager): 资源管理器，管理分支事务处理的资源，与 TC 通讯以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

简而言之：如果将分布式事务整体看作为一个糖葫芦串的话。TC (Transaction Coordinator)就可以看作是Seata本身，即是串糖葫芦的竹签。TM (Transaction Manager)就是触发分布式事务的第一个事务，即第一个糖葫芦。RM (Resource Manager)就是mysql数据库本身。

Seata 的事务模式

Seata 提供了 AT、TCC、SAGA 和 XA 四种事务模式，以适应不同的业务场景和需求。

AT 模式（Automatic Transaction）：基于支持本地 ACID 事务的关系型数据库，通过代理数据源的方式，拦截 SQL 操作，自动补偿回滚，实现分布式事务。
TCC 模式（Try-Confirm-Cancel）：应用层侵入业务代码，通过定义 Try、Confirm 和 Cancel 三个操作，由框架调用以完成分支事务的提交或回滚。
SAGA 模式：通过事件驱动的方式，补偿服务在接收到事件后进行相应的业务处理，实现长事务的最终一致性。
XA 模式：基于 XA 协议的两阶段提交，通过数据库支持的 XA 事务来实现分布式事务。

Seata 的基本工作流程

全局事务的开始：事务管理器。当业务应用需要执行一个全局事务时，TM 会向 TC（Transaction Coordinator）申请开启一个新的全局事务。TC 会生成一个全局唯一的事务 ID（XID），并返回给 TM。
分支事务的注册：资源管理器。在全局事务的上下文中，每个需要参与该事务的服务（或数据库）都会作为一个分支事务。RM 在执行分支事务之前，会向 TC 注册该分支事务，并报告其初始状态。
分支事务的执行：在注册分支事务后，RM 会开始执行实际的业务操作（如数据库操作）。这些操作会被 RM 拦截并记录下来，以便在需要时进行回滚。
一，二阶段提交/回滚：跟据具体情况进行提交或者回滚策略
全局事务结束：无论全局事务是提交还是回滚，当所有分支事务都处理完毕后，TM 会结束该全局事务的生命周期。

操作流程：

sql语句地址：https://github.com/seata/saeta/blob/develop/script/server/db/masql.sqlhttps://github.com/seata/saeta/blob/develop/script/server/db/masql.sql

==============================数据库语句准备=======================================
CREATE DATABASE seata;

USE seata;

-- ------------------- 当storeMode为'db'时使用的脚本--------------------------------

-- 存储GlobalSession数据的表

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_status_gmt_modified` (`status` , `gmt_modified`),

    KEY `idx_transaction_id` (`transaction_id`)

) ENGINE = InnoDB

  DEFAULT CHARSET = utf8mb4;



-- 存储BranchSession数据的表

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 = utf8mb4;



-- 存储锁数据的表

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),

    `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',

    `gmt_create`     DATETIME,

    `gmt_modified`   DATETIME,

    PRIMARY KEY (`row_key`),

    KEY `idx_status` (`status`),

    KEY `idx_branch_id` (`branch_id`),

    KEY `idx_xid` (`xid`)

) ENGINE = InnoDB

  DEFAULT CHARSET = utf8mb4;



CREATE TABLE IF NOT EXISTS `distributed_lock`

(

    `lock_key`       CHAR(20) NOT NULL,

    `lock_value`     VARCHAR(20) NOT NULL,

    `expire`         BIGINT,

    primary key (`lock_key`)

) ENGINE = InnoDB

  DEFAULT CHARSET = utf8mb4;



INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

==========================业务数据库创建（日志表+业务表）=============================
-- 对于AT模式，您必须为您的业务数据库初始化此SQL。Seata服务器不需要它。（日志表）
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 = utf8mb4 COMMENT ='AT transaction mode undo table';
ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);

-- 业务表，下面列举一个例子订单表，跟据自己的业务创建
CREATE TABLE t_order(

`id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,

`user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',

`product_id` BIGINT(11)DEFAULT NULL COMMENT '产品id',

`count` INT(11) DEFAULT NULL COMMENT '数量',

`money` DECIMAL(11,0) DEFAULT NULL COMMENT '金额',

`status` INT(1) DEFAULT NULL COMMENT '订单状态: 0:创建中; 1:已完结'

)ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

 

SELECT * FROM t_order;

======================添加依赖===================================
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.1.0</version>
</dependency>

======================配置文件======================================
seata:
  application-id: ${spring.application.name}
  tx-service-group: ${spring.application.name}-group
  service:
    vgroup-mapping:
      ${spring.application.name}-group: default
    grouplist:
      default: 127.0.0.1:8091

@Override
//在触发全局事务的方法上进行标注即可，就可以达到分布式事务异常回滚的效果
@GlobalTransactional(name = "zzyy-create-order",rollbackFor = Exception.class) //AT
public void create(Order order)

{

   //相关业务逻辑实现

}