概述

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务
中文开发文档http://seata.io/zh-cn/
Github地址:https://github.com/seata/seata

Seata术语

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

环境准备

二进制启动

release版本下载地址https://github.com/seata/seata/releases

  1. #!/bin/bash
  3. wget https://handson.oss-cn-shanghai.aliyuncs.com/seata-server-1.4.1.zip -O .seata-server-1.4.1.zip
  5. unzip .seata-server-1.4.1.zip
  7. nohup sh ~/seata/bin/seata-server.sh -p 8091 -m file &

docker

dockerhub地址https://hub.docker.com/r/seataio/seata-server
快速创建方式：

  1. docker run -d --name seata-server -p 8091:8091 seataio/seata-server:1.4.1

根pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.alibaba.seata</groupId>
  6.     <artifactId>seata-sample</artifactId>
  7.     <packaging>pom</packaging>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <modules>
  10.         <module>business-service</module>
  11.         <module>storage-service</module>
  12.         <module>order-service</module>
  13.         <module>common-service</module>
  14.     </modules>
  15.     <name>seata-sample</name>
  16.     <description>seata sample project for Spring Boot</description>
  18.     <properties>
  19.         <java.version>1.8</java.version>
  20.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  21.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  22.         <spring-boot.version>2.3.2.RELEASE</spring-boot.version>
  23.         <alibaba.cloud.version>2.2.3.RELEASE</alibaba.cloud.version>
  24.         <seata.version>1.4.0</seata.version>
  25.         <mysql.version>8.0.11</mysql.version>
  26.         <lombok.version>1.16.4</lombok.version>
  27.     </properties>
  29.     <dependencies>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter</artifactId>
  33.         </dependency>
  35.         <dependency>
  36.             <groupId>org.springframework.boot</groupId>
  37.             <artifactId>spring-boot-starter-test</artifactId>
  38.             <scope>test</scope>
  39.             <exclusions>
  40.                 <exclusion>
  41.                     <groupId>org.junit.vintage</groupId>
  42.                     <artifactId>junit-vintage-engine</artifactId>
  43.                 </exclusion>
  44.             </exclusions>
  45.         </dependency>
  46.     </dependencies>
  48.     <dependencyManagement>
  49.         <dependencies>
  50.             <dependency>
  51.                 <groupId>org.springframework.boot</groupId>
  52.                 <artifactId>spring-boot-dependencies</artifactId>
  53.                 <version>${spring-boot.version}</version>
  54.                 <type>pom</type>
  55.                 <scope>import</scope>
  56.             </dependency>
  57.             <dependency>
  58.                 <groupId>com.alibaba.cloud</groupId>
  59.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  60.                 <version>${alibaba.cloud.version}</version>
  61.                 <type>pom</type>
  62.                 <scope>import</scope>
  63.             </dependency>
  64.             <dependency>
  65.                 <groupId>org.springframework.cloud</groupId>
  66.                 <artifactId>spring-cloud-starter-openfeign</artifactId>
  67.                 <version>${alibaba.cloud.version}</version>
  68.             </dependency>
  69.             <dependency>
  70.                 <groupId>org.springframework.cloud</groupId>
  71.                 <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  72.                 <version>${alibaba.cloud.version}</version>
  73.             </dependency>
  74.             <dependency>
  75.                 <groupId>io.seata</groupId>
  76.                 <artifactId>seata-spring-boot-starter</artifactId>
  77.                 <version>${seata.version}</version>
  78.             </dependency>
  79.             <dependency>
  80.                 <groupId>mysql</groupId>
  81.                 <artifactId>mysql-connector-java</artifactId>
  82.                 <version>${mysql.version}</version>
  83.             </dependency>
  84.             <dependency>
  85.                 <groupId>org.projectlombok</groupId>
  86.                 <artifactId>lombok</artifactId>
  87.                 <version>${lombok.version}</version>
  88.             </dependency>
  89.             <dependency>
  90.                 <groupId>org.mybatis.spring.boot</groupId>
  91.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  92.                 <version>2.1.0</version>
  93.             </dependency>
  94.         </dependencies>
  95.     </dependencyManagement>
  97.     <build>
  98.         <plugins>
  99.             <plugin>
  100.                 <groupId>org.apache.maven.plugins</groupId>
  101.                 <artifactId>maven-compiler-plugin</artifactId>
  102.                 <version>3.8.1</version>
  103.                 <configuration>
  104.                     <source>1.8</source>
  105.                     <target>1.8</target>
  106.                     <encoding>UTF-8</encoding>
  107.                 </configuration>
  108.             </plugin>
  109.             <plugin>
  110.                 <groupId>org.springframework.boot</groupId>
  111.                 <artifactId>spring-boot-maven-plugin</artifactId>
  112.                 <version>2.3.0.RELEASE</version>
  113.             </plugin>
  114.         </plugins>
  115.     </build>
  117. </project>

