SpringCloud整合Seata解决分布式事务(搭建+源码)

SpringCloud 整合Seata 解决分布式事务(搭建+源码)

作者：Thinking曹 2020-12-09 09:14:57

开发

前端

分布式 本篇Spring Cloud整合Seata之前，你必须要了解一下Spring Cloud Alibaba与Spring Boot、Spring Cloud之间的版本对应关系。

成都创新互联公司主要从事成都网站建设、做网站、网页设计、企业做网站、公司建网站等业务。立足成都服务乌拉特中,10余年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:028-86922220

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

前言

在当下微服务架构比较火热时，新一代微服务解决方案Spring Cloud Alibaba提供的开源分布式事务解决框架Seata无疑成为了我们在解决分布式事务时的首要之选，前面两篇文章分别介绍了常见的分布式解决方案和成熟的框架以及关于Seata概念的入门介绍，没有过分布式事务处理的小伙伴可以先有个大致的入门了解：

  • SpringCloud Alibaba微服务架构(十一)- 常见分布式事务解决方案及理论基础篇
  • SpringCloud Alibaba微服务架构(十二)- 分布式事务解决框架之Seata概念入门篇

那么在本篇Spring Cloud整合Seata之前，你必须要了解一下Spring Cloud Alibaba与Spring Boot、Spring Cloud之间的版本对应关系。

版本选择： Spring Cloud Alibaba与Spring Boot、Spring Cloud版本对应关系

一、版本要求

坑点1： 如果项目中使用了druid数据库连接池，引入的是SpringBoot的Starter依赖druid-spring-boot-starter，那么需要把druid-spring-boot-starter依赖换成druid1.1.23，因为seata源码中引入的druid依赖跟druid-spring-boot-starter的自动装配类冲突了，冲突的情况下项目启动出现异常，异常如下：

二、整合Seata环境配置

1. 下载seata-server-1.2.0和seata-1.2.0源码

seate-server下载： https://seata.io/zh-cn/blog/download.html，下载我们需要使用的seata1.2压缩包。

seata-1.2.0源码下载： https://github.com/seata/seata/releases

在这里插入图片描述

2. 创建undo_log日志表

