Seata 案例

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

分布式事务问题由来

分布式前

在这里插入图片描述

分布式后

在这里插入图片描述
在这里插入图片描述

Seata术语

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

是什么

在这里插入图片描述

能干嘛

在这里插入图片描述
分布式事务处理过程的一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下管辖的全部分支事务完成提交或回滚请求。

在这里插入图片描述

Seata-Server安装

去哪下

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

怎么玩

在这里插入图片描述
在这里插入图片描述

Seata-Server安装

在这里插入图片描述

下载地址：

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文件

在这里插入图片描述

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

在这里插入图片描述

打开 file.conf.example 文件

在这里插入图片描述

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

在这里插入图片描述

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

  1. -- -------------------------------- The script used when storeMode is 'db' --------------------------------
  2. -- the table to store GlobalSession data
  3. CREATE TABLE IF NOT EXISTS `global_table`
  4. (
  5.     `xid`                       VARCHAR(128) NOT NULL,
  6.     `transaction_id`            BIGINT,
  7.     `status`                    TINYINT      NOT NULL,
  8.     `application_id`            VARCHAR(32),
  9.     `transaction_service_group` VARCHAR(32),
  10.     `transaction_name`          VARCHAR(128),
  11.     `timeout`                   INT,
  12.     `begin_time`                BIGINT,
  13.     `application_data`          VARCHAR(2000),
  14.     `gmt_create`                DATETIME,
  15.     `gmt_modified`              DATETIME,
  16.     PRIMARY KEY (`xid`),
  17.     KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),
  18.     KEY `idx_transaction_id` (`transaction_id`)
  19. ) ENGINE = InnoDB
  20.   DEFAULT CHARSET = utf8mb4;
  22. -- the table to store BranchSession data
  23. CREATE TABLE IF NOT EXISTS `branch_table`
  24. (
  25.     `branch_id`         BIGINT       NOT NULL,
  26.     `xid`               VARCHAR(128) NOT NULL,
  27.     `transaction_id`    BIGINT,
  28.     `resource_group_id` VARCHAR(32),
  29.     `resource_id`       VARCHAR(256),
  30.     `branch_type`       VARCHAR(8),
  31.     `status`            TINYINT,
  32.     `client_id`         VARCHAR(64),
  33.     `application_data`  VARCHAR(2000),
  34.     `gmt_create`        DATETIME(6),
  35.     `gmt_modified`      DATETIME(6),
  36.     PRIMARY KEY (`branch_id`),
  37.     KEY `idx_xid` (`xid`)
  38. ) ENGINE = InnoDB
  39.   DEFAULT CHARSET = utf8mb4;
  41. -- the table to store lock data
  42. CREATE TABLE IF NOT EXISTS `lock_table`
  43. (
  44.     `row_key`        VARCHAR(128) NOT NULL,
  45.     `xid`            VARCHAR(128),
  46.     `transaction_id` BIGINT,
  47.     `branch_id`      BIGINT       NOT NULL,
  48.     `resource_id`    VARCHAR(256),
  49.     `table_name`     VARCHAR(32),
  50.     `pk`             VARCHAR(36),
  51.     `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
  52.     `gmt_create`     DATETIME,
  53.     `gmt_modified`   DATETIME,
  54.     PRIMARY KEY (`row_key`),
  55.     KEY `idx_status` (`status`),
  56.     KEY `idx_branch_id` (`branch_id`),
  57.     KEY `idx_xid` (`xid`)
  58. ) ENGINE = InnoDB
  59.   DEFAULT CHARSET = utf8mb4;
  61. CREATE TABLE IF NOT EXISTS `distributed_lock`
  62. (
  63.     `lock_key`       CHAR(20) NOT NULL,
  64.     `lock_value`     VARCHAR(20) NOT NULL,
  65.     `expire`         BIGINT,
  66.     primary key (`lock_key`)
  67. ) ENGINE = InnoDB
  68.   DEFAULT CHARSET = utf8mb4;
  70. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
  71. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
  72. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
  73. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

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

先备份副本

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

  1. registry {
  3.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  4.   type = "nacos"
  6.   nacos {
  8.     application = "seata-server"
  9.     serverAddr = "127.0.0.1:8848"
  10.     group = "SEATA_GROUP"
  11.     namespace = ""
  12.     cluster = "default"
  13.     username = ""
  14.     password = ""
  15.   }

先启动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

在这里插入图片描述

分布式事务业务说明

在这里插入图片描述
在这里插入图片描述

创建业务数据库

  • seata_ order：存储订单的数据库
  • seata_ storage：存储库存的数据库
  • seata_ account：存储账户信息的数据库

建库SQL

  1. CREATE DATABASE seata_order;
  2. CREATE DATABASE seata_storage;
  3. CREATE DATABASE seata_account;

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

  • seata_order库下建t_order表

    CREATE TABLE t_order (

    1. `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
    2. `user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',
    3. `product_id` BIGINT(11) DEFAULT NULL COMMENT '产品id',
    4. `count` INT(11) DEFAULT NULL COMMENT '数量',
    5. `money` DECIMAL(11,0) DEFAULT NULL COMMENT '金额',
    6. `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(

    1. `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'id',
    2. `user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',
    3. `total` DECIMAL(10,0) DEFAULT NULL COMMENT '总额度',
    4. `used` DECIMAL(10,0) DEFAULT NULL COMMENT '已用余额',
    5. `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;

在这里插入图片描述

Seata之Order-Module配置搭建

业务需求

在这里插入图片描述

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

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud2020</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>seata-order-service2001</artifactId>
  14.     <dependencies>
  15.         <!--nacos-->
  16.         <dependency>
  17.             <groupId>com.alibaba.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  19.         </dependency>
  20.         <!--seata-->
  21.         <dependency>
  22.             <groupId>com.alibaba.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  24.             <exclusions>
  25.                 <exclusion>
  26.                     <artifactId>seata-all</artifactId>
  27.                     <groupId>io.seata</groupId>
  28.                 </exclusion>
  29.             </exclusions>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>io.seata</groupId>
  33.             <artifactId>seata-all</artifactId>
  34.             <version>1.4.2</version>
  35.         </dependency>
  36.         <!--feign-->
  37.         <dependency>
  38.             <groupId>org.springframework.cloud</groupId>
  39.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  40.         </dependency>
  41.         <!--web-actuator-->
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-web</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-actuator</artifactId>
  49.         </dependency>
  50.         <!--mysql-druid-->
  51.         <dependency>
  52.             <groupId>mysql</groupId>
  53.             <artifactId>mysql-connector-java</artifactId>
  54.             <version>5.1.6</version>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>com.alibaba</groupId>
  58.             <artifactId>druid-spring-boot-starter</artifactId>
  59.             <version>1.1.10</version>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>org.mybatis.spring.boot</groupId>
  63.             <artifactId>mybatis-spring-boot-starter</artifactId>
  64.             <version>2.0.0</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>org.springframework.boot</groupId>
  68.             <artifactId>spring-boot-starter-test</artifactId>
  69.             <scope>test</scope>
  70.         </dependency>
  71.         <dependency>
  72.             <groupId>org.projectlombok</groupId>
  73.             <artifactId>lombok</artifactId>
  74.             <optional>true</optional>
  75.         </dependency>
  76.     </dependencies>
  77. </project>

application.yml

  1. server:
  2.   port: 2001
  4. spring:
  5.   application:
  6.     name: seata-order-service
  7.   cloud:
  8.     alibaba:
  9.       seata:
  10.         #自定义事务组名称需要与seata-server中的对应
  11.         tx-service-group: fsp_tx_group
  12.     nacos:
  13.       discovery:
  14.         server-addr: localhost:8848
  15.   datasource:
  16.     driver-class-name: com.mysql.jdbc.Driver
  17.     url: jdbc:mysql://localhost:3306/seata_order
  18.     username: root
  19.     password: 123456
  21. feign:
  22.   hystrix:
  23.     enabled: false
  25. logging:
  26.   level:
  27.     io:
  28.       seata: info
  30. mybatis:
  31.   mapperLocations: classpath:mapper/*.xml

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. transport {
  3.   # tcp, unix-domain-socket
  4.   type = "TCP"
  5.   #NIO, NATIVE
  6.   server = "NIO"
  7.   #enable heartbeat
  8.   heartbeat = true
  9.   # the client batch send request enable
  10.   enableClientBatchSendRequest = false
  11.   #thread factory for netty
  12.   threadFactory {
  14.     bossThreadPrefix = "NettyBoss"
  15.     workerThreadPrefix = "NettyServerNIOWorker"
  16.     serverExecutorThreadPrefix = "NettyServerBizHandler"
  17.     shareBossWorker = false
  18.     clientSelectorThreadPrefix = "NettyClientSelector"
  19.     clientSelectorThreadSize = 1
  20.     clientWorkerThreadPrefix = "NettyClientWorkerThread"
  21.     # netty boss thread size
  22.     bossThreadSize = 1
  23.     #auto default pin or 8
  24.     workerThreadSize = "default"
  25.   }
  26.   shutdown {
  28.     # when destroy server, wait seconds
  29.     wait = 3
  30.   }
  31.   serialization = "seata"
  32.   compressor = "none"
  33. }
  35. ## transaction log store, only used in server side
  36. store {
  38.   ## store mode: file、db
  39.   mode = "db"
  40.   ## file store property
  41.   file {
  43.     ## store location dir
  44.     dir = "sessionStore"
  45.     # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
  46.     maxBranchSessionSize = 16384
  47.     # globe session size , if exceeded throws exceptions
  48.     maxGlobalSessionSize = 512
  49.     # file buffer size , if exceeded allocate new buffer
  50.     fileWriteBufferCacheSize = 16384
  51.     # when recover batch read size
  52.     sessionReloadReadSize = 100
  53.     # async, sync
  54.     flushDiskMode = async
  55.   }
  57.   ## database store property
  58.   db {
  60.     ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
  61.     datasource = "druid"
  62.     ## mysql/oracle/postgresql/h2/oceanbase etc.
  63.     dbType = "mysql"
  64.     driverClassName = "com.mysql.jdbc.Driver"
  65.     ## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
  66.     url = "jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true"
  67.     user = "root"
  68.     password = "123456"
  69.     minConn = 5
  70.     maxConn = 30
  71.     globalTable = "global_table"
  72.     branchTable = "branch_table"
  73.     lockTable = "lock_table"
  74.     queryLimit = 100
  75.   }
  76. }
  77. ## server configuration, only used in server side
  78. server {
  80.   recovery {
  82.     #schedule committing retry period in milliseconds
  83.     committingRetryPeriod = 1000
  84.     #schedule asyn committing retry period in milliseconds
  85.     asynCommittingRetryPeriod = 1000
  86.     #schedule rollbacking retry period in milliseconds
  87.     rollbackingRetryPeriod = 1000
  88.     #schedule timeout retry period in milliseconds
  89.     timeoutRetryPeriod = 1000
  90.   }
  91.   undo {
  93.     logSaveDays = 7
  94.     #schedule delete expired undo_log in milliseconds
  95.     logDeletePeriod = 86400000
  96.   }
  97.   #check auth
  98.   enableCheckAuth = true
  99.   #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
  100.   maxCommitRetryTimeout = "-1"
  101.   maxRollbackRetryTimeout = "-1"
  102.   rollbackRetryTimeoutUnlockEnable = false
  103.   retryDeadThreshold = 130000
  105.   #新增
  106.   #vgroup->rgroup
  107.   ##fsp_tx_group是自定义的
  108.   vgroup_mapping.my.test.tx_group="fsp_tx_group"
  109. }
  111. ## metrics configuration, only used in server side
  112. metrics {
  114.   enabled = false
  115.   registryType = "compact"
  116.   # multi exporters use comma divided
  117.   exporterList = "prometheus"
  118.   exporterPrometheusPort = 9898
  119. }

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. registry {
  3.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  4.   type = "nacos"
  6.   nacos {
  8.     application = "seata-server"
  9.     serverAddr = "127.0.0.1:8848"
  10.     group = "SEATA_GROUP"
  11.     namespace = ""
  12.     cluster = "default"
  13.     username = ""
  14.     password = ""
  15.   }
  16.   eureka {
  18.     serviceUrl = "http://localhost:8761/eureka"
  19.     application = "default"
  20.     weight = "1"
  21.   }
  22.   redis {
  24.     serverAddr = "localhost:6379"
  25.     db = 0
  26.     password = ""
  27.     cluster = "default"
  28.     timeout = 0
  29.   }
  30.   zk {
  32.     cluster = "default"
  33.     serverAddr = "127.0.0.1:2181"
  34.     sessionTimeout = 6000
  35.     connectTimeout = 2000
  36.     username = ""
  37.     password = ""
  38.   }
  39.   consul {
  41.     cluster = "default"
  42.     serverAddr = "127.0.0.1:8500"
  43.     aclToken = ""
  44.   }
  45.   etcd3 {
  47.     cluster = "default"
  48.     serverAddr = "http://localhost:2379"
  49.   }
  50.   sofa {
  52.     serverAddr = "127.0.0.1:9603"
  53.     application = "default"
  54.     region = "DEFAULT_ZONE"
  55.     datacenter = "DefaultDataCenter"
  56.     cluster = "default"
  57.     group = "SEATA_GROUP"
  58.     addressWaitTime = "3000"
  59.   }
  60.   file {
  62.     name = "file.conf"
  63.   }
  64. }
  66. config {
  68.   # file、nacos 、apollo、zk、consul、etcd3
  69.   type = "nacos"
  71.   nacos {
  73.     serverAddr = "127.0.0.1:8848"
  74.     namespace = ""
  75.     group = "SEATA_GROUP"
  76.     username = ""
  77.     password = ""
  78.     dataId = "seataServer.properties"
  79.   }
  80.   consul {
  82.     serverAddr = "127.0.0.1:8500"
  83.     aclToken = ""
  84.   }
  85.   apollo {
  87.     appId = "seata-server"
  88.     ## apolloConfigService will cover apolloMeta
  89.     apolloMeta = "http://192.168.1.204:8801"
  90.     apolloConfigService = "http://192.168.1.204:8080"
  91.     namespace = "application"
  92.     apolloAccesskeySecret = ""
  93.     cluster = "seata"
  94.   }
  95.   zk {
  97.     serverAddr = "127.0.0.1:2181"
  98.     sessionTimeout = 6000
  99.     connectTimeout = 2000
  100.     username = ""
  101.     password = ""
  102.     nodePath = "/seata/seata.properties"
  103.   }
  104.   etcd3 {
  106.     serverAddr = "http://localhost:2379"
  107.   }
  108.   file {
  110.     name = "file.conf"
  111.   }
  112. }

创建类 entity.CommonResult

  1. package com.atguigu.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. @Data
  8. @AllArgsConstructor
  9. @NoArgsConstructor
  10. public class CommonResult<T>
  11. {
  13.     private Integer code;
  14.     private String  message;
  15.     private T       data;
  17.     public CommonResult(Integer code, String message)
  18.     {
  20.         this(code,message,null);
  21.     }
  22. }

创建类 entity.Order

  1. package com.atguigu.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. import java.math.BigDecimal;
  9. @Data
  10. @AllArgsConstructor
  11. @NoArgsConstructor
  12. public class Order
  13. {
  15.     private Long id;
  17.     private Long userId;
  19.     private Long productId;
  21.     private Integer count;
  23.     private BigDecimal money;
  25.     private Integer status; //订单状态：0：创建中；1：已完结
  26. }

Seata之Order-Module撸码(上)

Mapper接口及实现

mapper.OrderMapper

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

mapper.OrderMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.atguigu.springcloud.mapper.OrderMapper">
  4.     <!-- 新增订单 -->
  5.     <!-- void create(Order order); -->
  6.     <insert id="create" parameterType="com.atguigu.springcloud.entity.Order">
  7.         insert into seata_order.t_order(id, user_id, product_id, count, money, status)
  8.         values (null,#{userId},#{productId},#{count},#{money},0);
  9.     </insert>
  11.     <!-- 修改订单状态 -->
  12.     <!-- void update(@Param("userId") Long userId, @Param("status") Integer status); -->
  13.     <update id="update">
  14.         update seata_order.t_order set status = 1
  15.         where user_id = #{userId} and status = #{status};
  16.     </update>
  18.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Order">
  19.         <id column="id" property="id" jdbcType="BIGINT"/>
  20.         <result column="user_id" property="userId" jdbcType="BIGINT"/>
  21.         <result column="product_id" property="productId" jdbcType="BIGINT"/>
  22.         <result column="count" property="count" jdbcType="INTEGER"/>
  23.         <result column="money" property="money" jdbcType="DECIMAL"/>
  24.         <result column="status" property="status" jdbcType="INTEGER"/>
  25.     </resultMap>
  27. </mapper>

Service接口及实现

  • StorageService
  • AccountService

  • OrderService

    • OrderServiceImpl

StorageService

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

AccountService

  1. package com.atguigu.springcloud.service;
  3. import com.atguigu.springcloud.entity.CommonResult;
  4. import org.springframework.cloud.openfeign.FeignClient;
  5. import org.springframework.web.bind.annotation.PostMapping;
  6. import org.springframework.web.bind.annotation.RequestParam;
  8. import java.math.BigDecimal;
  10. @FeignClient(value = "seata-account-service")
  11. public interface AccountService {
  13.     @PostMapping("/account/decrease")
  14.     CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
  15. }

OrderService

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

OrderServiceImpl

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.entity.Order;
  4. import com.atguigu.springcloud.mapper.OrderMapper;
  5. import com.atguigu.springcloud.service.AccountService;
  6. import com.atguigu.springcloud.service.OrderService;
  7. import com.atguigu.springcloud.service.StorageService;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.stereotype.Service;
  11. import javax.annotation.Resource;
  13. @Service
  14. @Slf4j
  15. public class OrderServiceImpl implements OrderService {
  18.     @Resource
  19.     private OrderMapper orderMapper;
  21.     @Resource
  22.     private StorageService storageService;
  24.     @Resource
  25.     private AccountService accountService;
  27.     /**
  28.      * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
  29.      * 简单说：下订单->扣库存->减余额->改状态
  30.      */
  31.     @Override
  32.     public void create(Order order) {
  34.         log.info("----->开始新建订单");
  36.         // 1. 新建订单
  37.         orderMapper.create(order);
  39.         // 2. 扣减库存
  40.         log.info("----->订单微服务开始调用库存，做扣减Count");
  41.         storageService.decrease(order.getProductId(), order.getCount());
  42.         log.info("----->订单微服务开始调用库存，做扣减end");
  44.         // 3. 扣除账户余额
  45.         log.info("----->订单微服务开始调用账户，做扣减Money");
  46.         accountService.decrease(order.getUserId(), order.getMoney());
  47.         log.info("----->订单微服务开始调用账户，做扣减end");
  49.         // 4. 修改订单状态 从0到1,1代表已经完成
  50.         log.info("----->修改订单状态开始");
  51.         orderMapper.update(order.getUserId(), 0);
  52.         log.info("----->修改订单状态结束");
  54.         log.info("----->下订单结束了，O(∩_∩)O哈哈~");
  56.     }
  57. }

Seata之Order-Module撸码(下)

controller.OrderController

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entity.CommonResult;
  4. import com.atguigu.springcloud.entity.Order;
  5. import com.atguigu.springcloud.service.OrderService;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  9. import javax.annotation.Resource;
  11. @RestController
  12. public class OrderController {
  15.     @Resource
  16.     private OrderService orderService;
  18.     @GetMapping("/order/create")
  19.     public CommonResult create(Order order) {
  21.         orderService.create(order);
  22.         return new CommonResult(200,"订单创建成功");
  23.     }
  24. }

Config配置

config.MyBatisConfig

  1. package com.atguigu.springcloud.config;
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.context.annotation.Configuration;
  6. @Configuration
  7. @MapperScan("com.atguigu.springcloud.mapper")
  8. public class MyBatisConfig {
  10. }

config.DataSourceProxyConfig

  1. package com.atguigu.springcloud.config;
  4. import com.alibaba.druid.pool.DruidDataSource;
  5. import io.seata.rm.datasource.DataSourceProxy;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.mybatis.spring.SqlSessionFactoryBean;
  8. import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
  9. import org.springframework.beans.factory.annotation.Value;
  10. import org.springframework.boot.context.properties.ConfigurationProperties;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  13. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
  15. import javax.sql.DataSource;
  18. /**
  19.  * 使用Seata对数据源进行代理
  20.  */
  21. @Configuration
  22. public class DataSourceProxyConfig {
  25.     @Value("${mybatis.mapperLocations}")
  26.     private String mapperLocations;
  28.     @Bean
  29.     @ConfigurationProperties(prefix = "spring.datasource")
  30.     public DataSource druidDataSource(){
  32.         return new DruidDataSource();
  33.     }
  35.     @Bean
  36.     public DataSourceProxy dataSourceProxy(DataSource dataSource) {
  38.         return new DataSourceProxy(dataSource);
  39.     }
  41.     @Bean
  42.     public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
  44.         SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
  45.         sqlSessionFactoryBean.setDataSource(dataSourceProxy);
  46.         sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
  47.         sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
  48.         return sqlSessionFactoryBean.getObject();
  49.     }
  50. }

主启动类 SeataOrderMainApp2001

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.cloud.openfeign.EnableFeignClients;
  9. @EnableDiscoveryClient
  10. @EnableFeignClients
  11. //取消数据源的自动创建，而是使用自己定义的
  12. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
  13. public class SeataOrderMainApp2001 {
  15.     public static void main(String[] args) {
  17.         SpringApplication.run(SeataOrderMainApp2001.class, args);
  18.     }
  19. }

启动微服务项目 2001

在这里插入图片描述

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

  1. 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

在这里插入图片描述
在这里插入图片描述

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

Seata之Storage-Module说明

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

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud2020</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>seata- storage - service2002</artifactId>
  14.     <dependencies>
  15.         <!--nacos-->
  16.         <dependency>
  17.             <groupId>com.alibaba.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  19.         </dependency>
  20.         <!--seata-->
  21.         <dependency>
  22.             <groupId>com.alibaba.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  24.             <exclusions>
  25.                 <exclusion>
  26.                     <artifactId>seata-all</artifactId>
  27.                     <groupId>io.seata</groupId>
  28.                 </exclusion>
  29.             </exclusions>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>io.seata</groupId>
  33.             <artifactId>seata-all</artifactId>
  34.             <version>1.4.2</version>
  35.         </dependency>
  36.         <!--feign-->
  37.         <dependency>
  38.             <groupId>org.springframework.cloud</groupId>
  39.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  40.         </dependency>
  41.         <!--web-actuator-->
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-web</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-actuator</artifactId>
  49.         </dependency>
  50.         <!--mysql-druid-->
  51.         <dependency>
  52.             <groupId>mysql</groupId>
  53.             <artifactId>mysql-connector-java</artifactId>
  54.             <version>5.1.6</version>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>com.alibaba</groupId>
  58.             <artifactId>druid-spring-boot-starter</artifactId>
  59.             <version>1.1.10</version>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>org.mybatis.spring.boot</groupId>
  63.             <artifactId>mybatis-spring-boot-starter</artifactId>
  64.             <version>2.0.0</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>org.springframework.boot</groupId>
  68.             <artifactId>spring-boot-starter-test</artifactId>
  69.             <scope>test</scope>
  70.         </dependency>
  71.         <dependency>
  72.             <groupId>org.projectlombok</groupId>
  73.             <artifactId>lombok</artifactId>
  74.             <optional>true</optional>
  75.         </dependency>
  76.     </dependencies>
  77. </project>

application.yml

  1. server:
  2.   port: 2002
  4. spring:
  5.   application:
  6.     name: seata-storage-service
  7.   cloud:
  8.     alibaba:
  9.       seata:
  10.         tx-service-group: fsp_tx_group
  11.     nacos:
  12.       discovery:
  13.         server-addr: localhost:8848
  14.   datasource:
  15.     driver-class-name: com.mysql.jdbc.Driver
  16.     url: jdbc:mysql://localhost:3306/seata_storage
  17.     username: root
  18.     password: 123456
  20. logging:
  21.   level:
  22.     io:
  23.       seata: info
  25. mybatis:
  26.   mapperLocations: classpath:mapper/*.xml

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. transport {
  3.   # tcp, unix-domain-socket
  4.   type = "TCP"
  5.   #NIO, NATIVE
  6.   server = "NIO"
  7.   #enable heartbeat
  8.   heartbeat = true
  9.   # the client batch send request enable
  10.   enableClientBatchSendRequest = false
  11.   #thread factory for netty
  12.   threadFactory {
  14.     bossThreadPrefix = "NettyBoss"
  15.     workerThreadPrefix = "NettyServerNIOWorker"
  16.     serverExecutorThreadPrefix = "NettyServerBizHandler"
  17.     shareBossWorker = false
  18.     clientSelectorThreadPrefix = "NettyClientSelector"
  19.     clientSelectorThreadSize = 1
  20.     clientWorkerThreadPrefix = "NettyClientWorkerThread"
  21.     # netty boss thread size
  22.     bossThreadSize = 1
  23.     #auto default pin or 8
  24.     workerThreadSize = "default"
  25.   }
  26.   shutdown {
  28.     # when destroy server, wait seconds
  29.     wait = 3
  30.   }
  31.   serialization = "seata"
  32.   compressor = "none"
  33. }
  35. ## transaction log store, only used in server side
  36. store {
  38.   ## store mode: file、db
  39.   mode = "db"
  40.   ## file store property
  41.   file {
  43.     ## store location dir
  44.     dir = "sessionStore"
  45.     # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
  46.     maxBranchSessionSize = 16384
  47.     # globe session size , if exceeded throws exceptions
  48.     maxGlobalSessionSize = 512
  49.     # file buffer size , if exceeded allocate new buffer
  50.     fileWriteBufferCacheSize = 16384
  51.     # when recover batch read size
  52.     sessionReloadReadSize = 100
  53.     # async, sync
  54.     flushDiskMode = async
  55.   }
  57.   ## database store property
  58.   db {
  60.     ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
  61.     datasource = "druid"
  62.     ## mysql/oracle/postgresql/h2/oceanbase etc.
  63.     dbType = "mysql"
  64.     driverClassName = "com.mysql.jdbc.Driver"
  65.     ## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
  66.     url = "jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true"
  67.     user = "root"
  68.     password = "123456"
  69.     minConn = 5
  70.     maxConn = 30
  71.     globalTable = "global_table"
  72.     branchTable = "branch_table"
  73.     lockTable = "lock_table"
  74.     queryLimit = 100
  75.   }
  76. }
  77. ## server configuration, only used in server side
  78. server {
  80.   recovery {
  82.     #schedule committing retry period in milliseconds
  83.     committingRetryPeriod = 1000
  84.     #schedule asyn committing retry period in milliseconds
  85.     asynCommittingRetryPeriod = 1000
  86.     #schedule rollbacking retry period in milliseconds
  87.     rollbackingRetryPeriod = 1000
  88.     #schedule timeout retry period in milliseconds
  89.     timeoutRetryPeriod = 1000
  90.   }
  91.   undo {
  93.     logSaveDays = 7
  94.     #schedule delete expired undo_log in milliseconds
  95.     logDeletePeriod = 86400000
  96.   }
  97.   #check auth
  98.   enableCheckAuth = true
  99.   #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
  100.   maxCommitRetryTimeout = "-1"
  101.   maxRollbackRetryTimeout = "-1"
  102.   rollbackRetryTimeoutUnlockEnable = false
  103.   retryDeadThreshold = 130000
  105.   #新增
  106.   #vgroup->rgroup
  107.   ##fsp_tx_group是自定义的
  108.   vgroup_mapping.my.test.tx_group="fsp_tx_group"
  109. }
  111. ## metrics configuration, only used in server side
  112. metrics {
  114.   enabled = false
  115.   registryType = "compact"
  116.   # multi exporters use comma divided
  117.   exporterList = "prometheus"
  118.   exporterPrometheusPort = 9898
  119. }

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. registry {
  3.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  4.   type = "nacos"
  6.   nacos {
  8.     application = "seata-server"
  9.     serverAddr = "127.0.0.1:8848"
  10.     group = "SEATA_GROUP"
  11.     namespace = ""
  12.     cluster = "default"
  13.     username = ""
  14.     password = ""
  15.   }
  16.   eureka {
  18.     serviceUrl = "http://localhost:8761/eureka"
  19.     application = "default"
  20.     weight = "1"
  21.   }
  22.   redis {
  24.     serverAddr = "localhost:6379"
  25.     db = 0
  26.     password = ""
  27.     cluster = "default"
  28.     timeout = 0
  29.   }
  30.   zk {
  32.     cluster = "default"
  33.     serverAddr = "127.0.0.1:2181"
  34.     sessionTimeout = 6000
  35.     connectTimeout = 2000
  36.     username = ""
  37.     password = ""
  38.   }
  39.   consul {
  41.     cluster = "default"
  42.     serverAddr = "127.0.0.1:8500"
  43.     aclToken = ""
  44.   }
  45.   etcd3 {
  47.     cluster = "default"
  48.     serverAddr = "http://localhost:2379"
  49.   }
  50.   sofa {
  52.     serverAddr = "127.0.0.1:9603"
  53.     application = "default"
  54.     region = "DEFAULT_ZONE"
  55.     datacenter = "DefaultDataCenter"
  56.     cluster = "default"
  57.     group = "SEATA_GROUP"
  58.     addressWaitTime = "3000"
  59.   }
  60.   file {
  62.     name = "file.conf"
  63.   }
  64. }
  66. config {
  68.   # file、nacos 、apollo、zk、consul、etcd3
  69.   type = "nacos"
  71.   nacos {
  73.     serverAddr = "127.0.0.1:8848"
  74.     namespace = ""
  75.     group = "SEATA_GROUP"
  76.     username = ""
  77.     password = ""
  78.     dataId = "seataServer.properties"
  79.   }
  80.   consul {
  82.     serverAddr = "127.0.0.1:8500"
  83.     aclToken = ""
  84.   }
  85.   apollo {
  87.     appId = "seata-server"
  88.     ## apolloConfigService will cover apolloMeta
  89.     apolloMeta = "http://192.168.1.204:8801"
  90.     apolloConfigService = "http://192.168.1.204:8080"
  91.     namespace = "application"
  92.     apolloAccesskeySecret = ""
  93.     cluster = "seata"
  94.   }
  95.   zk {
  97.     serverAddr = "127.0.0.1:2181"
  98.     sessionTimeout = 6000
  99.     connectTimeout = 2000
  100.     username = ""
  101.     password = ""
  102.     nodePath = "/seata/seata.properties"
  103.   }
  104.   etcd3 {
  106.     serverAddr = "http://localhost:2379"
  107.   }
  108.   file {
  110.     name = "file.conf"
  111.   }
  112. }

创建类 entity.CommonResult

  1. package com.atguigu.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. @Data
  8. @AllArgsConstructor
  9. @NoArgsConstructor
  10. public class CommonResult<T>
  11. {
  13.     private Integer code;
  14.     private String  message;
  15.     private T       data;
  17.     public CommonResult(Integer code, String message)
  18.     {
  20.         this(code,message,null);
  21.     }
  22. }

创建类 entity.Storage

  1. package com.atguigu.springcloud.entity;
  3. import lombok.Data;
  5. @Data
  6. public class Storage {
  8.     private Long id;
  10.     /**
  11.      * 产品id
  12.      */
  13.     private Long productId;
  15.     /**
  16.      * 总库存
  17.      */
  18.     private Integer total;
  20.     /**
  21.      * 已用库存
  22.      */
  23.     private Integer used;
  25.     /**
  26.      * 剩余库存
  27.      */
  28.     private Integer residue;
  29. }

Mapper接口及实现

创建接口 mapper.StorageMapper

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

mapper.StorageMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.atguigu.springcloud.mapper.StorageMapper">
  4.     <!-- 扣减库存 -->
  5.     <!-- void decrease(@Param("productId") Long productId, @Param("count") Integer count); -->
  6.     <update id="decrease" parameterType="com.atguigu.springcloud.entity.Storage">
  7.         update seata_storage.t_storage
  8.         set used = used + #{count}, residue = residue - #{count}
  9.         where product_id = #{productId}
  10.     </update>
  12.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Storage">
  13.         <id column="id" property="id" jdbcType="BIGINT"/>
  14.         <result column="product_id" property="productId" jdbcType="BIGINT"/>
  15.         <result column="total" property="total" jdbcType="INTEGER"/>
  16.         <result column="used" property="used" jdbcType="INTEGER"/>
  17.         <result column="residue" property="residue" jdbcType="INTEGER"/>
  18.     </resultMap>
  20. </mapper>

Service接口及实现

创建接口 service.StorageService

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

创建类 service.impl.StorageServiceImpl

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.mapper.StorageMapper;
  4. import com.atguigu.springcloud.service.StorageService;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.stereotype.Service;
  8. import javax.annotation.Resource;
  10. @Service
  11. @Slf4j
  12. public class StorageServiceImpl implements StorageService {
  15.     @Resource
  16.     private StorageMapper storageMapper;
  18.     // 扣减库存
  19.     @Override
  20.     public void decrease(Long productId, Integer count) {
  22.         log.info("------->storage-service中扣减库存开始");
  23.         storageMapper.decrease(productId, count);
  24.         log.info("------->storage-service中扣减库存结束");
  25.     }
  26. }

Controller

创建类 controller.StorageController

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entity.CommonResult;
  4. import com.atguigu.springcloud.service.StorageService;
  5. import org.springframework.web.bind.annotation.RequestMapping;
  6. import org.springframework.web.bind.annotation.RestController;
  8. import javax.annotation.Resource;
  10. @RestController
  11. public class StorageController {
  13.     @Resource
  14.     private StorageService storageServicep;
  16.     /**
  17.      * 扣减库存
  18.      */
  19.     @RequestMapping("/storage/decrease")
  20.     public CommonResult decrease(Long productId, Integer count) {
  22.         storageServicep.decrease(productId, count);
  23.         return new CommonResult(200, "扣减库存成功！");
  24.     }
  25. }

Config 配置

config.MyBatisConfig

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

config.DataSourceProxyConfig

  1. package com.atguigu.springcloud.config;
  3. import com.alibaba.druid.pool.DruidDataSource;
  4. import io.seata.rm.datasource.DataSourceProxy;
  5. import org.apache.ibatis.session.SqlSessionFactory;
  6. import org.mybatis.spring.SqlSessionFactoryBean;
  7. import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
  8. import org.springframework.beans.factory.annotation.Value;
  9. import org.springframework.boot.context.properties.ConfigurationProperties;
  10. import org.springframework.context.annotation.Bean;
  11. import org.springframework.context.annotation.Configuration;
  12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
  14. import javax.sql.DataSource;
  17. /**
  18.  * 使用Seata对数据源进行代理
  19.  */
  20. @Configuration
  21. public class DataSourceProxyConfig {
  24.     @Value("${mybatis.mapperLocations}")
  25.     private String mapperLocations;
  27.     @Bean
  28.     @ConfigurationProperties(prefix = "spring.datasource")
  29.     public DataSource druidDataSource(){
  31.         return new DruidDataSource();
  32.     }
  34.     @Bean
  35.     public DataSourceProxy dataSourceProxy(DataSource dataSource) {
  37.         return new DataSourceProxy(dataSource);
  38.     }
  40.     @Bean
  41.     public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
  43.         SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
  44.         sqlSessionFactoryBean.setDataSource(dataSourceProxy);
  45.         sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
  46.         sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
  47.         return sqlSessionFactoryBean.getObject();
  48.     }
  49. }

主启动类 SeataStorageMainApp2002

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.cloud.openfeign.EnableFeignClients;
  9. @EnableDiscoveryClient
  10. @EnableFeignClients
  11. //取消数据源的自动创建，而是使用自己定义的
  12. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
  13. public class SeataStorageMainApp2002 {
  15.     public static void main(String[] args) {
  17.         SpringApplication.run(SeataStorageMainApp2002.class, args);
  18.     }
  19. }

启动微服务项目2002

在这里插入图片描述

Seata之Account-Module说明

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

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud2020</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>seata- account- service2003</artifactId>
  14.     <dependencies>
  15.         <!--nacos-->
  16.         <dependency>
  17.             <groupId>com.alibaba.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  19.         </dependency>
  20.         <!--seata-->
  21.         <dependency>
  22.             <groupId>com.alibaba.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  24.             <exclusions>
  25.                 <exclusion>
  26.                     <artifactId>seata-all</artifactId>
  27.                     <groupId>io.seata</groupId>
  28.                 </exclusion>
  29.             </exclusions>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>io.seata</groupId>
  33.             <artifactId>seata-all</artifactId>
  34.             <version>1.4.2</version>
  35.         </dependency>
  36.         <!--feign-->
  37.         <dependency>
  38.             <groupId>org.springframework.cloud</groupId>
  39.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  40.         </dependency>
  41.         <!--web-actuator-->
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-web</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-actuator</artifactId>
  49.         </dependency>
  50.         <!--mysql-druid-->
  51.         <dependency>
  52.             <groupId>mysql</groupId>
  53.             <artifactId>mysql-connector-java</artifactId>
  54.             <version>5.1.6</version>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>com.alibaba</groupId>
  58.             <artifactId>druid-spring-boot-starter</artifactId>
  59.             <version>1.1.10</version>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>org.mybatis.spring.boot</groupId>
  63.             <artifactId>mybatis-spring-boot-starter</artifactId>
  64.             <version>2.0.0</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>org.springframework.boot</groupId>
  68.             <artifactId>spring-boot-starter-test</artifactId>
  69.             <scope>test</scope>
  70.         </dependency>
  71.         <dependency>
  72.             <groupId>org.projectlombok</groupId>
  73.             <artifactId>lombok</artifactId>
  74.             <optional>true</optional>
  75.         </dependency>
  76.     </dependencies>
  78. </project>

application.yml

  1. server:
  2.   port: 2003
  4. spring:
  5.   application:
  6.     name: seata-account-service
  7.   cloud:
  8.     alibaba:
  9.       seata:
  10.         #自定义事务组名称需要与seata-server中的对应
  11.         tx-service-group: fsp_tx_group
  13.     nacos:
  14.       discovery:
  15.         server-addr: localhost:8848
  16.   datasource:
  17.     driver-class-name: com.mysql.jdbc.Driver
  18.     url: jdbc:mysql://localhost:3306/seata_order
  19.     username: root
  20.     password: 123456
  22. feign:
  23.   hystrix:
  24.     enabled: false
  26. logging:
  27.   level:
  28.     io:
  29.       seata: info
  31. mybatis:
  32.   mapperLocations: classpath:mapper/*.xml

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. transport {
  3.   # tcp, unix-domain-socket
  4.   type = "TCP"
  5.   #NIO, NATIVE
  6.   server = "NIO"
  7.   #enable heartbeat
  8.   heartbeat = true
  9.   # the client batch send request enable
  10.   enableClientBatchSendRequest = false
  11.   #thread factory for netty
  12.   threadFactory {
  14.     bossThreadPrefix = "NettyBoss"
  15.     workerThreadPrefix = "NettyServerNIOWorker"
  16.     serverExecutorThreadPrefix = "NettyServerBizHandler"
  17.     shareBossWorker = false
  18.     clientSelectorThreadPrefix = "NettyClientSelector"
  19.     clientSelectorThreadSize = 1
  20.     clientWorkerThreadPrefix = "NettyClientWorkerThread"
  21.     # netty boss thread size
  22.     bossThreadSize = 1
  23.     #auto default pin or 8
  24.     workerThreadSize = "default"
  25.   }
  26.   shutdown {
  28.     # when destroy server, wait seconds
  29.     wait = 3
  30.   }
  31.   serialization = "seata"
  32.   compressor = "none"
  33. }
  35. ## transaction log store, only used in server side
  36. store {
  38.   ## store mode: file、db
  39.   mode = "db"
  40.   ## file store property
  41.   file {
  43.     ## store location dir
  44.     dir = "sessionStore"
  45.     # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
  46.     maxBranchSessionSize = 16384
  47.     # globe session size , if exceeded throws exceptions
  48.     maxGlobalSessionSize = 512
  49.     # file buffer size , if exceeded allocate new buffer
  50.     fileWriteBufferCacheSize = 16384
  51.     # when recover batch read size
  52.     sessionReloadReadSize = 100
  53.     # async, sync
  54.     flushDiskMode = async
  55.   }
  57.   ## database store property
  58.   db {
  60.     ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
  61.     datasource = "druid"
  62.     ## mysql/oracle/postgresql/h2/oceanbase etc.
  63.     dbType = "mysql"
  64.     driverClassName = "com.mysql.jdbc.Driver"
  65.     ## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
  66.     url = "jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true"
  67.     user = "root"
  68.     password = "123456"
  69.     minConn = 5
  70.     maxConn = 30
  71.     globalTable = "global_table"
  72.     branchTable = "branch_table"
  73.     lockTable = "lock_table"
  74.     queryLimit = 100
  75.   }
  76. }
  77. ## server configuration, only used in server side
  78. server {
  80.   recovery {
  82.     #schedule committing retry period in milliseconds
  83.     committingRetryPeriod = 1000
  84.     #schedule asyn committing retry period in milliseconds
  85.     asynCommittingRetryPeriod = 1000
  86.     #schedule rollbacking retry period in milliseconds
  87.     rollbackingRetryPeriod = 1000
  88.     #schedule timeout retry period in milliseconds
  89.     timeoutRetryPeriod = 1000
  90.   }
  91.   undo {
  93.     logSaveDays = 7
  94.     #schedule delete expired undo_log in milliseconds
  95.     logDeletePeriod = 86400000
  96.   }
  97.   #check auth
  98.   enableCheckAuth = true
  99.   #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
  100.   maxCommitRetryTimeout = "-1"
  101.   maxRollbackRetryTimeout = "-1"
  102.   rollbackRetryTimeoutUnlockEnable = false
  103.   retryDeadThreshold = 130000
  105.   #新增
  106.   #vgroup->rgroup
  107.   ##fsp_tx_group是自定义的
  108.   vgroup_mapping.my.test.tx_group="fsp_tx_group"
  109. }
  111. ## metrics configuration, only used in server side
  112. metrics {
  114.   enabled = false
  115.   registryType = "compact"
  116.   # multi exporters use comma divided
  117.   exporterList = "prometheus"
  118.   exporterPrometheusPort = 9898
  119. }

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

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  1. registry {
  3.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  4.   type = "nacos"
  6.   nacos {
  8.     application = "seata-server"
  9.     serverAddr = "127.0.0.1:8848"
  10.     group = "SEATA_GROUP"
  11.     namespace = ""
  12.     cluster = "default"
  13.     username = ""
  14.     password = ""
  15.   }
  16.   eureka {
  18.     serviceUrl = "http://localhost:8761/eureka"
  19.     application = "default"
  20.     weight = "1"
  21.   }
  22.   redis {
  24.     serverAddr = "localhost:6379"
  25.     db = 0
  26.     password = ""
  27.     cluster = "default"
  28.     timeout = 0
  29.   }
  30.   zk {
  32.     cluster = "default"
  33.     serverAddr = "127.0.0.1:2181"
  34.     sessionTimeout = 6000
  35.     connectTimeout = 2000
  36.     username = ""
  37.     password = ""
  38.   }
  39.   consul {
  41.     cluster = "default"
  42.     serverAddr = "127.0.0.1:8500"
  43.     aclToken = ""
  44.   }
  45.   etcd3 {
  47.     cluster = "default"
  48.     serverAddr = "http://localhost:2379"
  49.   }
  50.   sofa {
  52.     serverAddr = "127.0.0.1:9603"
  53.     application = "default"
  54.     region = "DEFAULT_ZONE"
  55.     datacenter = "DefaultDataCenter"
  56.     cluster = "default"
  57.     group = "SEATA_GROUP"
  58.     addressWaitTime = "3000"
  59.   }
  60.   file {
  62.     name = "file.conf"
  63.   }
  64. }
  66. config {
  68.   # file、nacos 、apollo、zk、consul、etcd3
  69.   type = "nacos"
  71.   nacos {
  73.     serverAddr = "127.0.0.1:8848"
  74.     namespace = ""
  75.     group = "SEATA_GROUP"
  76.     username = ""
  77.     password = ""
  78.     dataId = "seataServer.properties"
  79.   }
  80.   consul {
  82.     serverAddr = "127.0.0.1:8500"
  83.     aclToken = ""
  84.   }
  85.   apollo {
  87.     appId = "seata-server"
  88.     ## apolloConfigService will cover apolloMeta
  89.     apolloMeta = "http://192.168.1.204:8801"
  90.     apolloConfigService = "http://192.168.1.204:8080"
  91.     namespace = "application"
  92.     apolloAccesskeySecret = ""
  93.     cluster = "seata"
  94.   }
  95.   zk {
  97.     serverAddr = "127.0.0.1:2181"
  98.     sessionTimeout = 6000
  99.     connectTimeout = 2000
  100.     username = ""
  101.     password = ""
  102.     nodePath = "/seata/seata.properties"
  103.   }
  104.   etcd3 {
  106.     serverAddr = "http://localhost:2379"
  107.   }
  108.   file {
  110.     name = "file.conf"
  111.   }
  112. }

创建类 entity.CommonResult

  1. package com.atguigu.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. @Data
  8. @AllArgsConstructor
  9. @NoArgsConstructor
  10. public class CommonResult<T>
  11. {
  13.     private Integer code;
  14.     private String  message;
  15.     private T       data;
  17.     public CommonResult(Integer code, String message)
  18.     {
  20.         this(code,message,null);
  21.     }
  22. }

创建类 entity.Account

  1. package com.atguigu.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. import java.math.BigDecimal;
  9. @Data
  10. @AllArgsConstructor
  11. @NoArgsConstructor
  12. public class Account {
  14.     private Long id;
  16.     /**
  17.      * 用户id
  18.      */
  19.     private Long userId;
  21.     /**
  22.      * 总额度
  23.      */
  24.     private BigDecimal total;
  26.     /**
  27.      * 已用额度
  28.      */
  29.     private BigDecimal used;
  31.     /**
  32.      * 剩余额度
  33.      */
  34.     private BigDecimal residue;
  35. }

Mapper接口及实现

创建接口 mapper.AccountMapper

  1. package com.atguigu.springcloud.mapper;
  3. import org.apache.ibatis.annotations.Mapper;
  4. import org.apache.ibatis.annotations.Param;
  6. import java.math.BigDecimal;
  8. @Mapper
  9. public interface AccountMapper {
  11.     /**
  12.      * 扣减账户余额
  13.      */
  14.     void decrease(@Param("userId") Long userId, @Param("money") BigDecimal money);
  15. }

mapper.AccountMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.atguigu.springcloud.mapper.AccountMapper">
  4.     <!-- 扣减账户余额 -->
  5.     <!-- void decrease(@Param("userId") Long userId, @Param("money") BigDecimal money); -->
  6.     <update id="decrease" parameterType="com.atguigu.springcloud.entity.Account">
  7.         update seata_account.t_account
  8.         set residue = residue - #{money}, used = used + #{money}
  9.         where user_id = #{userId}
  10.     </update>
  12.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entity.Account">
  13.         <id column="id" property="id" jdbcType="BIGINT"/>
  14.         <result column="user_id" property="userId" jdbcType="BIGINT"/>
  15.         <result column="total" property="total" jdbcType="DECIMAL"/>
  16.         <result column="used" property="used" jdbcType="DECIMAL"/>
  17.         <result column="residue" property="residue" jdbcType="DECIMAL"/>
  18.     </resultMap>
  20. </mapper>

Service接口及实现

service.AccountService

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

service.impl.AccountServiceImpl

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.mapper.AccountMapper;
  4. import com.atguigu.springcloud.service.AccountService;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.stereotype.Service;
  8. import javax.annotation.Resource;
  9. import java.math.BigDecimal;
  11. @Service
  12. @Slf4j
  13. public class AccountServiceImpl implements AccountService {
  16.     @Resource
  17.     private AccountMapper accountMapper;
  19.     /**
  20.      * 扣减账户余额
  21.      * @param userId 用户 id
  22.      * @param money 金额
  23.      */
  24.     @Override
  25.     public void decrease(Long userId, BigDecimal money) {
  27.         log.info("------->account-service中扣减账户余额开始");
  28.         accountMapper.decrease(userId,money);
  29.         log.info("------->account-service中扣减账户余额结束");
  30.     }
  31. }

Controller

controller.AccountController

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entity.CommonResult;
  4. import com.atguigu.springcloud.service.AccountService;
  5. import org.springframework.web.bind.annotation.RequestMapping;
  6. import org.springframework.web.bind.annotation.RequestParam;
  7. import org.springframework.web.bind.annotation.RestController;
  9. import javax.annotation.Resource;
  10. import java.math.BigDecimal;
  12. @RestController
  13. public class AccountController {
  16.     @Resource
  17.     private AccountService accountService;
  19.     /**
  20.      * 扣减账户余额
  21.      * @param userId
  22.      * @param money
  23.      * @return
  24.      */
  25.     @RequestMapping("/account/decrease")
  26.     public CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money){
  28.         accountService.decrease(userId, money);
  29.         return new CommonResult(200,"扣减账户余额成功！");
  30.     }
  31. }

Config配置

config.MyBatisConfig

  1. package com.atguigu.springcloud.config;
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.context.annotation.Configuration;
  6. @Configuration
  7. @MapperScan("com.atguigu.springcloud.mapper")
  8. public class MyBatisConfig {
  10. }

config.DataSourceProxyConfig

  1. package com.atguigu.springcloud.config;
  4. import com.alibaba.druid.pool.DruidDataSource;
  5. import io.seata.rm.datasource.DataSourceProxy;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.mybatis.spring.SqlSessionFactoryBean;
  8. import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
  9. import org.springframework.beans.factory.annotation.Value;
  10. import org.springframework.boot.context.properties.ConfigurationProperties;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  13. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
  15. import javax.sql.DataSource;
  18. /**
  19.  * 使用Seata对数据源进行代理
  20.  */
  21. @Configuration
  22. public class DataSourceProxyConfig {
  25.     @Value("${mybatis.mapperLocations}")
  26.     private String mapperLocations;
  28.     @Bean
  29.     @ConfigurationProperties(prefix = "spring.datasource")
  30.     public DataSource druidDataSource(){
  32.         return new DruidDataSource();
  33.     }
  35.     @Bean
  36.     public DataSourceProxy dataSourceProxy(DataSource dataSource) {
  38.         return new DataSourceProxy(dataSource);
  39.     }
  41.     @Bean
  42.     public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
  44.         SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
  45.         sqlSessionFactoryBean.setDataSource(dataSourceProxy);
  46.         sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
  47.         sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
  48.         return sqlSessionFactoryBean.getObject();
  49.     }
  50. }

主启动类 SeataAccountMainApp2003

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.cloud.openfeign.EnableFeignClients;
  9. @EnableDiscoveryClient
  10. @EnableFeignClients
  11. //取消数据源的自动创建，而是使用自己定义的
  12. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
  13. public class SeataAccountMainApp2003 {
  15.     public static void main(String[] args) {
  17.         SpringApplication.run(SeataAccountMainApp2003.class, args);
  18.     }
  19. }

启动微服务2003

在这里插入图片描述

Seata之@GlobalTransactional验证

在这里插入图片描述

数据库初始情况：

在这里插入图片描述

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

在这里插入图片描述

数据库正常下单后状况：

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

超时异常，没加@GlobalTransactional

模拟AccountServiceImpl添加超时

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.mapper.AccountMapper;
  4. import com.atguigu.springcloud.service.AccountService;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.stereotype.Service;
  8. import javax.annotation.Resource;
  9. import java.math.BigDecimal;
  10. import java.util.concurrent.TimeUnit;
  12. @Service
  13. @Slf4j
  14. public class AccountServiceImpl implements AccountService {
  17.     @Resource
  18.     private AccountMapper accountMapper;
  20.     /**
  21.      * 扣减账户余额
  22.      * @param userId 用户 id
  23.      * @param money 金额
  24.      */
  25.     @Override
  26.     public void decrease(Long userId, BigDecimal money) {
  28.         log.info("------->account-service中扣减账户余额开始");
  29.         //模拟超时异常，全局事务回滚
  30.         //暂停几秒钟线程
  31.         try {
  32.      TimeUnit.SECONDS.sleep(20); } catch (InterruptedException e) {
  33.      e.printStackTrace(); }
  34.         accountMapper.decrease(userId,money);
  35.         log.info("------->account-service中扣减账户余额结束");
  36.     }
  37. }

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

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

在这里插入图片描述

数据库情况

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

故障情况

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

超时异常，加了@GlobalTransactional

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

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.entity.Order;
  4. import com.atguigu.springcloud.mapper.OrderMapper;
  5. import com.atguigu.springcloud.service.AccountService;
  6. import com.atguigu.springcloud.service.OrderService;
  7. import com.atguigu.springcloud.service.StorageService;
  8. import io.seata.spring.annotation.GlobalTransactional;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.stereotype.Service;
  12. import javax.annotation.Resource;
  14. @Service
  15. @Slf4j
  16. public class OrderServiceImpl implements OrderService {
  19.     @Resource
  20.     private OrderMapper orderMapper;
  22.     @Resource
  23.     private StorageService storageService;
  25.     @Resource
  26.     private AccountService accountService;
  28.     /**
  29.      * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
  30.      * 简单说：下订单->扣库存->减余额->改状态
  31.      */
  32.     // name = "fsp-create-order" 名称可以随便取，只要保证唯一性就可以
  33.     //rollbackFor = Exception.class表示对任意异常都进行回滚
  34.     @GlobalTransactional(name = "fsp-create-order", rollbackFor = Exception.class)
  35.     @Override
  36.     public void create(Order order) {
  38.         log.info("----->开始新建订单");
  40.         // 1. 新建订单
  41.         orderMapper.create(order);
  43.         // 2. 扣减库存
  44.         log.info("----->订单微服务开始调用库存，做扣减Count");
  45.         storageService.decrease(order.getProductId(), order.getCount());
  46.         log.info("----->订单微服务开始调用库存，做扣减end");
  48.         // 3. 扣除账户余额
  49.         log.info("----->订单微服务开始调用账户，做扣减Money");
  50.         accountService.decrease(order.getUserId(), order.getMoney());
  51.         log.info("----->订单微服务开始调用账户，做扣减end");
  53.         // 4. 修改订单状态 从0到1,1代表已经完成
  54.         log.info("----->修改订单状态开始");
  55.         orderMapper.update(order.getUserId(), 0);
  56.         log.info("----->修改订单状态结束");
  58.         log.info("----->下订单结束了，O(∩_∩)O哈哈~");
  60.     }
  61. }

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

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

Seata之原理简介

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

分布式事务的执行流程

在这里插入图片描述
在这里插入图片描述

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

在这里插入图片描述

一阶段加载

在这里插入图片描述
在这里插入图片描述

二阶段提交

在这里插入图片描述

二阶段回滚

在这里插入图片描述
在这里插入图片描述

补充

在这里插入图片描述

发表评论

表情：
评论列表 （有 0 条评论，230人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Seata 案例

    分布式事务问题由来 分布式前 ![在这里插入图片描述][8e66a18cc37f405d87b0548023924cb2.png] 分布式后 ![在这里插入图片描述

    桃扇骨桃扇骨/ 0 赞/ 231 阅读

    相关 【Seata】初识Seata

    Seata是 2019 年 1 月份蚂蚁金服和阿里巴巴共同开源的分布式事务解决方案。致力于提供高性能和简单易用的分布式事务服务，为用户打造一站式的分布式解决方案。 官网地址：

    爱被打了一巴掌爱被打了一巴掌/ 0 赞/ 170 阅读

    相关 Seata

    目录 1、分布式事务产生的背景？ 2、常见的分布式事务解决方案？ 3、什么是Seata？ 4、Seata分布式事务框架实现原理？ 5、SpringBoot如何整合Se

    古城微笑少年丶古城微笑少年丶/ 0 赞/ 519 阅读