工程说明

common-service

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>seata-sample</artifactId>
  7.         <groupId>com.alibaba.seata</groupId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>common-service</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.projectlombok</groupId>
  17.             <artifactId>lombok</artifactId>
  18.         </dependency>
  19.     </dependencies>
  20. </project>

常量定义

  1. package com.alibaba.seata.sample.common;
  3. /**
  4.  * @author slievrly
  5.  */
  6. public interface Constants {
  8.     String SUCCESS_RESPONSE = "ok";
  9.     String FAIL_RESPONSE = "fail";
  10. }

实体类 Account

  1. package com.alibaba.seata.sample.common.entity;
  3. import lombok.Data;
  5. /**
  6.  * @author slievrly
  7.  */
  9. @Data
  10. public class Account {
  11.     private Integer id;
  13.     private String userId;
  15.     private Integer money;
  17. }

实体类 订单Order

  1. package com.alibaba.seata.sample.common.entity;
  3. import lombok.Data;
  4. /**
  5.  * @author slievrly
  6.  */
  7. @Data
  8. public class Order {
  9.     private Integer id;
  11.     private String userId;
  13.     private String commodityCode;
  15.     private Integer count;
  17.     private Integer money;
  18. }

Storage

  1. package com.alibaba.seata.sample.common.entity;
  3. import lombok.Data;
  4. /**
  5.  * @author slievrly
  6.  */
  8. @Data
  9. public class Storage {
  10.     private Integer id;
  12.     private String commodityCode;
  14.     private Integer count;
  16. }

business-service

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>seata-sample</artifactId>
  7.         <groupId>com.alibaba.seata</groupId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>business-service</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>${project.groupId}</groupId>
  17.             <artifactId>common-service</artifactId>
  18.             <version>${project.version}</version>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>io.seata</groupId>
  30.             <artifactId>seata-spring-boot-starter</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>mysql</groupId>
  34.             <artifactId>mysql-connector-java</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>com.alibaba.cloud</groupId>
  38.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-starter-web</artifactId>
  43.         </dependency>
  44.     </dependencies>
  46.     <build>
  47.         <plugins>
  48.             <plugin>
  49.                 <groupId>org.apache.maven.plugins</groupId>
  50.                 <artifactId>maven-compiler-plugin</artifactId>
  51.                 <version>3.1</version>
  52.                 <configuration>
  53.                     <source>1.8</source>
  54.                     <target>1.8</target>
  55.                     <encoding>UTF-8</encoding>
  56.                 </configuration>
  57.             </plugin>
  58.             <plugin>
  59.                 <groupId>org.springframework.boot</groupId>
  60.                 <artifactId>spring-boot-maven-plugin</artifactId>
  61.                 <version>${spring-boot.version}</version>
  62.                 <configuration>
  63.                     <mainClass>com.alibaba.seata.sample.business.service.BusinessApplication</mainClass>
  64.                     <layout>ZIP</layout>
  65.                 </configuration>
  66.                 <executions>
  67.                     <execution>
  68.                         <goals>
  69.                             <goal>repackage</goal>
  70.                         </goals>
  71.                     </execution>
  72.                 </executions>
  73.             </plugin>
  74.         </plugins>
  75.     </build>
  76. </project>

入口main类 BusinessApplication

  1. package com.alibaba.seata.sample.business.service;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.openfeign.EnableFeignClients;
  7. /**
  8.  * @author slievrly
  9.  */
  10. @EnableFeignClients
  11. @SpringBootApplication
  12. public class BusinessApplication {
  13.     public static void main(String[] args) {
  14.         SpringApplication.run(BusinessApplication.class, args);
  15.     }
  16. }

service

  1. package com.alibaba.seata.sample.business.service.service;
  3. /**
  4.  * @author slievrly
  5.  */
  6. public interface IBusinessService {
  8.     void reduceStockAndCreateOrder(int count, boolean mockException);
  10.     String checkData();
  11. }