在seata1.2源码seata-1.2.0\script\client\at\db目录下有提供针对mysql、oracle、postgresql这三种数据库生成undo-log逆向日志回滚表的表创建脚本。

  • 在你项目的参与全局事务的数据库中加入undo_log这张表。undo_log表脚本根据自身数据库类型来选择。
  
 
 
 
    
   
  
  
  
  1. -- for AT mode you must to init this sql for you business database. the seata server not need it. 
    2. 
   
  
  
  
  2. CREATE TABLE IF NOT EXISTS `undo_log` 
    3. 
   
  
  
  
  3. ( 
    4. 
   
  
  
  
  4.     `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id', 
    5. 
   
  
  
  
  5.     `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id', 
    6. 
   
  
  
  
  6.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization', 
    7. 
   
  
  
  
  7.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info', 
    8. 
   
  
  
  
  8.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status', 
    9. 
   
  
  
  
  9.     `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime', 
    10. 
   
  
  
  
  10.     `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime', 
    11. 
   
  
  
  
  11.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`) 
    12. 
   
  
  
  
  12. ) ENGINE = InnoDB 
    13. 
   
  
  
  
  13.   AUTO_INCREMENT = 1 
    14. 
   
  
  
  
  14.   DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table'; 
    15.

3.创建seata事务相关表

下载Seata1.2的源码后解压如上图，目前支持mysql、oracle、postgresql这三种数据库，上述三种脚本是针对Seata的Sever端在协调处理分布式事务时所需要的3张表，提供了不同数据库的global_table表、branch_table表、lock_table表创建脚本，根据自身数据库执行对应的sql脚本执行即可。

这里以mysql为例，在你的mysql数据库中创建名为seata的库，并执行以下sql，将会生成三张表：

  
 
 
 
    
   
  
  
  
  1. -- -------------------------------- The script used when storeMode is 'db' -------------------------------- 
    2. 
   
  
  
  
  2. -- the table to store GlobalSession data 
    3. 
   
  
  
  
  3. CREATE TABLE IF NOT EXISTS `global_table` 
    4. 
   
  
  
  
  4. ( 
    5. 
   
  
  
  
  5.     `xid`                       VARCHAR(128) NOT NULL, 
    6. 
   
  
  
  
  6.     `transaction_id`            BIGINT, 
    7. 
   
  
  
  
  7.     `status`                    TINYINT      NOT NULL, 
    8. 
   
  
  
  
  8.     `application_id`            VARCHAR(32), 
    9. 
   
  
  
  
  9.     `transaction_service_group` VARCHAR(32), 
    10. 
   
  
  
  
  10.     `transaction_name`          VARCHAR(128), 
    11. 
   
  
  
  
  11.     `timeout`                   INT, 
    12. 
   
  
  
  
  12.     `begin_time`                BIGINT, 
    13. 
   
  
  
  
  13.     `application_data`          VARCHAR(2000), 
    14. 
   
  
  
  
  14.     `gmt_create`                DATETIME, 
    15. 
   
  
  
  
  15.     `gmt_modified`              DATETIME, 
    16. 
   
  
  
  
  16.     PRIMARY KEY (`xid`), 
    17. 
   
  
  
  
  17.     KEY `idx_gmt_modified_status` (`gmt_modified`, `status`), 
    18. 
   
  
  
  
  18.     KEY `idx_transaction_id` (`transaction_id`) 
    19. 
   
  
  
  
  19. ) ENGINE = InnoDB 
    20. 
   
  
  
  
  20.   DEFAULT CHARSET = utf8; 
    21. 
   
  
  
  
  21.  
    22. 
   
  
  
  
  22. -- the table to store BranchSession data 
    23. 
   
  
  
  
  23. CREATE TABLE IF NOT EXISTS `branch_table` 
    24. 
   
  
  
  
  24. ( 
    25. 
   
  
  
  
  25.     `branch_id`         BIGINT       NOT NULL, 
    26. 
   
  
  
  
  26.     `xid`               VARCHAR(128) NOT NULL, 
    27. 
   
  
  
  
  27.     `transaction_id`    BIGINT, 
    28. 
   
  
  
  
  28.     `resource_group_id` VARCHAR(32), 
    29. 
   
  
  
  
  29.     `resource_id`       VARCHAR(256), 
    30. 
   
  
  
  
  30.     `branch_type`       VARCHAR(8), 
    31. 
   
  
  
  
  31.     `status`            TINYINT, 
    32. 
   
  
  
  
  32.     `client_id`         VARCHAR(64), 
    33. 
   
  
  
  
  33.     `application_data`  VARCHAR(2000), 
    34. 
   
  
  
  
  34.     `gmt_create`        DATETIME(6), 
    35. 
   
  
  
  
  35.     `gmt_modified`      DATETIME(6), 
    36. 
   
  
  
  
  36.     PRIMARY KEY (`branch_id`), 
    37. 
   
  
  
  
  37.     KEY `idx_xid` (`xid`) 
    38. 
   
  
  
  
  38. ) ENGINE = InnoDB 
    39. 
   
  
  
  
  39.   DEFAULT CHARSET = utf8; 
    40. 
   
  
  
  
  40.  
    41. 
   
  
  
  
  41. -- the table to store lock data 
    42. 
   
  
  
  
  42. CREATE TABLE IF NOT EXISTS `lock_table` 
    43. 
   
  
  
  
  43. ( 
    44. 
   
  
  
  
  44.     `row_key`        VARCHAR(128) NOT NULL, 
    45. 
   
  
  
  
  45.     `xid`            VARCHAR(96), 
    46. 
   
  
  
  
  46.     `transaction_id` BIGINT, 
    47. 
   
  
  
  
  47.     `branch_id`      BIGINT       NOT NULL, 
    48. 
   
  
  
  
  48.     `resource_id`    VARCHAR(256), 
    49. 
   
  
  
  
  49.     `table_name`     VARCHAR(32), 
    50. 
   
  
  
  
  50.     `pk`             VARCHAR(36), 
    51. 
   
  
  
  
  51.     `gmt_create`     DATETIME, 
    52. 
   
  
  
  
  52.     `gmt_modified`   DATETIME, 
    53. 
   
  
  
  
  53.     PRIMARY KEY (`row_key`), 
    54. 
   
  
  
  
  54.     KEY `idx_branch_id` (`branch_id`) 
    55. 
   
  
  
  
  55. ) ENGINE = InnoDB 
    56. 
   
  
  
  
  56.   DEFAULT CHARSET = utf8; 
    57.

4. 项目中引入seata依赖

4.1 如果微服务是SpringCloud

  
 
 
 
    
   
  
  
  
  1.  
    2. 
   
  
  
  
  2.  
    3. 
   
  
  
  
  3.  
    4. 
   
  
  
  
  4.    com.alibaba.cloud 
    5. 
   
  
  
  
  5.    spring-cloud-starter-alibaba-seata 
    6. 
   
  
  
  
  6.    2.1.3.RELEASE 
    7. 
   
  
  
  
  7.     
    8. 
   
  
  
  
  8.       
    9. 
   
  
  
  
  9.         io.seata 
    10. 
   
  
  
  
  10.         seata-spring-boot-starter 
    11. 
   
  
  
  
  11.          
    12. 
   
  
  
  
  12.     
    13. 
   
  
  
  
  13.  
    14. 
   
  
  
  
  14.  
    15. 
   
  
  
  
  15.     io.seata 
    16. 
   
  
  
  
  16.     seata-spring-boot-starter 
    17. 
   
  
  
  
  17.     1.2.0 
    18. 
   
  
  
  
  18.  
    19. 
   
  
  
  
  19.  
    20.

4.2 如果微服务是Dubbo

  
 
 
 
    
   
  
  
  
  1.  
    2. 
   
  
  
  
  2.     io.seata 
    3. 
   
  
  
  
  3.     seata-spring-boot-starter 
    4. 
   
  
  
  
  4.     1.2.0 
    5. 
   
  
  
  
  5.  
    6.

5. 更改seata-server中的registry.conf

配置registry.conf注册中心为nacos，配置nacos相关属性参数。

  
 
 
 
    
   
  
  
  
  1. ##配置seata-server的注册中心，支持file 、nacos 、eureka、redis、zk、consul、etcd3、sofa 
    2. 
   
  
  
  
  2. registry { 
    3. 
   
  
  
  
  3.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa 
    4. 
   
  
  
  
  4.   type = "nacos" 
    5. 
   
  
  
  
  5.  
    6. 
   
  
  
  
  6.   nacos { 
    7. 
   
  
  
  
  7.     application = "seata-server" 
    8. 
   
  
  
  
  8.     serverAddr = "127.0.0.1:8848" 
    9. 
   
  
  
  
  9.     group = "SEATA_GROUP" 
    10. 
   
  
  
  
  10.     namespace = "public" 
    11. 
   
  
  
  
  11.     username = "nacos" 
    12. 
   
  
  
  
  12.     cluster = "default" 
    13. 
   
  
  
  
  13.     password = "nacos" 
    14. 
   
  
  
  
  14.   } 
    15. 
   
  
  
  
  15.    
    16. 
   
  
  
  
  16.   file { 
    17. 
   
  
  
  
  17.     name = "file.conf" 
    18. 
   
  
  
  
  18.   } 
    19. 
   
  
  
  
  19. } 
    20. 
   
  
  
  
  20.  
    21. 
   
  
  
  
  21. ##配置seata-server的配置中心，支持file、nacos 、apollo、zk、consul、etcd3 
    22. 
   
  
  
  
  22. config { 
    23. 
   
  
  
  
  23.   # file、nacos 、apollo、zk、consul、etcd3 
    24. 
   
  
  
  
  24.   type = "nacos" 
    25. 
   
  
  
  
  25.  
    26. 
   
  
  
  
  26.   nacos { 
    27. 
   
  
  
  
  27.     serverAddr = "127.0.0.1:8848" 
    28. 
   
  
  
  
  28.     namespace = "public" 
    29. 
   
  
  
  
  29.     group = "SEATA_GROUP" 
    30. 
   
  
  
  
  30.     username = "nacos" 
    31. 
   
  
  
  
  31.     password = "nacos" 
    32. 
   
  
  
  
  32.   } 
    33. 
   
  
  
  
  33.   
    34. 
   
  
  
  
  34.   file { 
    35. 
   
  
  
  
  35.     name = "file.conf" 
    36. 
   
  
  
  
  36.   } 
    37. 
   
  
  
  
  37. } 
    38.

6. 修改seata-server中的file.config

配置file.config的DB模式相关参数配置。

  
 
 
 
    
   
  
  
  
  1. ##配置seata-server的数据存储方式，支持本地文档和数据库。 
    2. 
   
  
  
  
  2. ## transaction log store, only used in seata-server 
    3. 
   
  
  
  
  3. store { 
    4. 
   
  
  
  
  4.   ## store mode: file、db、redis 
    5. 
   
  
  
  
  5.   mode = "db" 
    6. 
   
  
  
  
  6.  
    7. 
   
  
  
  
  7.   ## file store property 
    8. 
   
  
  
  
  8.   file { 
    9. 
   
  
  
  
  9.     ## store location dir 
    10. 
   
  
  
  
  10.     dir = "sessionStore" 
    11. 
   
  
  
  
  11.     # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions 
    12. 
   
  
  
  
  12.     maxBranchSessionSize = 16384 
    13. 
   
  
  
  
  13.     # globe session size , if exceeded throws exceptions 
    14. 
   
  
  
  
  14.     maxGlobalSessionSize = 512 
    15. 
   
  
  
  
  15.     # file buffer size , if exceeded allocate new buffer 
    16. 
   
  
  
  
  16.     fileWriteBufferCacheSize = 16384 
    17. 
   
  
  
  
  17.     # when recover batch read size 
    18. 
   
  
  
  
  18.     sessionReloadReadSize = 100 
    19. 
   
  
  
  
  19.     # async, sync 
    20. 
   
  
  
  
  20.     flushDiskMode = async 
    21. 
   
  
  
  
  21.   } 
    22. 
   
  
  
  
  22.  
    23. 
   
  
  
  
  23.   ## database store property 
    24. 
   
  
  
  
  24.   db { 
    25. 
   
  
  
  
  25.     ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc. 
    26. 
   
  
  
  
  26.     datasource = "druid" 
    27. 
   
  
  
  
  27.     ## mysql/oracle/postgresql/h2/oceanbase etc. 
    28. 
   
  
  
  
  28.     dbType = "mysql" 
    29. 
   
  
  
  
  29.     driverClassName = "com.mysql.jdbc.Driver" 
    30. 
   
  
  
  
  30.     url = "jdbc:mysql://127.0.0.1:3306/seata" 
    31. 
   
  
  
  
  31.     user = "root" 
    32. 
   
  
  
  
  32.     password = "root" 
    33. 
   
  
  
  
  33.     minConn = 5 
    34. 
   
  
  
  
  34.     maxConn = 30 
    35. 
   
  
  
  
  35.     globalTable = "global_table" 
    36. 
   
  
  
  
  36.     branchTable = "branch_table" 
    37. 
   
  
  
  
  37.     lockTable = "lock_table" 
    38. 
   
  
  
  
  38.     queryLimit = 100 
    39. 
   
  
  
  
  39.     maxWait = 5000 
    40. 
   
  
  
  
  40.   } 
    41. 
   
  
  
  
  41.  
    42. 
   
  
  
  
  42.   ## redis store property 
    43. 
   
  
  
  
  43.   redis { 
    44. 
   
  
  
  
  44.     host = "127.0.0.1" 
    45. 
   
  
  
  
  45.     port = "6379" 
    46. 
   
  
  
  
  46.     password = "" 
    47. 
   
  
  
  
  47.     database = "0" 
    48. 
   
  
  
  
  48.     minConn = 1 
    49. 
   
  
  
  
  49.     maxConn = 10 
    50. 
   
  
  
  
  50.     queryLimit = 100 
    51. 
   
  
  
  
  51.   } 
    52. 
   
  
  
  
  52. } 
    53.

7. 修改提交nacos脚本到nacos控制台

运行你下载的nacos，并参考：https://github.com/seata/seata/tree/develop/script/config-center 下的config.txt文件并修改：

  
 
 
 
    
   
  
  
  
  1. service.vgroupMapping.my_test_tx_group=default 
    2. 
   
  
  
  
  2. store.mode=db 
    3. 
   
  
  
  
  3. store.db.datasource=druid 
    4. 
   
  
  
  
  4. store.db.dbType=mysql 
    5. 
   
  
  
  
  5. store.db.driverClassName=com.mysql.jdbc.Driver 
    6. 
   
  
  
  
  6. store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true 
    7. 
   
  
  
  
  7. store.db.user=username 
    8. 
   
  
  
  
  8. store.db.password=password 
    9. 
   
  
  
  
  9. store.db.minConn=5 
    10. 
   
  
  
  
  10. store.db.maxConn=30 
    11. 
   
  
  
  
  11. store.db.globalTable=global_table 
    12. 
   
  
  
  
  12. store.db.branchTable=branch_table 
    13. 
   
  
  
  
  13. store.db.queryLimit=100 
    14. 
   
  
  
  
  14. store.db.lockTable=lock_table 
    15. 
   
  
  
  
  15. store.db.maxWait=5000 
    16.

运行仓库：https://github.com/seata/seata/tree/develop/script/config-center/nacos 中提供的nacos脚本nacos-config.sh，将以上信息提交到nacos控制台，如果有需要修改参数，可直接通过登录nacos控制台修改。

操作如下图：

8. application.yml配置

从官方github仓库：https://github.com/seata/seata/tree/develop/script/client 拿到参考配置做修改，加到你项目的application.yml文件中。

  
 
 
 
    
   
  
  
  
  1. #Seata分布式事务配置(AT模式) 
    2. 
   
  
  
  
  2. seata: 
    3. 
   
  
  
  
  3.   enabled: true 
    4. 
   
  
  
  
  4.   application-id: ${spring.application.name} 
    5. 
   
  
  
  
  5.   #客户端和服务端在同一个事务组 
    6. 
   
  
  
  
  6.   tx-service-group: my_test_tx_group 
    7. 
   
  
  
  
  7.   enable-auto-data-source-proxy: true 
    8. 
   
  
  
  
  8.   service: 
    9. 
   
  
  
  
  9.     vgroup-mapping: 
    10. 
   
  
  
  
  10.       my_test_tx_group: default 
    11. 
   
  
  
  
  11.   config: 
    12. 
   
  
  
  
  12.     type: nacos 
    13. 
   
  
  
  
  13.     nacos: 
    14. 
   
  
  
  
  14.       namespace: "public" 
    15. 
   
  
  
  
  15.       serverAddr: 127.0.0.1:8848 
    16. 
   
  
  
  
  16.       group: SEATA_GROUP 
    17. 
   
  
  
  
  17.       username: "nacos" 
    18. 
   
  
  
  
  18.       password: "nacos" 
    19. 
   
  
  
  
  19.   #服务注册到nacos 
    20. 
   
  
  
  
  20.   registry: 
    21. 
   
  
  
  
  21.     type: nacos 
    22. 
   
  
  
  
  22.     nacos: 
    23. 
   
  
  
  
  23.       application: seata-server 
    24. 
   
  
  
  
  24.       server-addr: 127.0.0.1:8848 
    25. 
   
  
  
  
  25.       group: SEATA_GROUP 
    26. 
   
  
  
  
  26.       namespace: "public" 
    27. 
   
  
  
  
  27.       username: "nacos" 
    28. 
   
  
  
  
  28.       password: "nacos" 
    29. 
   
  
  
  
  29.       cluster: default 
    30.

9. 运行seata-server

启动运行seata-server，成功后，运行自己的服务提供者，服务参与者。在全局事务调用者(发起全局事务的服务)的接口上加入@GlobalTransactional注解

到此为止，整合SpringCloud整合seata1.2及seata1.2整合nacos的配置与注册中心全部整合完成了。

三、项目准备

如果你经过前面的步骤搭建Seata环境完成了，那么你可以尝试一下启动项目，控制台无异常则搭建成功。

那么下面准备以Seata官方文档上的一个经典例子为题，模拟用户下单，创建订单同时扣减库存数量这一过程中产生的分布式事务问题，然后使用Seata解决，正好使用以下Seata的特性。

1. 订单服务

  • OrderController
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc:  订单服务 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:27 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. @RestController 
    7. 
   
  
  
  
  7. @Slf4j 
    8. 
   
  
  
  
  8. @RequestMapping("/order") 
    9. 
   
  
  
  
  9. public class OrderController { 
    10. 
   
  
  
  
  10.  
    11. 
   
  
  
  
  11.     @Autowired 
    12. 
   
  
  
  
  12.     private OrderServiceImpl orderService; 
    13. 
   
  
  
  
  13.  
    14. 
   
  
  
  
  14.     /** 
    15. 
   
  
  
  
  15.      * 用户购买下单，模拟全局事务提交 
    16. 
   
  
  
  
  16.      * @param pid 
    17. 
   
  
  
  
  17.      * @return 
    18. 
   
  
  
  
  18.      */ 
    19. 
   
  
  
  
  19.     @RequestMapping("/purchase/commit/{pid}") 
    20. 
   
  
  
  
  20.     public Order orderCommit(@PathVariable("pid") Integer pid) { 
    21. 
   
  
  
  
  21.         return orderService.createOrderCommit(pid); 
    22. 
   
  
  
  
  22.     } 
    23. 
   
  
  
  
  23.  
    24. 
   
  
  
  
  24.     /** 
    25. 
   
  
  
  
  25.      * 用户购买下单，模拟全局事务回滚 
    26. 
   
  
  
  
  26.      * @param pid 
    27. 
   
  
  
  
  27.      * @return 
    28. 
   
  
  
  
  28.      */ 
    29. 
   
  
  
  
  29.     @RequestMapping("/purchase/rollback/{pid}") 
    30. 
   
  
  
  
  30.     public Order orderRollback(@PathVariable("pid") Integer pid) { 
    31. 
   
  
  
  
  31.         return orderService.createOrderRollback(pid); 
    32. 
   
  
  
  
  32.     } 
    33. 
   
  
  
  
  33.  
    34. 
   
  
  
  
  34. } 
    35.
  • OrderServiceImpl
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc: 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:30 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. @Service 
    7. 
   
  
  
  
  7. @Slf4j 
    8. 
   
  
  
  
  8. public class OrderServiceImpl { 
    9. 
   
  
  
  
  9.     @Autowired 
    10. 
   
  
  
  
  10.     private OrderDao orderDao; 
    11. 
   
  
  
  
  11.  
    12. 
   
  
  
  
  12.     @Autowired 
    13. 
   
  
  
  
  13.     private ProductService productService; 
    14. 
   
  
  
  
  14.  
    15. 
   
  
  
  
  15.     //用户下单，模拟全局事务提交 
    16. 
   
  
  
  
  16.     public Order createOrderCommit(Integer pid) { 
    17. 
   
  
  
  
  17.         log.info("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息", pid); 
    18. 
   
  
  
  
  18.  
    19. 
   
  
  
  
  19.         //1 调用商品微服务,查询商品信息 
    20. 
   
  
  
  
  20.         Product product = productService.findByPid(pid); 
    21. 
   
  
  
  
  21.         log.info("查询到{}号商品的信息,内容是:{}", pid, JSON.toJSONString(product)); 
    22. 
   
  
  
  
  22.  
    23. 
   
  
  
  
  23.         //2 下单(创建订单) 
    24. 
   
  
  
  
  24.         Order order = new Order(); 
    25. 
   
  
  
  
  25.         order.setUid(1); 
    26. 
   
  
  
  
  26.         order.setUsername("测试用户"); 
    27. 
   
  
  
  
  27.         order.setPid(pid); 
    28. 
   
  
  
  
  28.         order.setPname(product.getPname()); 
    29. 
   
  
  
  
  29.         order.setPprice(product.getPprice()); 
    30. 
   
  
  
  
  30.         order.setNumber(1); 
    31. 
   
  
  
  
  31.         orderDao.save(order); 
    32. 
   
  
  
  
  32.         log.info("创建订单成功,订单信息为{}", JSON.toJSONString(order)); 
    33. 
   
  
  
  
  33.  
    34. 
   
  
  
  
  34.         //3 扣库存m 
    35. 
   
  
  
  
  35.         productService.reduceInventoryCommit(pid, order.getNumber()); 
    36. 
   
  
  
  
  36.  
    37. 
   
  
  
  
  37.         return order; 
    38. 
   
  
  
  
  38.     } 
    39. 
   
  
  
  
  39.  
    40. 
   
  
  
  
  40.     //用户下单，模拟全局事务回滚 
    41. 
   
  
  
  
  41.     @GlobalTransactional//全局事务控制 
    42. 
   
  
  
  
  42.     public Order createOrderRollback(Integer pid) { 
    43. 
   
  
  
  
  43.         log.info("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息", pid); 
    44. 
   
  
  
  
  44.  
    45. 
   
  
  
  
  45.         //1 调用商品微服务,查询商品信息 
    46. 
   
  
  
  
  46.         Product product = productService.findByPid(pid); 
    47. 
   
  
  
  
  47.         log.info("查询到{}号商品的信息,内容是:{}", pid, JSON.toJSONString(product)); 
    48. 
   
  
  
  
  48.  
    49. 
   
  
  
  
  49.         //2 下单(创建订单) 
    50. 
   
  
  
  
  50.         Order order = new Order(); 
    51. 
   
  
  
  
  51.         order.setUid(1); 
    52. 
   
  
  
  
  52.         order.setUsername("测试用户"); 
    53. 
   
  
  
  
  53.         order.setPid(pid); 
    54. 
   
  
  
  
  54.         order.setPname(product.getPname()); 
    55. 
   
  
  
  
  55.         order.setPprice(product.getPprice()); 
    56. 
   
  
  
  
  56.         order.setNumber(1); 
    57. 
   
  
  
  
  57.         orderDao.save(order); 
    58. 
   
  
  
  
  58.         log.info("创建订单成功,订单信息为{}", JSON.toJSONString(order)); 
    59. 
   
  
  
  
  59.  
    60. 
   
  
  
  
  60.         //3 扣库存m 
    61. 
   
  
  
  
  61.         productService.reduceInventoryRollback(pid, order.getNumber()); 
    62. 
   
  
  
  
  62.  
    63. 
   
  
  
  
  63.         return order; 
    64. 
   
  
  
  
  64.     } 
    65. 
   
  
  
  
  65.  
    66. 
   
  
  
  
  66. } 
    67.
  • 商品服务的Feign类ProductService
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc: 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:43 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. @FeignClient(value = "product-service",configuration = FeignRequestInterceptor.class) 
    7. 
   
  
  
  
  7. public interface ProductService { 
    8. 
   
  
  
  
  8.     //@FeignClient的value +  @RequestMapping的value值  其实就是完成的请求地址  "http://product-service/product/" + pid 
    9. 
   
  
  
  
  9.     //指定请求的URI部分 
    10. 
   
  
  
  
  10.     @RequestMapping("/product/product/{pid}") 
    11. 
   
  
  
  
  11.     Product findByPid(@PathVariable Integer pid); 
    12. 
   
  
  
  
  12.  
    13. 
   
  
  
  
  13.     //扣减库存,模拟全局事务提交 
    14. 
   
  
  
  
  14.     //参数一: 商品标识 
    15. 
   
  
  
  
  15.     //参数二:扣减数量 
    16. 
   
  
  
  
  16.     @RequestMapping("/product/reduceInventory/commit") 
    17. 
   
  
  
  
  17.     void reduceInventoryCommit(@RequestParam("pid") Integer pid, 
    18. 
   
  
  
  
  18.                                @RequestParam("number") Integer number); 
    19. 
   
  
  
  
  19.  
    20. 
   
  
  
  
  20.     //扣减库存,模拟全局事务回滚 
    21. 
   
  
  
  
  21.     //参数一: 商品标识 
    22. 
   
  
  
  
  22.     //参数二:扣减数量 
    23. 
   
  
  
  
  23.     @RequestMapping("/product/reduceInventory/rollback") 
    24. 
   
  
  
  
  24.     void reduceInventoryRollback(@RequestParam("pid") Integer pid, 
    25. 
   
  
  
  
  25.                          @RequestParam("number") Integer number); 
    26. 
   
  
  
  
  26.  
    27. 
   
  
  
  
  27. } 
    28.

2. 商品服务

  • ProductController
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc: 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:16 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. @RestController 
    7. 
   
  
  
  
  7. @Slf4j 
    8. 
   
  
  
  
  8. @RequestMapping("/product") 
    9. 
   
  
  
  
  9. public class ProductController { 
    10. 
   
  
  
  
  10.  
    11. 
   
  
  
  
  11.     @Autowired 
    12. 
   
  
  
  
  12.     private ProductService productService; 
    13. 
   
  
  
  
  13.  
    14. 
   
  
  
  
  14.     /** 
    15. 
   
  
  
  
  15.      * 扣减库存，正常->模拟全局事务提交 
    16. 
   
  
  
  
  16.      * @param pid 
    17. 
   
  
  
  
  17.      * @param number 
    18. 
   
  
  
  
  18.      */ 
    19. 
   
  
  
  
  19.     @RequestMapping("/reduceInventory/commit") 
    20. 
   
  
  
  
  20.     public void reduceInventoryCommit(Integer pid, Integer number) { 
    21. 
   
  
  
  
  21.         String token = ServletUtils.getRequest().getHeader("token"); 
    22. 
   
  
  
  
  22.         log.info("从head请求头透传过来的值为token："+ token); 
    23. 
   
  
  
  
  23.         productService.reduceInventoryCommit(pid, number); 
    24. 
   
  
  
  
  24.     } 
    25. 
   
  
  
  
  25.  
    26. 
   
  
  
  
  26.     /** 
    27. 
   
  
  
  
  27.      * 扣减库存，异常->模拟全局事务回滚 
    28. 
   
  
  
  
  28.      * @param pid 
    29. 
   
  
  
  
  29.      * @param number 
    30. 
   
  
  
  
  30.      */ 
    31. 
   
  
  
  
  31.     @RequestMapping("/reduceInventory/rollback") 
    32. 
   
  
  
  
  32.     public void reduceInventoryRollback(Integer pid, Integer number) { 
    33. 
   
  
  
  
  33.         productService.reduceInventoryRollback(pid, number); 
    34. 
   
  
  
  
  34.     } 
    35. 
   
  
  
  
  35.  
    36. 
   
  
  
  
  36.     //商品信息查询 
    37. 
   
  
  
  
  37.     @RequestMapping("/product/{pid}") 
    38. 
   
  
  
  
  38.     public Product product(@PathVariable("pid") Integer pid) { 
    39. 
   
  
  
  
  39.         log.info("接下来要进行{}号商品信息的查询", pid); 
    40. 
   
  
  
  
  40.         Product product = productService.findByPid(pid); 
    41. 
   
  
  
  
  41.         log.info("商品信息查询成功,内容为{}", JSON.toJSONString(product)); 
    42. 
   
  
  
  
  42.         return product; 
    43. 
   
  
  
  
  43.     } 
    44. 
   
  
  
  
  44. } 
    45.
  • ProductService接口类
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc:  商品接口 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:18 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. public interface ProductService { 
    7. 
   
  
  
  
  7.     //根据pid查询商品信息 
    8. 
   
  
  
  
  8.     Product findByPid(Integer pid); 
    9. 
   
  
  
  
  9.  
    10. 
   
  
  
  
  10.     //扣减库存，正常->模拟全局事务提交 
    11. 
   
  
  
  
  11.     void reduceInventoryCommit(Integer pid, Integer number); 
    12. 
   
  
  
  
  12.  
    13. 
   
  
  
  
  13.     //扣减库存，异常->模拟全局事务回滚 
    14. 
   
  
  
  
  14.     void reduceInventoryRollback(Integer pid, Integer number); 
    15. 
   
  
  
  
  15. } 
    16.
  • ProductServiceImpl 接口实现类
  
 
 
 
    
   
  
  
  
  1. /** 
    2. 
   
  
  
  
  2.  * @desc:  商品服务实现类 
    3. 
   
  
  
  
  3.  * @author: cao_wencao 
    4. 
   
  
  
  
  4.  * @date: 2020-09-22 23:20 
    5. 
   
  
  
  
  5.  */ 
    6. 
   
  
  
  
  6. @Service 
    7. 
   
  
  
  
  7. public class ProductServiceImpl implements ProductService { 
    8. 
   
  
  
  
  8.  
    9. 
   
  
  
  
  9.     @Autowired 
    10. 
   
  
  
  
  10.     private ProductDao productDao; 
    11. 
   
  
  
  
  11.  
    12. 
   
  
  
  
  12.     @Override 
    13. 
   
  
  
  
  13.     public Product findByPid(Integer pid) { 
    14. 
   
  
  
  
  14.         return productDao.findById(pid).get(); 
    15. 
   
  
  
  
  15.     } 
    16. 
   
  
  
  
  16.  
    17. 
   
  
  
  
  17.     /** 
    18. 
   
  
  
  
  18.      * 扣减库存，正常->模拟全局事务提交 
    19. 
   
  
  
  
  19.      * @param pid 
    20. 
   
  
  
  
  20.      * @param number 
    21. 
   
  
  
  
  21.      */ 
    22. 
   
  
  
  
  22.     @Override 
    23. 
   
  
  
  
  23.     public void reduceInventoryCommit(Integer pid, Integer number) { 
    24. 
   
  
  
  
  24.         //查询 
    25. 
   
  
  
  
  25.         Product product = productDao.findById(pid).get(); 
    26. 
   
  
  
  
  26.         //省略校验 
    27. 
   
  
  
  
  27.  
    28. 
   
  
  
  
  28.         //内存中扣减 
    29. 
   
  
  
  
  29.         product.setStock(product.getStock() - number); 
    30. 
   
  
  
  
  30.  
    31. 
   
  
  
  
  31.         //保存扣减库存 
    32. 
   
  
  
  
  32.         productDao.save(product); 
    33. 
   
  
  
  
  33.     } 
    34. 
   
  
  
  
  34.  
    35. 
   
  
  
  
  35.     /** 
    36. 
   
  
  
  
  36.      * 扣减库存，异常->模拟全局事务回滚 
    37. 
   
  
  
  
  37.      * @param pid 
    38. 
   
  
  
  
  38.      * @param number 
    39. 
   
  
  
  
  39.      */ 
    40. 
   
  
  
  
  40.     @Transactional(rollbackFor = Exception.class)  //服务提供方本地事务注解 
    41. 
   
  
  
  
  41.     @Override 
    42. 
   
  
  
  
  42.     public void reduceInventoryRollback(Integer pid, Integer number) { 
    43. 
   
  
  
  
  43.         //查询 
    44. 
   
  
  
  
  44.         Product product = productDao.findById(pid).get(); 
    45. 
   
  
  
  
  45.         //省略校验 
    46. 
   
  
  
  
  46.  
    47. 
   
  
  
  
  47.         //内存中扣减 
    48. 
   
  
  
  
  48.         product.setStock(product.getStock() - number); 
    49. 
   
  
  
  
  49.  
    50. 
   
  
  
  
  50.         //模拟异常 
    51. 
   
  
  
  
  51.         int i = 1 / 0; 
    52. 
   
  
  
  
  52.  
    53. 
   
  
  
  
  53.         //保存扣减库存 
    54. 
   
  
  
  
  54.         productDao.save(product); 
    55. 
   
  
  
  
  55.     } 
    56. 
   
  
  
  
  56. } 
    57.

四、参考文档

seata官网:

  • http://seata.io/zh-cn/

Seata常见问题:

  • http://seata.io/zh-cn/docs/overview/faq.html

Seata整合1.2教程:

  • https://www.bilibili.com/video/BV12Q4y1A7Nt

升级1.3教程:

  • https://www.bilibili.com/video/BV1Cf4y1X7vR
  • https: //mp.weixin.qq.com/s/2KSidJ72YsovpJ94P1aK1g

springcloud整合demo:

  • https://gitee.com/itCjb/spring-cloud-alibaba-seata-demo

五、完整源码

  • https://github.com/Thinkingcao/SpringCloudLearning/tree/master/springcloud-seata

名称栏目：SpringCloud整合Seata解决分布式事务(搭建+源码)
本文链接：http://www.shufengxianlan.com/qtweb/news1/527251.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

小程序开发知识

同城分类信息

成都app开发公司　　 　成都保温材料　　 　全网营销推广　　 　网站制作　　 　绵阳电信机房　　 　成都光华机房服务器托管　　 　成都活动策划　　 　SSL证书　　 　腾讯云虚拟主机　　 　吉安网站建设　　 　香港主机　　 　路面机械及配件　　 　高端网站设计　　 　成都主机托管　　 　品牌网站建设公司　　 　普格博源建站　　 　高端网站建设　　 　网站营销　　 　成都免费建网站　　 　南充主机托管