Seata 案例

桃扇骨 2024-03-23 23:32 97阅读 0赞

## 分布式事务问题由来 ##

**分布式前**

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

**分布式后**

![在这里插入图片描述][c956fabb9e914a45ab26fc07048b6f6e.png]  
![在这里插入图片描述][72fb3918e18546fbb9cad0da304a4abb.png]

## Seata术语 ##

**官网地址： http://seata.io/zh-cn/**

**是什么**

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

**能干嘛**

![在这里插入图片描述][e6a0ac5c9ac34d2f851d4a6805d6224d.png]  
分布式事务处理过程的一ID+三组件模型：

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

处理过程：

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

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

## Seata-Server安装 ##

**去哪下**

发布说明: https://github.com/seata/seata/releases

**怎么玩**

![在这里插入图片描述][4824cd6229be457b8c2de39607b40fb2.png]  
![在这里插入图片描述][9e55d41e980a4539af4f46e5f5df15ad.png]

**Seata-Server安装**

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

下载地址：

https://github.com/seata/seata/releases

https://github.com/seata/seata/releases/download/v1.4.2/seata-server-1.4.2.zip

seata-server-1.4.2.zip解压到指定目录并修改conf目录下的 file.conf 配置文件

先备份原始file.conf文件

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

主要修改:自定义事务组名称+事务日志存储模式为db +数据库连接信息

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

**打开 file.conf.example 文件**

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

#新增
      #vgroup->rgroup
      ##fsp_tx_group是自定义的
      vgroup_mapping.my.test.tx_group="fsp_tx_group"

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

mysql8.0.34 数据库新建库seata，在seata库里建表

在seata库里建表

**注意：1.4.2版本的seata文件下没有db.sql的脚本文件，需要去seata的GitHub上下载**  
**路径：https://github.com/seata/seata/blob/develop/script/server/db/mysql.sql**

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
    -- the table to store GlobalSession data
    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;
    
    -- the table to store BranchSession data
    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;
    
    -- the table to store lock data
    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);

修改seata-server-1.4.2\\seata\\conf目录下的registry.conf配置文件

先备份副本

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

![在这里插入图片描述][b99c71ab967c41fd9a2af6d758cb671c.png]  
![在这里插入图片描述][41466e3656b54b7594acabdf0c9bf1ba.png]

先启动Nacos端口号8848 nacos\\bin\\startup.cmd

再启动seata-server - seata-server-1.4.2\\seata\\bin\\seata-server.bat

直接双击 seata-server-1.4.2\\seata\\bin\\ 目录下的 seata-server.bat 即可启动 seata

## Seata业务数据库准备 ##

**以下演示都需要先启动Nacos后启动Seata,保证两个都OK**

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

**分布式事务业务说明**

![在这里插入图片描述][719b1378924c48efb904b357f7002333.png]  
![在这里插入图片描述][4b1f3822a9454bac84d46a39d425a901.png]

**创建业务数据库**

*  seata\_ order：存储订单的数据库
 *  seata\_ storage：存储库存的数据库
 *  seata\_ account：存储账户信息的数据库

**建库SQL**

CREATE DATABASE seata_order;
    CREATE DATABASE seata_storage;
    CREATE DATABASE seata_account;

**按照上述3库分别建对应业务表**

*  seata\_order库下建t\_order表

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;

*  seata\_storage库下建t\_storage表