继承接口

  1. package com.alibaba.seata.sample.business.service.service.impl;
  3. import java.util.List;
  4. import java.util.concurrent.ThreadLocalRandom;
  5. import java.util.concurrent.TimeUnit;
  7. import javax.annotation.PostConstruct;
  9. import com.alibaba.seata.sample.business.service.feign.IOrderService;
  10. import com.alibaba.seata.sample.business.service.feign.IStorageService;
  11. import com.alibaba.seata.sample.business.service.service.IBusinessService;
  12. import com.alibaba.seata.sample.common.entity.Order;
  13. import com.alibaba.seata.sample.common.entity.Storage;
  15. import io.seata.core.context.RootContext;
  16. import io.seata.spring.annotation.GlobalTransactional;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.stereotype.Service;
  20. import static com.alibaba.seata.sample.common.Constants.SUCCESS_RESPONSE;
  22. /**
  23.  * @author slievrly
  24.  */
  25. @Service
  26. public class BusinessServiceImpl implements IBusinessService {
  28.     private static final int INIT_COUNT = 100;
  30.     @Autowired
  31.     private IOrderService orderService;
  33.     @Autowired
  34.     private IStorageService storageService;
  36.     private String opCommodityCode;
  38.     @PostConstruct
  39.     public void init() throws InterruptedException {
  40.         for (int i = 0; i < 100; i++) {
  41.             try {
  42.                 ThreadLocalRandom random = ThreadLocalRandom.current();
  43.                 String commodityCode = "C" + random.nextInt(999999);
  44.                 storageService.initStock(commodityCode, INIT_COUNT);
  45.                 opCommodityCode = commodityCode;
  46.                 break;
  47.             } catch (Exception ignore) {
  48.                 ignore.printStackTrace();
  49.                 TimeUnit.MILLISECONDS.sleep(2);
  50.             }
  51.         }
  52.     }
  54.     @Override
  55.     @GlobalTransactional(timeoutMills = 300000, name = "spring-cloud-alibaba-seata")
  56.     public void reduceStockAndCreateOrder(int count, boolean mockException) {
  57.         String xid = RootContext.getXID();
  58.         System.out.println("business-service 当前正在执行的事务xid:" + xid);
  59.         String result = storageService.reduceStock(opCommodityCode, count);
  61.         if (!SUCCESS_RESPONSE.equals(result)) {
  62.             throw new RuntimeException("库存扣减失败! xid:" + xid);
  63.         }
  65.         Order order = new Order().setCommodityCode(opCommodityCode).setCount(count).setMoney(count * 100).setUserId(
  66.             "system");
  68.         result = orderService.createOrder(order);
  70.         if (!SUCCESS_RESPONSE.equals(result)) {
  71.             throw new RuntimeException("创建订单失败! xid:" + xid);
  72.         }
  73.         if (mockException) {
  74.             throw new RuntimeException("模拟用户业务异常! xid:" + xid);
  75.         }
  77.     }
  79.     @Override
  80.     public String checkData() {
  81.         StringBuilder sb = new StringBuilder();
  82.         List<Order> orders = orderService.selectOrderByCode(opCommodityCode);
  83.         List<Storage> storages = storageService.selectStockByCode(opCommodityCode);
  84.         int orderTotal = 0;
  85.         int storageTotal = 0;
  86.         sb.append("<strong>当前您操作的CommodityCode是: <font color=\"#FF0000\">" + opCommodityCode + "</font></strong>");
  87.         sb.append("<hr>");
  88.         sb.append("<strong>数据表:</strong>");
  89.         sb.append("<br/>");
  90.         sb.append("<br/>");
  91.         sb.append("<strong>order_tbl:</strong>");
  92.         sb.append("<table border=\"2\">");
  93.         sb.append("<tr>");
  94.         sb.append("<td>Id</td><td>user_id</td><td>commodity_code</td><td>count</td><td>money</td>");
  95.         sb.append("</tr>");
  96.         for (Order order : orders) {
  97.             sb.append("<tr>");
  98.             sb.append("<td>" + order.getId() + "</td><td>" + order.getUserId() + "</td><td>" + order.getCommodityCode()
  99.                 + "</td><td>" + order.getCount() + "</td><td>" + order.getMoney() + "</td>");
  100.             sb.append("</tr>");
  101.             orderTotal += order.getCount();
  102.         }
  103.         sb.append("</table>");
  105.         sb.append("<br/>");
  107.         sb.append("<strong>storage_tbl:</strong>");
  108.         sb.append("<table border=\"2\">");
  109.         sb.append("<tr>");
  110.         sb.append("<td>Id</td><td>commodity_code</td><td>count</td>");
  111.         sb.append("</tr>");
  112.         for (Storage storage : storages) {
  113.             sb.append("<tr>");
  114.             sb.append(
  115.                 "<td>" + storage.getId() + "</td><td>" + storage.getCommodityCode() + "</td><td>" + storage.getCount()
  116.                     + "</td>");
  117.             sb.append("</tr>");
  118.             storageTotal += storage.getCount();
  119.         }
  120.         sb.append("</table>");
  121.         sb.append("<hr>");
  122.         sb.append("<strong>数据一致性校验:</strong>");
  123.         sb.append("<br/>");
  124.         sb.append("<br/>");
  125.         sb.append("<strong>调用前库存:</strong>");
  126.         sb.append("<br/>");
  127.         sb.append("初始化库存(storage_tbl): <strong><font color=\"#FF0000\">" + INIT_COUNT + "</font></strong>");
  128.         sb.append("<br/>");
  129.         sb.append("<br/>");
  130.         sb.append("<strong>调用后库存:</strong>");
  131.         sb.append("<br/>");
  132.         sb.append("已卖出库存数量(order_tbl): <strong><font color=\"#FF0000\">" + orderTotal + "</font></strong>");
  133.         sb.append("<br/>");
  134.         sb.append("剩余库存(storage_tbl): <strong><font color=\"#FF0000\">" + storageTotal + "</font></strong>");
  135.         sb.append("<br/>");
  136.         sb.append("<br/>");
  137.         sb.append(
  138.             "<strong>结论:</strong> 库存量调用前后 <strong><font color=\"#FF0000\">" + (INIT_COUNT == orderTotal + storageTotal
  139.                 ? "一致" : "不一致") + "</font></strong>");
  140.         sb.append("<hr>");
  141.         return sb.toString();
  142.     }
  143. }

feign

  1. package com.alibaba.seata.sample.business.service.feign;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Order;
  7. import org.springframework.cloud.openfeign.FeignClient;
  8. import org.springframework.web.bind.annotation.RequestBody;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RequestParam;
  12. /**
  13.  * @author slievrly
  14.  */
  15. @FeignClient(name = "order-service",url = "http://127.0.0.1:8082")
  16. public interface IOrderService {
  18.     @RequestMapping(value = "/createOrder")
  19.     String createOrder(@RequestBody Order orders);
  21.     @RequestMapping(value = "/selectOrderByCode")
  22.     List<Order> selectOrderByCode(@RequestParam(name = "commodityCode") String commodityCode);
  24. }

存储

  1. package com.alibaba.seata.sample.business.service.feign;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Storage;
  7. import org.springframework.cloud.openfeign.FeignClient;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RequestParam;
  11. /**
  12.  * @author slievrly
  13.  */
  14. @FeignClient(name = "storage-service",url = "http://127.0.0.1:8083")
  15. public interface IStorageService {
  17.     @RequestMapping("/reduceStock")
  18.     String reduceStock(@RequestParam(name = "commodityCode") String commodityCode,
  19.                        @RequestParam(name = "count") Integer count);
  21.     @RequestMapping("/initStock")
  22.     int initStock(@RequestParam(name = "commodityCode") String commodityCode,
  23.                   @RequestParam(name = "count") Integer count);
  25.     @RequestMapping(value = "/selectStockByCode")
  26.     List<Storage> selectStockByCode(@RequestParam(name = "commodityCode") String commodityCode);
  27. }

controller

  1. package com.alibaba.seata.sample.business.service.controller;
  3. import java.io.IOException;
  5. import javax.servlet.http.HttpServletResponse;
  7. import com.alibaba.seata.sample.business.service.service.IBusinessService;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.web.bind.annotation.GetMapping;
  11. import org.springframework.web.bind.annotation.PathVariable;
  12. import org.springframework.web.bind.annotation.RestController;
  14. /**
  15.  * @author slievrly
  16.  */
  17. @RestController
  18. public class HomeController {
  20.     @Autowired
  21.     private IBusinessService businessService;
  23.     @GetMapping(value = "/seata/feign", produces = "application/json")
  24.     public String feign(int count, boolean mockException) {
  25.         StringBuilder result = new StringBuilder();
  26.         if (count <= 0) {
  27.             return "expect: count>0 ";
  28.         }
  29.         try {
  30.             businessService.reduceStockAndCreateOrder(count, mockException);
  31.         } catch (Exception exx) {
  32.             result.append("失败:").append(exx.getMessage()).append("事务发生回滚!");
  33.         }
  34.         if (result.length() == 0) {
  35.             result.append("调用扣减库存生成订单服务成功!");
  36.         }
  37.         return result.toString();
  38.     }
  40.     @GetMapping(value = "/seata/check", produces = "application/json")
  41.     public void check(HttpServletResponse response) throws IOException {
  42.         response.setContentType("text/html; charset=gb2312");
  43.         response.getWriter().write(businessService.checkData());
  44.     }
  45. }

application.yml

  1. spring:
  2.    datasource:
  3.       type: com.alibaba.druid.pool.DruidDataSource
  4.       url: jdbc:mysql://rm-2zetd9474ydd1g5955o.mysql.rds.aliyuncs.com:3306/seata_training?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
  5.       driver-class-name: com.mysql.cj.jdbc.Driver
  6.       username: seata
  7.       password: seata123
  8.       max-wait: 60000
  9.       max-active: 100
  10.       min-idle: 10
  11.       initial-size: 10
  12. seata:
  13.    enabled: true
  14.    application-id: business
  15.    tx-service-group: my_test_tx_group
  16.    service:
  17.       vgroup-mapping:
  18.          my_test_tx_group: default
  19.       grouplist:
  20.          default: 127.0.0.1:8091
  21.       disable-global-transaction: false