CREATE TABLE t_storage (
    `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
    `product_id` BIGINT(11) DEFAULT NULL COMMENT '产品id',
    `total` INT(11) DEFAULT NULL COMMENT '总库存',
    `used` INT(11) DEFAULT NULL COMMENT '已用库存',
    `residue` INT(11) DEFAULT NULL COMMENT '剩余库存'
    ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
    
    INSERT INTO seata_storage.t_storage(`id`, `product_id`, `total`, `used`, `residue`)
    VALUES ('1', '1', '100', '0','100');
    
    SELECT * FROM t_storage;

*  seata\_account库下建t\_account表

CREATE TABLE t_account(
    	`id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'id',
    	`user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',
    	`total` DECIMAL(10,0) DEFAULT NULL COMMENT '总额度',
    	`used` DECIMAL(10,0) DEFAULT NULL COMMENT '已用余额',
    	`residue` DECIMAL(10,0) DEFAULT '0' COMMENT '剩余可用额度'
    ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
    
    INSERT INTO seata_account.t_account(`id`, `user_id`, `total`, `used`, `residue`)
    VALUES ('1', '1', '1000', '0', '1000');
    
    SELECT * FROM t_account;

**按照上述3库分别建对应的回滚日志表**

*  订单-库存-账户3个库下都需要建各自的回滚日志表
 *  建表SQL

-- the table to store seata xid data
    -- 0.7.0+ add context
    -- you must to init this sql for you business databese. the seata server not need it.
    -- 此脚本必须初始化在你当前的业务数据库中，用于AT 模式XID记录。与server端无关（注：业务数据库）
    -- 注意此处0.3.0+ 增加唯一索引 ux_undo_log
    drop table `undo_log`;
    CREATE TABLE `undo_log` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT,
      `branch_id` bigint(20) NOT NULL,
      `xid` varchar(100) NOT NULL,
      `context` varchar(128) NOT NULL,
      `rollback_info` longblob NOT NULL,
      `log_status` int(11) NOT NULL,
      `log_created` datetime NOT NULL,
      `log_modified` datetime NOT NULL,
      `ext` varchar(100) DEFAULT NULL,
      PRIMARY KEY (`id`),
      UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

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

## Seata之Order-Module配置搭建 ##

**业务需求**

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

**新建订单 Order-Module：seata-order-service2001**

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>cloud2020</artifactId>
            <groupId>com.atguigu.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>seata-order-service2001</artifactId>
    
        <dependencies>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <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>1.4.2</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.6</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.0.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
        </dependencies>
    </project>

application.yml

server:
      port: 2001
    
    spring:
      application:
        name: seata-order-service
      cloud:
        alibaba:
          seata:
            #自定义事务组名称需要与seata-server中的对应
            tx-service-group: fsp_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
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml

在 resources 目录下新建 file.conf 文件， 将 seata 目录下的 conf/file.conf 复制进来 ，修改对应的数据库地址，数据库名，用户名，密码

![在这里插入图片描述][c1279d38a2944f54b019377eb29650ac.png]  
![在这里插入图片描述][ff6ddc46ff4945c4a57e4caa261c2667.png]  
![在这里插入图片描述][41432cfc3b274143a26152eb1f7be24a.png]

transport {
        
      # tcp, unix-domain-socket
      type = "TCP"
      #NIO, NATIVE
      server = "NIO"
      #enable heartbeat
      heartbeat = true
      # the client batch send request enable
      enableClientBatchSendRequest = false
      #thread factory for netty
      threadFactory {
        
        bossThreadPrefix = "NettyBoss"
        workerThreadPrefix = "NettyServerNIOWorker"
        serverExecutorThreadPrefix = "NettyServerBizHandler"
        shareBossWorker = false
        clientSelectorThreadPrefix = "NettyClientSelector"
        clientSelectorThreadSize = 1
        clientWorkerThreadPrefix = "NettyClientWorkerThread"
        # netty boss thread size
        bossThreadSize = 1
        #auto default pin or 8
        workerThreadSize = "default"
      }
      shutdown {
        
        # when destroy server, wait seconds
        wait = 3
      }
      serialization = "seata"
      compressor = "none"
    }
    
    ## transaction log store, only used in server side
    store {
        
      ## store mode: file、db
      mode = "db"
      ## file store property
      file {
        
        ## store location dir
        dir = "sessionStore"
        # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
        maxBranchSessionSize = 16384
        # globe session size , if exceeded throws exceptions
        maxGlobalSessionSize = 512
        # file buffer size , if exceeded allocate new buffer
        fileWriteBufferCacheSize = 16384
        # when recover batch read size
        sessionReloadReadSize = 100
        # async, sync
        flushDiskMode = async
      }
    
      ## 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"
        ## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
        url = "jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true"
        user = "root"
        password = "123456"
        minConn = 5
        maxConn = 30
        globalTable = "global_table"
        branchTable = "branch_table"
        lockTable = "lock_table"
        queryLimit = 100
      }
    }
    ## server configuration, only used in server side
    server {
        
      recovery {
        
        #schedule committing retry period in milliseconds
        committingRetryPeriod = 1000
        #schedule asyn committing retry period in milliseconds
        asynCommittingRetryPeriod = 1000
        #schedule rollbacking retry period in milliseconds
        rollbackingRetryPeriod = 1000
        #schedule timeout retry period in milliseconds
        timeoutRetryPeriod = 1000
      }
      undo {
        
        logSaveDays = 7
        #schedule delete expired undo_log in milliseconds
        logDeletePeriod = 86400000
      }
      #check auth
      enableCheckAuth = true
      #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
      maxCommitRetryTimeout = "-1"
      maxRollbackRetryTimeout = "-1"
      rollbackRetryTimeoutUnlockEnable = false
      retryDeadThreshold = 130000
    
      #新增
      #vgroup->rgroup
      ##fsp_tx_group是自定义的
      vgroup_mapping.my.test.tx_group="fsp_tx_group"
    }
    
    ## metrics configuration, only used in server side
    metrics {
        
      enabled = false
      registryType = "compact"
      # multi exporters use comma divided
      exporterList = "prometheus"
      exporterPrometheusPort = 9898
    }

在 resources 目录下新建 registry.conf文件， 将 seata 目录下的 conf/registry.conf 复制进来

![在这里插入图片描述][94f1eaeef89348fdbe258e3bc0f4d194.png]  
![在这里插入图片描述][cab27ad9014a4f0681b951476e01f912.png]  
![在这里插入图片描述][628d214fdd69455c9bcc6622bcd37879.png]  
![在这里插入图片描述][2ba8469e4a9848f2b18a1368b901fa30.png]

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 = ""
        password = ""
      }
      eureka {
        
        serviceUrl = "http://localhost:8761/eureka"
        application = "default"
        weight = "1"
      }
      redis {
        
        serverAddr = "localhost:6379"
        db = 0
        password = ""
        cluster = "default"
        timeout = 0
      }
      zk {
        
        cluster = "default"
        serverAddr = "127.0.0.1:2181"
        sessionTimeout = 6000
        connectTimeout = 2000
        username = ""
        password = ""
      }
      consul {
        
        cluster = "default"
        serverAddr = "127.0.0.1:8500"
        aclToken = ""
      }
      etcd3 {
        
        cluster = "default"
        serverAddr = "http://localhost:2379"
      }
      sofa {
        
        serverAddr = "127.0.0.1:9603"
        application = "default"
        region = "DEFAULT_ZONE"
        datacenter = "DefaultDataCenter"
        cluster = "default"
        group = "SEATA_GROUP"
        addressWaitTime = "3000"
      }
      file {
        
        name = "file.conf"
      }
    }
    
    config {
        
      # file、nacos 、apollo、zk、consul、etcd3
      type = "nacos"
    
      nacos {
        
        serverAddr = "127.0.0.1:8848"
        namespace = ""
        group = "SEATA_GROUP"
        username = ""
        password = ""
        dataId = "seataServer.properties"
      }
      consul {
        
        serverAddr = "127.0.0.1:8500"
        aclToken = ""
      }
      apollo {
        
        appId = "seata-server"
        ## apolloConfigService will cover apolloMeta
        apolloMeta = "http://192.168.1.204:8801"
        apolloConfigService = "http://192.168.1.204:8080"
        namespace = "application"
        apolloAccesskeySecret = ""
        cluster = "seata"
      }
      zk {
        
        serverAddr = "127.0.0.1:2181"
        sessionTimeout = 6000
        connectTimeout = 2000
        username = ""
        password = ""
        nodePath = "/seata/seata.properties"
      }
      etcd3 {
        
        serverAddr = "http://localhost:2379"
      }
      file {
        
        name = "file.conf"
      }
    }

创建类 entity.CommonResult

package com.atguigu.springcloud.entity;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class CommonResult<T>
    {
        
        private Integer code;
        private String  message;
        private T       data;
    
        public CommonResult(Integer code, String message)
        {
        
            this(code,message,null);
        }
    }

创建类 entity.Order

package com.atguigu.springcloud.entity;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    import java.math.BigDecimal;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Order
    {
        
        private Long id;
    
        private Long userId;
    
        private Long productId;
    
        private Integer count;
    
        private BigDecimal money;
    
        private Integer status; //订单状态：0：创建中；1：已完结
    }

## Seata之Order-Module撸码(上) ##

**Mapper接口及实现**

mapper.OrderMapper

package com.atguigu.springcloud.mapper;
    
    import com.atguigu.springcloud.entity.Order;
    import org.apache.ibatis.annotations.Param;
    
    public interface OrderMapper {
        
        // 新建订单
        void create(Order order);
    
        // 修改订单状态， 从 0 改为 1
        void update(@Param("userId") Long userId, @Param("status") Integer status);
    }

mapper.OrderMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.atguigu.springcloud.mapper.OrderMapper">
        
        
        <insert id="create" parameterType="com.atguigu.springcloud.entity.Order">
            insert into seata_order.t_order(id, user_id, product_id, count, money, status)
            values (null,#{userId},#{productId},#{count},#{money},0);
        </insert>
    
        
        
        <update id="update">
            update seata_order.t_order set status = 1
            where user_id = #{userId} and status = #{status};
        </update>
    
        <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Order">
            <id column="id" property="id" jdbcType="BIGINT"/>
            <result column="user_id" property="userId" jdbcType="BIGINT"/>
            <result column="product_id" property="productId" jdbcType="BIGINT"/>
            <result column="count" property="count" jdbcType="INTEGER"/>
            <result column="money" property="money" jdbcType="DECIMAL"/>
            <result column="status" property="status" jdbcType="INTEGER"/>
        </resultMap>
    
    </mapper>

**Service接口及实现**

*  StorageService
 *  AccountService
 *  OrderService
    
     *  OrderServiceImpl

StorageService

package com.atguigu.springcloud.service;
    
    import com.atguigu.springcloud.entity.CommonResult;
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    
    @FeignClient(value = "seata-storage-service")
    public interface StorageService {
        
        @PostMapping("/storage/decrease")
        CommonResult decrease(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
    }

AccountService

package com.atguigu.springcloud.service;
    
    import com.atguigu.springcloud.entity.CommonResult;
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    
    import java.math.BigDecimal;
    
    @FeignClient(value = "seata-account-service")
    public interface AccountService {
        
        @PostMapping("/account/decrease")
        CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
    }

OrderService

package com.atguigu.springcloud.service;
    
    import com.atguigu.springcloud.entity.Order;
    
    public interface OrderService {
        
    
        // 新建订单
        void create(Order order);
    }

OrderServiceImpl

package com.atguigu.springcloud.service.impl;
    
    import com.atguigu.springcloud.entity.Order;
    import com.atguigu.springcloud.mapper.OrderMapper;
    import com.atguigu.springcloud.service.AccountService;
    import com.atguigu.springcloud.service.OrderService;
    import com.atguigu.springcloud.service.StorageService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    
    @Service
    @Slf4j
    public class OrderServiceImpl implements OrderService {
        
    
        @Resource
        private OrderMapper orderMapper;
    
        @Resource
        private StorageService storageService;
    
        @Resource
        private AccountService accountService;
    
        /**
         * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
         * 简单说：下订单->扣库存->减余额->改状态
         */
        @Override
        public void create(Order order) {
        
            log.info("----->开始新建订单");
    
            // 1. 新建订单
            orderMapper.create(order);
    
            // 2. 扣减库存
            log.info("----->订单微服务开始调用库存，做扣减Count");
            storageService.decrease(order.getProductId(), order.getCount());
            log.info("----->订单微服务开始调用库存，做扣减end");
    
            // 3. 扣除账户余额
            log.info("----->订单微服务开始调用账户，做扣减Money");
            accountService.decrease(order.getUserId(), order.getMoney());
            log.info("----->订单微服务开始调用账户，做扣减end");
    
            // 4. 修改订单状态 从0到1,1代表已经完成
            log.info("----->修改订单状态开始");
            orderMapper.update(order.getUserId(), 0);
            log.info("----->修改订单状态结束");
    
            log.info("----->下订单结束了，O(∩_∩)O哈哈~");
    
        }
    }

## Seata之Order-Module撸码(下) ##

**controller.OrderController**

package com.atguigu.springcloud.controller;
    
    import com.atguigu.springcloud.entity.CommonResult;
    import com.atguigu.springcloud.entity.Order;
    import com.atguigu.springcloud.service.OrderService;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    
    @RestController
    public class OrderController {
        
    
        @Resource
        private OrderService orderService;
    
        @GetMapping("/order/create")
        public CommonResult create(Order order) {
        
            orderService.create(order);
            return new CommonResult(200,"订单创建成功");
        }
    }

**Config配置**

config.MyBatisConfig

package com.atguigu.springcloud.config;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    @MapperScan("com.atguigu.springcloud.mapper")
    public class MyBatisConfig {
        
    }

config.DataSourceProxyConfig

package com.atguigu.springcloud.config;
    
    
    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();
        }
    }

主启动类 SeataOrderMainApp2001

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @EnableDiscoveryClient
    @EnableFeignClients
    //取消数据源的自动创建，而是使用自己定义的
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    public class SeataOrderMainApp2001 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(SeataOrderMainApp2001.class, args);
        }
    }

**启动微服务项目 2001**

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

**注意：启动微服务2001项目报以下错误**

can not get cluster name in registry config 'service.vgroupMapping.fsp_tx_group', please make sure registry config correct

**解决方案：**

在nacos中配置 service.vgroupMapping.fsp\_tx\_group

![在这里插入图片描述][c431c74b299b411190e6032aad9f5c3f.png]  
![在这里插入图片描述][1ee8fd94e0894472a2af1a60cc71660d.png]

再重启微服务2001项目就可以了

## Seata之Storage-Module说明 ##

**新建库存 Storage-Module：seata- storage - service2002**

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>cloud2020</artifactId>
            <groupId>com.atguigu.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>seata- storage - service2002</artifactId>
    
        <dependencies>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <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>1.4.2</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.6</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.0.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
        </dependencies>
    </project>

application.yml

server:
      port: 2002
    
    spring:
      application:
        name: seata-storage-service
      cloud:
        alibaba:
          seata:
            tx-service-group: fsp_tx_group
        nacos:
          discovery:
            server-addr: localhost:8848
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata_storage
        username: root
        password: 123456
    
    logging:
      level:
        io:
          seata: info
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml

在 resources 目录下新建 file.conf 文件， 将 seata 目录下的 conf/file.conf 复制进来 ，修改对应的数据库地址，数据库名，用户名，密码

![在这里插入图片描述][6d2116240435421abaa5664cb695106f.png]  
![在这里插入图片描述][ff6ddc46ff4945c4a57e4caa261c2667.png]  
![在这里插入图片描述][41432cfc3b274143a26152eb1f7be24a.png]

在 resources 目录下新建 registry.conf文件， 将 seata 目录下的 conf/registry.conf 复制进来

![在这里插入图片描述][032cdb5f3ff94b69a64e98c73686ba85.png]  
![在这里插入图片描述][cab27ad9014a4f0681b951476e01f912.png]  
![在这里插入图片描述][628d214fdd69455c9bcc6622bcd37879.png]  
![在这里插入图片描述][2ba8469e4a9848f2b18a1368b901fa30.png]

创建类 entity.CommonResult

创建类 entity.Storage

package com.atguigu.springcloud.entity;
    
    import lombok.Data;
    
    @Data
    public class Storage {
        
        private Long id;
    
        /**
         * 产品id
         */
        private Long productId;
    
        /**
         * 总库存
         */
        private Integer total;
    
        /**
         * 已用库存
         */
        private Integer used;
    
        /**
         * 剩余库存
         */
        private Integer residue;
    }

**Mapper接口及实现**

创建接口 mapper.StorageMapper

package com.atguigu.springcloud.mapper;
    
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Param;
    
    @Mapper
    public interface StorageMapper {
        
        // 扣减库存
        void decrease(@Param("productId") Long productId, @Param("count") Integer count);
    }

mapper.StorageMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.atguigu.springcloud.mapper.StorageMapper">
        
        
        <update id="decrease" parameterType="com.atguigu.springcloud.entity.Storage">
            update seata_storage.t_storage
            set used = used + #{count}, residue = residue - #{count}
            where product_id = #{productId}
        </update>
    
        <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Storage">
            <id column="id" property="id" jdbcType="BIGINT"/>
            <result column="product_id" property="productId" jdbcType="BIGINT"/>
            <result column="total" property="total" jdbcType="INTEGER"/>
            <result column="used" property="used" jdbcType="INTEGER"/>
            <result column="residue" property="residue" jdbcType="INTEGER"/>
        </resultMap>
    
    </mapper>

**Service接口及实现**

创建接口 service.StorageService

package com.atguigu.springcloud.service;
    
    public interface StorageService {
        
        // 扣减库存
        void decrease(Long productId, Integer count);
    }

创建类 service.impl.StorageServiceImpl

package com.atguigu.springcloud.service.impl;
    
    import com.atguigu.springcloud.mapper.StorageMapper;
    import com.atguigu.springcloud.service.StorageService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    
    @Service
    @Slf4j
    public class StorageServiceImpl implements StorageService {
        
    
        @Resource
        private StorageMapper storageMapper;
    
        // 扣减库存
        @Override
        public void decrease(Long productId, Integer count) {
        
            log.info("------->storage-service中扣减库存开始");
            storageMapper.decrease(productId, count);
            log.info("------->storage-service中扣减库存结束");
        }
    }

**Controller**

创建类 controller.StorageController

package com.atguigu.springcloud.controller;
    
    import com.atguigu.springcloud.entity.CommonResult;
    import com.atguigu.springcloud.service.StorageService;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    
    @RestController
    public class StorageController {
        
        @Resource
        private StorageService storageServicep;
    
        /**
         * 扣减库存
         */
        @RequestMapping("/storage/decrease")
        public CommonResult decrease(Long productId, Integer count) {
        
            storageServicep.decrease(productId, count);
            return new CommonResult(200, "扣减库存成功！");
        }
    }

**Config 配置**

config.MyBatisConfig

package com.atguigu.springcloud.config;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    @MapperScan(value = "com.atguigu.springcloud.mapper")
    public class MyBatisConfig {
        
    }

config.DataSourceProxyConfig

package com.atguigu.springcloud.config;
    
    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();
        }
    }

主启动类 SeataStorageMainApp2002

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @EnableDiscoveryClient
    @EnableFeignClients
    //取消数据源的自动创建，而是使用自己定义的
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    public class SeataStorageMainApp2002 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(SeataStorageMainApp2002.class, args);
        }
    }

**启动微服务项目2002**

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

## Seata之Account-Module说明 ##

**新建账户 Account-Module：seata- account- service2003**

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>cloud2020</artifactId>
            <groupId>com.atguigu.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>seata- account- service2003</artifactId>
    
        <dependencies>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <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>1.4.2</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.6</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.0.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
        </dependencies>
    
    </project>

application.yml

server:
      port: 2003
    
    spring:
      application:
        name: seata-account-service
      cloud:
        alibaba:
          seata:
            #自定义事务组名称需要与seata-server中的对应
            tx-service-group: fsp_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
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml

在 resources 目录下新建 file.conf 文件， 将 seata 目录下的 conf/file.conf 复制进来 ，修改对应的数据库地址，数据库名，用户名，密码

![在这里插入图片描述][2bd7dff00f0f4579ab51833bdf846ad4.png]  
![在这里插入图片描述][ff6ddc46ff4945c4a57e4caa261c2667.png]  
![在这里插入图片描述][41432cfc3b274143a26152eb1f7be24a.png]

在 resources 目录下新建 registry.conf文件， 将 seata 目录下的 conf/registry.conf 复制进来

![在这里插入图片描述][7f456261992543a498f44d3dc58d73ab.png]  
![在这里插入图片描述][cab27ad9014a4f0681b951476e01f912.png]  
![在这里插入图片描述][628d214fdd69455c9bcc6622bcd37879.png]  
![在这里插入图片描述][2ba8469e4a9848f2b18a1368b901fa30.png]

创建类 entity.CommonResult

创建类 entity.Account

package com.atguigu.springcloud.entity;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    import java.math.BigDecimal;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Account {
        
        private Long id;
    
        /**
         * 用户id
         */
        private Long userId;
    
        /**
         * 总额度
         */
        private BigDecimal total;
    
        /**
         * 已用额度
         */
        private BigDecimal used;
    
        /**
         * 剩余额度
         */
        private BigDecimal residue;
    }

**Mapper接口及实现**

创建接口 mapper.AccountMapper

package com.atguigu.springcloud.mapper;
    
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Param;
    
    import java.math.BigDecimal;
    
    @Mapper
    public interface AccountMapper {
        
        /**
         * 扣减账户余额
         */
        void decrease(@Param("userId") Long userId, @Param("money") BigDecimal money);
    }

mapper.AccountMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.atguigu.springcloud.mapper.AccountMapper">
        
        
        <update id="decrease" parameterType="com.atguigu.springcloud.entity.Account">
            update seata_account.t_account
            set residue = residue - #{money}, used = used + #{money}
            where user_id = #{userId}
        </update>
    
        <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Account">
            <id column="id" property="id" jdbcType="BIGINT"/>
            <result column="user_id" property="userId" jdbcType="BIGINT"/>
            <result column="total" property="total" jdbcType="DECIMAL"/>
            <result column="used" property="used" jdbcType="DECIMAL"/>
            <result column="residue" property="residue" jdbcType="DECIMAL"/>
        </resultMap>
    
    </mapper>

**Service接口及实现**

service.AccountService

package com.atguigu.springcloud.service;
    
    import org.springframework.web.bind.annotation.RequestParam;
    
    import java.math.BigDecimal;
    
    public interface AccountService {
        
        /**
         * 扣减账户余额
         * @param userId 用户 id
         * @param money 金额
         */
        void decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
    }

service.impl.AccountServiceImpl

package com.atguigu.springcloud.service.impl;
    
    import com.atguigu.springcloud.mapper.AccountMapper;
    import com.atguigu.springcloud.service.AccountService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    import java.math.BigDecimal;
    
    @Service
    @Slf4j
    public class AccountServiceImpl implements AccountService {
        
    
        @Resource
        private AccountMapper accountMapper;
    
        /**
         * 扣减账户余额
         * @param userId 用户 id
         * @param money 金额
         */
        @Override
        public void decrease(Long userId, BigDecimal money) {
        
            log.info("------->account-service中扣减账户余额开始");
            accountMapper.decrease(userId,money);
            log.info("------->account-service中扣减账户余额结束");
        }
    }

**Controller**

controller.AccountController

package com.atguigu.springcloud.controller;
    
    import com.atguigu.springcloud.entity.CommonResult;
    import com.atguigu.springcloud.service.AccountService;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    import java.math.BigDecimal;
    
    @RestController
    public class AccountController {
        
    
        @Resource
        private AccountService accountService;
    
        /**
         * 扣减账户余额
         * @param userId
         * @param money
         * @return
         */
        @RequestMapping("/account/decrease")
        public CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money){
        
            accountService.decrease(userId, money);
            return new CommonResult(200,"扣减账户余额成功！");
        }
    }

**Config配置**

config.MyBatisConfig

config.DataSourceProxyConfig

主启动类 SeataAccountMainApp2003

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @EnableDiscoveryClient
    @EnableFeignClients
    //取消数据源的自动创建，而是使用自己定义的
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    public class SeataAccountMainApp2003 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(SeataAccountMainApp2003.class, args);
        }
    }

**启动微服务2003**

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

## Seata之@GlobalTransactional验证 ##

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

**数据库初始情况：**

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

**正常下单 - http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100**

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

**数据库正常下单后状况：**

![在这里插入图片描述][f945dc581b424813b49605f3e5344989.png]  
![在这里插入图片描述][5ae9c9a0627146bd860d216f784b266f.png]  
![在这里插入图片描述][d53f8f31beb842d7a947335365f12012.png]

**超时异常，没加@GlobalTransactional**

模拟AccountServiceImpl添加超时

package com.atguigu.springcloud.service.impl;
    
    import com.atguigu.springcloud.mapper.AccountMapper;
    import com.atguigu.springcloud.service.AccountService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    import java.math.BigDecimal;
    import java.util.concurrent.TimeUnit;
    
    @Service
    @Slf4j
    public class AccountServiceImpl implements AccountService {
        
    
        @Resource
        private AccountMapper accountMapper;
    
        /**
         * 扣减账户余额
         * @param userId 用户 id
         * @param money 金额
         */
        @Override
        public void decrease(Long userId, BigDecimal money) {
        
            log.info("------->account-service中扣减账户余额开始");
            //模拟超时异常，全局事务回滚
            //暂停几秒钟线程
            try {
         TimeUnit.SECONDS.sleep(20); } catch (InterruptedException e) {
         e.printStackTrace(); }
            accountMapper.decrease(userId,money);
            log.info("------->account-service中扣减账户余额结束");
        }
    }

超时下单 - http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100

另外，OpenFeign的调用默认时间是1s以内，所以最后会抛异常。

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

数据库情况

![在这里插入图片描述][4b91bd0884044249b7ced63aed1ce2eb.png]  
![在这里插入图片描述][7ad8f08729f84b7e8ad2185b3bfc7afe.png]  
![在这里插入图片描述][62b8ede083e64f7681a17ee8d0f169a1.png]

**故障情况**

*  当库存和账户金额扣减后，订单状态并没有设置为已经完成，没有从零改为1
 *  而且由于feign的重试机制，账户余额还有可能被多次扣减

**超时异常，加了@GlobalTransactional**

用@GlobalTransactional标注OrderServiceImpl的create()方法。

package com.atguigu.springcloud.service.impl;
    
    import com.atguigu.springcloud.entity.Order;
    import com.atguigu.springcloud.mapper.OrderMapper;
    import com.atguigu.springcloud.service.AccountService;
    import com.atguigu.springcloud.service.OrderService;
    import com.atguigu.springcloud.service.StorageService;
    import io.seata.spring.annotation.GlobalTransactional;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    
    @Service
    @Slf4j
    public class OrderServiceImpl implements OrderService {
        
    
        @Resource
        private OrderMapper orderMapper;
    
        @Resource
        private StorageService storageService;
    
        @Resource
        private AccountService accountService;
    
        /**
         * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
         * 简单说：下订单->扣库存->减余额->改状态
         */
        // name = "fsp-create-order" 名称可以随便取，只要保证唯一性就可以
        //rollbackFor = Exception.class表示对任意异常都进行回滚
        @GlobalTransactional(name = "fsp-create-order", rollbackFor = Exception.class)
        @Override
        public void create(Order order) {
        
            log.info("----->开始新建订单");
    
            // 1. 新建订单
            orderMapper.create(order);
    
            // 2. 扣减库存
            log.info("----->订单微服务开始调用库存，做扣减Count");
            storageService.decrease(order.getProductId(), order.getCount());
            log.info("----->订单微服务开始调用库存，做扣减end");
    
            // 3. 扣除账户余额
            log.info("----->订单微服务开始调用账户，做扣减Money");
            accountService.decrease(order.getUserId(), order.getMoney());
            log.info("----->订单微服务开始调用账户，做扣减end");
    
            // 4. 修改订单状态 从0到1,1代表已经完成
            log.info("----->修改订单状态开始");
            orderMapper.update(order.getUserId(), 0);
            log.info("----->修改订单状态结束");
    
            log.info("----->下订单结束了，O(∩_∩)O哈哈~");
    
        }
    }

**还是模拟AccountServiceImpl添加超时，下单后数据库数据并没有任何改变，记录都添加不进来，达到出异常，数据库回滚的效果。**

超时下单 - http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100

## Seata之原理简介 ##

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

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

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

**分布式事务的执行流程**

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

**AT模式如何做到对业务的无侵入**

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

**一阶段加载**

![在这里插入图片描述][31f0cd5a3b1c424eba7ddf457f8952a0.png]  
![在这里插入图片描述][e0d68534028742e0b278c87c615dad99.png]

**二阶段提交**

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

**二阶段回滚**

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

**补充**

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

[8e66a18cc37f405d87b0548023924cb2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/05fc6c8c53bf46109bf3d19ed210f681.png
[c956fabb9e914a45ab26fc07048b6f6e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/71a56d1fdc41449d8df37a10050c0d1b.png
[72fb3918e18546fbb9cad0da304a4abb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/fc6e16877d4449469c51e1baf9cd8968.png
[7efda774098c479cb5cfed2b816f1249.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/75f436c05c6f4eccb3be2687f60cde1e.png
[e6a0ac5c9ac34d2f851d4a6805d6224d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/e9cd9d6625c84b8dbd64a253a989c264.png
[224374e932664dd3972430b072b082d6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/bf5f311acad94a67ab6b8ba30ca2c42d.png
[4824cd6229be457b8c2de39607b40fb2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/eac0384dccdf4e53b2a2ab96ceb122bf.png
[9e55d41e980a4539af4f46e5f5df15ad.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/be2d1f8a80654ebaaa0915661ba3a038.png
[a7155738b0e9486484dfb3bf663f83e8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/04ef9f775eee4b7e85da1625e2fd25f5.png
[cab3f57d44364c43b48dd809c4439bc3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/4d3d9f72f4d04bfb86083859aa384a4f.png
[e74c089ee2ce44fdb7827c114583e716.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/2f6633f613b44a5fb27be2dde31f2062.png
[a6aa603edb0540afa9857bb0aedac95f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/cb22c43567504eeabcde6593a3d9c0c8.png
[73ea39c4827a404e8436dae8a1d331f0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/7fe7e04e2e5d4e05a0b791a1c238378c.png
[a8a7af6381384f7bbe26b2b9a6f3fc5c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/3cf88f74e34742b49070cef682c54ddc.png
[b99c71ab967c41fd9a2af6d758cb671c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/7f727e19e589459488fcf8caf314297a.png
[41466e3656b54b7594acabdf0c9bf1ba.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/910f02ba99eb43b388b37ae65f75446d.png
[e6f0cf5316ae47e1ad095943bb49c26a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/b89700af9e5f47a0b0b9c508545d5e48.png
[719b1378924c48efb904b357f7002333.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/8cc2336dccfd46beac02c85313bcaca8.png
[4b1f3822a9454bac84d46a39d425a901.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/0b9287aa269947c88d0a9366ae5f8473.png
[f6031f2463bb4d9aa0913c85ab3e33b0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5129a729568e4644bd1e510cf590fb89.png
[1289217601ed4940b72f7187c65edbc2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/241aa1596ac9471cad92723b8ff1786b.png
[c1279d38a2944f54b019377eb29650ac.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/39b23abd39714b3bbc8e63475c3d12c6.png
[ff6ddc46ff4945c4a57e4caa261c2667.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/0f2132abe3de403284ea4bffebec87c4.png
[41432cfc3b274143a26152eb1f7be24a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/b2d1523fcf0544a380c9ee9d5e2377d3.png
[94f1eaeef89348fdbe258e3bc0f4d194.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5156e106e8d74b85a66fec315c85f696.png
[cab27ad9014a4f0681b951476e01f912.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/b71ed1e9440c47678168c1962cc9a008.png
[628d214fdd69455c9bcc6622bcd37879.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/3629c7241e5a42eca4ba88ed22b402ca.png
[2ba8469e4a9848f2b18a1368b901fa30.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/0884acc77e7745dd8c58c3dd8492d0d0.png
[3e7bf6d966844c4cafe3d9689c842fc4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/9cbf20be38cd4bf2889f4fa6f31db170.png
[c431c74b299b411190e6032aad9f5c3f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5f32e2dc258c4c889859f97a6dcd2038.png
[1ee8fd94e0894472a2af1a60cc71660d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/1f5b1c4021cd4907aa91804928cd4877.png
[6d2116240435421abaa5664cb695106f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/6d5d7742ea604f5dbee2a37ba645ffa7.png
[032cdb5f3ff94b69a64e98c73686ba85.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/c92850b072ba45b5a63317a713f759ea.png
[40ba4b5a89fa49b99336eadfcbddfdb8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/67af8118d6e84dda8a28a0ff97ea28fe.png
[2bd7dff00f0f4579ab51833bdf846ad4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/542ca91e8e454fe7a968e3b6957665f7.png
[7f456261992543a498f44d3dc58d73ab.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/7f8832bb65834882bb3b8efd8fd88672.png
[eb4316c1cc3444449f6bf22b8d8f97e9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/956578e15f4d430280b17dbd23ce4495.png
[f0505f82017b4081b165b20d00fd70e1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/8e25717ff0844e138bcc9261b6d00623.png
[d6fea7f3b9ce4a189dc9a6d975e3070c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/1496101ae24d4568b344c625749e9ef7.png
[c40eb35a3e354ed497cb75ba199d2e8f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/4b1b6c41edbd43878adbcd2a566445e4.png
[f945dc581b424813b49605f3e5344989.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/c739e4de127543958c145b54eb92ce09.png
[5ae9c9a0627146bd860d216f784b266f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/b86b70fb987e47d9bef3c3788247964f.png
[d53f8f31beb842d7a947335365f12012.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/4c66301fa16b45328f7233b799ed074b.png
[5930bef9191a4addad4634d08c19c3e7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/d7d5288d65224ce085553183da0b7535.png
[4b91bd0884044249b7ced63aed1ce2eb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/ea2c0e99bf384d8cab34bfe00c543b82.png
[7ad8f08729f84b7e8ad2185b3bfc7afe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/ce3e108d4f6241bdac93a6fbc57c67c6.png
[62b8ede083e64f7681a17ee8d0f169a1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/642024a1041c4d87a6560f1726aa2fcd.png
[ad6ea01f11b34421a79c422cd931c3ae.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/4e6a41c3ea4c417b83b812853e8dc108.png
[643cee9e338e4411b348237937399989.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/9e702a935eb143ea8976ed0bb5da1b6e.png
[9dd202f9d5284e2b9837ac80a6603202.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/e7096641f3da48dba881abd465c34b72.png
[c6d30331904c4562820a61e80f205f5d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/faae5b105dd340c1914693f63b0586a3.png
[c9a15b3bd658431c8a156517b9b9002a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/a4a870d6c59e4b38a5124f84226e69c9.png
[bb202c40326b46fc9b48a23fdb59f381.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/f0751c1098014d1290c3c356135c807f.png
[31f0cd5a3b1c424eba7ddf457f8952a0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5cf94e793d2c4784a8de23983218151e.png
[e0d68534028742e0b278c87c615dad99.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5ddf1feceac7404686bf634b1a09806c.png
[68e182b3a8f848feacc2661929978d9e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/85c67b680e8d4e30a4ce32089b1f2f25.png
[ce89eceb98c24516a82b58d9de920f30.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/8078fd3146f8460db88dcdea50acf104.png
[6dddebd565c84d858798e746674fd731.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/a7e2b7e2eabc4ae78e1bc166f2e2c174.png
[d139ef27621f4118b184e668976cf32b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/86877622427a40bf8bf9e6549d97a501.png