bootstrap.yml

  1. spring:
  2.    application:
  3.       name: business-service
  4.    main:
  5.       allow-bean-definition-overriding: true
  6.    cloud:
  7.       loadbalancer:
  8.          retry:
  9.             enabled: false
  10. server:
  11.    port: 60000
  12. ribbon:
  13.    ConnectTimeout: 100000
  14.    ReadTimeout: 1000000
  15.    OkToRetryOnAllOperations: false
  16. feign:
  17.    httpclient:
  18.       enabled: true
  19.       connection-timeout: 60000
  20.    client:
  21.       config:
  22.          default:
  23.             connectTimeout: 60000
  24.             readTimeout: 60000
  25.             loggerLevel: FULL

order-service

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>seata-sample</artifactId>
  7.         <groupId>com.alibaba.seata</groupId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>order-service</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>${project.groupId}</groupId>
  17.             <artifactId>common-service</artifactId>
  18.             <version>${project.version}</version>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>io.seata</groupId>
  30.             <artifactId>seata-spring-boot-starter</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>mysql</groupId>
  34.             <artifactId>mysql-connector-java</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.mybatis.spring.boot</groupId>
  38.             <artifactId>mybatis-spring-boot-starter</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>com.alibaba.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-web</artifactId>
  47.         </dependency>
  48.     </dependencies>
  50.     <build>
  51.         <plugins>
  52.             <plugin>
  53.                 <groupId>org.apache.maven.plugins</groupId>
  54.                 <artifactId>maven-compiler-plugin</artifactId>
  55.                 <version>3.1</version>
  56.                 <configuration>
  57.                     <source>1.8</source>
  58.                     <target>1.8</target>
  59.                     <encoding>UTF-8</encoding>
  60.                 </configuration>
  61.             </plugin>
  62.             <plugin>
  63.                 <groupId>org.springframework.boot</groupId>
  64.                 <artifactId>spring-boot-maven-plugin</artifactId>
  65.                 <version>${spring-boot.version}</version>
  66.                 <configuration>
  67.                     <mainClass>com.alibaba.seata.sample.order.service.OrderApplication</mainClass>
  68.                     <layout>ZIP</layout>
  69.                 </configuration>
  70.                 <executions>
  71.                     <execution>
  72.                         <goals>
  73.                             <goal>repackage</goal>
  74.                         </goals>
  75.                     </execution>
  76.                 </executions>
  77.             </plugin>
  78.         </plugins>
  79.     </build>
  81. </project>

入口类

  1. package com.alibaba.seata.sample.order.service;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6. import org.springframework.cloud.openfeign.EnableFeignClients;
  8. /**
  9.  * @author slievrly
  10.  */
  11. @SpringBootApplication
  12. @EnableFeignClients
  13. @EnableDiscoveryClient
  14. public class OrderApplication {
  15.     public static void main(String[] args) {
  16.         SpringApplication.run(OrderApplication.class, args);
  17.     }
  18. }

service

  1. package com.alibaba.seata.sample.order.service.service;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Order;
  7. /**
  8.  * @author slievrly
  9.  */
  10. public interface IOrderService {
  12.     void createOrder(Order order);
  14.     List<Order> selectOrderByCode(String commodityCode);
  15. }

服务实现类

  1. package com.alibaba.seata.sample.order.service.service.impl;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Order;
  6. import com.alibaba.seata.sample.order.service.mapper.OrderMapper;
  7. import com.alibaba.seata.sample.order.service.service.IOrderService;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  12. /**
  13.  * @author slievrly
  14.  */
  15. @Service
  16. public class OrderServiceImpl implements IOrderService {
  18.     @Autowired
  19.     private OrderMapper orderMapper;
  21.     @Override
  22.     public void createOrder(Order order) {
  23.         orderMapper.insert(order);
  24.     }
  26.     @Override
  27.     public List<Order> selectOrderByCode(String commodityCode) {
  28.         return orderMapper.selectOrderByCode(commodityCode);
  29.     }
  30. }

数据maper

  1. import org.apache.ibatis.annotations.Mapper;
  3. /**
  4.  * @author slievrly
  5.  */
  6. @Mapper
  7. public interface OrderMapper {
  9.     int insert(Order order);
  11.     List<Order> selectOrderByCode(String commodityCode);
  13. }

resources/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.alibaba.seata.sample.order.service.mapper.OrderMapper">
  4.     <resultMap id="BaseResultMap" type="com.alibaba.seata.sample.common.entity.Order">
  5.         <id column="id" property="id" jdbcType="INTEGER"/>
  6.         <result column="user_id" property="userId" jdbcType="VARCHAR"/>
  7.         <result column="commodity_code" property="commodityCode" jdbcType="VARCHAR"/>
  8.         <result column="count" property="count" jdbcType="INTEGER"/>
  9.         <result column="money" property="money" jdbcType="INTEGER"/>
  10.     </resultMap>
  12.     <insert id="insert" parameterType="com.alibaba.seata.sample.common.entity.Order">
  13.     insert into order_tbl (user_id,commodity_code,count,money)
  14.     values (#{userId,jdbcType=VARCHAR}, #{commodityCode,jdbcType=VARCHAR}, #{count,jdbcType=INTEGER}, #{money,jdbcType=INTEGER})
  15.   </insert>
  17.     <select id="selectOrderByCode" parameterType="java.lang.String" resultMap="BaseResultMap">
  18.         select * from order_tbl where commodity_code=#{commodityCode};
  19.     </select>
  21. </mapper>

控制类

  1. package com.alibaba.seata.sample.order.service.controller;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.Constants;
  6. import com.alibaba.seata.sample.common.entity.Order;
  7. import com.alibaba.seata.sample.order.service.service.IOrderService;
  9. import io.seata.core.context.RootContext;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.web.bind.annotation.RequestBody;
  12. import org.springframework.web.bind.annotation.RequestMapping;
  13. import org.springframework.web.bind.annotation.RequestMethod;
  14. import org.springframework.web.bind.annotation.RestController;
  16. /**
  17.  * @author slievrly
  18.  */
  19. @RestController
  20. public class OrderController {
  21.     @Autowired
  22.     private IOrderService orderService;
  24.     @RequestMapping(value = "/createOrder", method = RequestMethod.POST, produces = "application/json")
  25.     public String create(@RequestBody Order order) {
  26.         System.out.println("order-service 当前正在执行的事务xid:" + RootContext.getXID());
  27.         try {
  28.             orderService.createOrder(order);
  29.         } catch (Exception exx) {
  30.             exx.printStackTrace();
  31.             return Constants.FAIL_RESPONSE;
  32.         }
  33.         return Constants.SUCCESS_RESPONSE;
  34.     }
  36.     @RequestMapping(value = "/selectOrderByCode", method = RequestMethod.GET, produces = "application/json")
  37.     public List<Order> selectOrderByCode(String commodityCode) {
  38.         return orderService.selectOrderByCode(commodityCode);
  39.     }
  40. }

application.yml

  1. spring:
  2.    datasource:
  3.       type: com.alibaba.druid.pool.DruidDataSource
  4.       url: jdbc:mysql://rm-2zetd9474ydd1g5955o.mysql.rds.aliyuncs.com:3306/seata_training?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
  5.       driver-class-name: com.mysql.cj.jdbc.Driver
  6.       username: seata
  7.       password: seata123
  8.       max-wait: 60000
  9.       max-active: 100
  10.       min-idle: 10
  11.       initial-size: 10
  12. mybatis:
  13.    mapper-locations: classpath*:mapper/*Mapper.xml
  14. seata:
  15.    enabled: true
  16.    application-id: order
  17.    tx-service-group: my_test_tx_group
  18.    service:
  19.       vgroup-mapping:
  20.          my_test_tx_group: default
  21.       grouplist:
  22.          default: 127.0.0.1:8091
  23.       disable-global-transaction: false

bootstrap.yml

  1. spring:
  2.    application:
  3.       name: order-service
  4.    main:
  5.       allow-bean-definition-overriding: true
  6.    cloud:
  7.       loadbalancer:
  8.          retry:
  9.             enabled: false
  10. server:
  11.    port: 8082
  12. ribbon:
  13.    ConnectTimeout: 100000
  14.    ReadTimeout: 1000000
  15.    OkToRetryOnAllOperations: false

storage-service

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>seata-sample</artifactId>
  7.         <groupId>com.alibaba.seata</groupId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>storage-service</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>${project.groupId}</groupId>
  17.             <artifactId>common-service</artifactId>
  18.             <version>${project.version}</version>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>io.seata</groupId>
  30.             <artifactId>seata-spring-boot-starter</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>mysql</groupId>
  34.             <artifactId>mysql-connector-java</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.mybatis.spring.boot</groupId>
  38.             <artifactId>mybatis-spring-boot-starter</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>com.alibaba.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-web</artifactId>
  47.         </dependency>
  48.     </dependencies>
  50.     <build>
  51.         <plugins>
  52.             <plugin>
  53.                 <groupId>org.apache.maven.plugins</groupId>
  54.                 <artifactId>maven-compiler-plugin</artifactId>
  55.                 <version>3.1</version>
  56.                 <configuration>
  57.                     <source>1.8</source>
  58.                     <target>1.8</target>
  59.                     <encoding>UTF-8</encoding>
  60.                 </configuration>
  61.             </plugin>
  62.             <plugin>
  63.                 <groupId>org.springframework.boot</groupId>
  64.                 <artifactId>spring-boot-maven-plugin</artifactId>
  65.                 <version>${spring-boot.version}</version>
  66.                 <configuration>
  67.                     <mainClass>com.alibaba.seata.sample.storage.service.StorageApplication</mainClass>
  68.                     <layout>ZIP</layout>
  69.                 </configuration>
  70.                 <executions>
  71.                     <execution>
  72.                         <goals>
  73.                             <goal>repackage</goal>
  74.                         </goals>
  75.                     </execution>
  76.                 </executions>
  77.             </plugin>
  78.         </plugins>
  79.     </build>
  80. </project>

入口类

  1. package com.alibaba.seata.sample.storage.service;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. /**
  7.  * @author slievrly
  8.  */
  9. @SpringBootApplication
  10. public class StorageApplication {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(StorageApplication.class, args);
  13.     }
  14. }

service 接口

  1. package com.alibaba.seata.sample.storage.service.service;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Storage;
  7. /**
  8.  * @author slievrly
  9.  */
  10. public interface IStorageService {
  12.     int reduceStock(String commodityCode, int count);
  14.     int initStock(String commodityCode, int count);
  16.     List<Storage> selectStockByCode(String commodityCode);
  18. }

接口实现

  1. package com.alibaba.seata.sample.storage.service.service.impl;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Storage;
  6. import com.alibaba.seata.sample.storage.service.mapper.StorageMapper;
  7. import com.alibaba.seata.sample.storage.service.service.IStorageService;
  9. import io.seata.core.context.RootContext;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  13. /**
  14.  * @author slievrly
  15.  */
  16. @Service
  17. public class StorageServiceImpl implements IStorageService {
  19.     @Autowired
  20.     private StorageMapper storageMapper;
  22.     @Override
  23.     public int reduceStock(String commodityCode, int count) {
  24.         System.out.println("storage-service 当前正在执行的事务xid:" + RootContext.getXID());
  25.         return storageMapper.updateStockByCode(commodityCode, count);
  26.     }
  28.     @Override
  29.     public int initStock(String commodityCode, int count) {
  30.         return storageMapper.insert(new Storage().setCommodityCode(commodityCode).setCount(count));
  31.     }
  33.     @Override
  34.     public List<Storage> selectStockByCode(String commodityCode) {
  35.         return storageMapper.selectStockByCode(commodityCode);
  36.     }
  37. }

数据mapper

  1. package com.alibaba.seata.sample.storage.service.mapper;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.entity.Storage;
  7. import org.apache.ibatis.annotations.Mapper;
  8. import org.apache.ibatis.annotations.Param;
  10. /**
  11.  * @author slievrly
  12.  */
  13. @Mapper
  14. public interface StorageMapper {
  16.     Storage selectById(@Param("id") Integer id);
  18.     List<Storage> selectStockByCode(@Param("commodityCode") String commodityCode);
  20.     int updateStockByCode(@Param("commodityCode") String commodityCode, @Param("count") int count);
  22.     int insert(Storage storage);
  23. }

resource/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.alibaba.seata.sample.storage.service.mapper.StorageMapper">
  4.     <resultMap id="BaseResultMap" type="com.alibaba.seata.sample.common.entity.Storage">
  5.         <id column="id" property="id" jdbcType="INTEGER"/>
  6.         <result column="commodity_code" property="commodityCode" jdbcType="VARCHAR"/>
  7.         <result column="count" property="count" jdbcType="INTEGER"/>
  8.     </resultMap>
  10.     <select id="selectById" resultMap="BaseResultMap">
  11.         select id, commodity_code, count from storage_tbl
  12.         WHERE id = #{id}
  13.     </select>
  15.     <select id="selectAll" resultMap="BaseResultMap">
  16.         select id, commodity_code, count from storage_tbl
  17.     </select>
  19.     <select id="selectStockByCode" parameterType="java.lang.String" resultMap="BaseResultMap">
  20.         select id, commodity_code, count from storage_tbl
  21.         WHERE commodity_code = #{commodityCode}
  22.     </select>
  24.     <update id="updateStockByCode">
  25.         update storage_tbl set count = count- #{count}
  26.         WHERE commodity_code = #{commodityCode} and count &gt;= #{count}
  27.     </update>
  29.     <insert id="insert" parameterType="com.alibaba.seata.sample.common.entity.Storage">
  30.         insert into storage_tbl (commodity_code, count)
  31.         values (#{commodityCode,jdbcType=VARCHAR}, #{count,jdbcType=INTEGER})
  32.     </insert>
  34.     <delete id="delete" parameterType="java.lang.String">
  35.         delete from storage_tbl where commodity_code=#{commodityCode}
  36.     </delete>
  37. </mapper>

控制类

  1. package com.alibaba.seata.sample.storage.service.controller;
  3. import java.util.List;
  5. import com.alibaba.seata.sample.common.Constants;
  6. import com.alibaba.seata.sample.common.entity.Storage;
  7. import com.alibaba.seata.sample.storage.service.service.IStorageService;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RequestParam;
  12. import org.springframework.web.bind.annotation.RestController;
  14. /**
  15.  * @author slievrly
  16.  */
  17. @RestController
  18. public class StorageController {
  19.     @Autowired
  20.     IStorageService storageService;
  22.     @RequestMapping("/reduceStock")
  23.     public String reduceStock(@RequestParam(name = "commodityCode") String commodityCode,
  24.                               @RequestParam(name = "count") Integer count) {
  25.         return storageService.reduceStock(commodityCode, count) == 1 ? Constants.SUCCESS_RESPONSE
  26.             : Constants.FAIL_RESPONSE;
  27.     }
  29.     @RequestMapping("/initStock")
  30.     public int initStock(@RequestParam(name = "commodityCode") String commodityCode,
  31.                          @RequestParam(name = "count") Integer count) {
  32.         return storageService.initStock(commodityCode, count);
  33.     }
  35.     @RequestMapping("/selectStockByCode")
  36.     public List<Storage> selectStockByCode(@RequestParam(name = "commodityCode") String commodityCode) {
  37.         return storageService.selectStockByCode(commodityCode);
  38.     }
  39. }

application.yml

  1. spring:
  2.    datasource:
  3.       type: com.alibaba.druid.pool.DruidDataSource
  4.       url: jdbc:mysql://rm-2zetd9474ydd1g5955o.mysql.rds.aliyuncs.com:3306/seata_training?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
  5.       driver-class-name: com.mysql.cj.jdbc.Driver
  6.       username: seata
  7.       password: seata123
  8.       max-wait: 60000
  9.       max-active: 100
  10.       min-idle: 10
  11.       initial-size: 10
  12. mybatis:
  13.    mapper-locations: classpath*:mapper/*Mapper.xml
  14. seata:
  15.    enabled: true
  16.    application-id: storage
  17.    tx-service-group: my_test_tx_group
  18.    service:
  19.       vgroup-mapping:
  20.          my_test_tx_group: default
  21.       grouplist:
  22.          default: 127.0.0.1:8091
  23.       disable-global-transaction: false

bootstrap.yml

  1. spring:
  2.    application:
  3.       name: storage-service
  4.    main:
  5.       allow-bean-definition-overriding: true
  6.    cloud:
  7.       loadbalancer:
  8.          retry:
  9.             enabled: false
  10. server:
  11.    port: 8083
  12. ribbon:
  13.    ConnectTimeout: 100000
  14.    ReadTimeout: 1000000
  15.    OkToRetryOnAllOperations: false

本实验提供了3个工程，其调用关系如下：
image.png
如图所示，服务链路中包含三个微服务：business（微服务入口）、order（订单服务）和 storage（库存服务）。
业务逻辑

  1. 通过url 调用 business 服务，business 服务会通过 openFeign 的方式分别调用 storage 和 order 服务。
  2. 每个服务调用后会根据正常（ok）或异常（fail）的返回值决定是否抛出异常，若返回结果不为 ok 那么 business 将抛出异常，触发整个事务回滚，预期数据至 business 方法执行前的数据并且库存总量和与初始值一致。
  3. 当order 和 storage 两个服务调用正常，用户可以根据 url 中的 mockException=true 或 false 来注入一个 mock 异常，当注入异常后，期望数据回滚至 business 方法执行前的数据并且库存总量和与初始值一致。

异常逻辑

  1. 在 bussiness 中请求超过现有库存，通过参数 count 来指定要扣减的库存数量，当超出库存，将抛出异常进行事务回滚。
  2. 在 bussiness 中请求中加入 mockException=true 参数，触发事务回滚。

undo.sql

  2. CREATE TABLE undo_log
  3. (
  4.     id            BIGINT(20) NOT NULL AUTO_INCREMENT,
  5.     branch_id     BIGINT(20) NOT NULL,
  6.     xid           VARCHAR(100) NOT NULL,
  7.     context       VARCHAR(128) NOT NULL,
  8.     rollback_info LONGBLOB     NOT NULL,
  9.     log_status    INT(11) NOT NULL,
  10.     log_created   DATETIME     NOT NULL,
  11.     log_modified  DATETIME     NOT NULL,
  12.     PRIMARY KEY (id),
  13.     UNIQUE KEY ux_undo_log (xid, branch_id)
  14. ) ENGINE = InnoDB;

参考

https://doc.ruoyi.vip/ruoyi-cloud/cloud/seata.html#%E5%A6%82%E4%BD%95%E4%BD%BF%E7%94%A8