// 開啟一個全局事務，方法內的跨庫數(shù)據(jù)操作要么全部成功，要么全部失敗
@GlobalTransactional
public void purchase() {
    // 調用服務A
    serviceA.doSomething();
    // 調用服務B
    serviceB.doSomething();
}

# 下載
$ wget https://github.com/seata/seata/releases/download/v1.5.2/seata-server-1.5.2.tar.gz

# 解壓
$ tar -zxvf seata-server-1.5.2.tar.gz

CREATE TABLEIFNOTEXISTS`tb_stock` (
`id`int(11) NOTNULL AUTO_INCREMENT,
`product_code`varchar(255) DEFAULTNULL,
`count`int(11) DEFAULT0,
  PRIMARY KEY (`id`),
UNIQUEKEY (`commodity_code`)
) ENGINE=InnoDBDEFAULTCHARSET=utf8;


INSERTINTO`tb_stock` (`id`, `product_code`, `count`)
VALUES (1, 'wahaha', 10);


CREATETABLEIFNOTEXISTS`undo_log`
(
    `branch_id`     BIGINT       NOTNULLCOMMENT'branch transaction id',
    `xid`           VARCHAR(128) NOTNULLCOMMENT'global transaction id',
    `context`       VARCHAR(128) NOTNULLCOMMENT'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOTNULLCOMMENT'rollback info',
    `log_status`    INT(11)      NOTNULLCOMMENT'0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOTNULLCOMMENT'create datetime',
    `log_modified`  DATETIME(6)  NOTNULLCOMMENT'modify datetime',
    UNIQUEKEY`ux_undo_log` (`xid`, `branch_id`)
    KEY`ix_log_created` (`log_created`)
) ENGINE = InnoDB AUTO_INCREMENT = 1DEFAULTCHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';

<properties>
    <spring-boot.version>2.2.5.RELEASE</spring-boot.version>
    <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
    <spring-cloud-alibaba.version>2.2.1.RELEASE</spring-cloud-alibaba.version>
</properties>

<dependencies>
    <!-- SpringBoot web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!--mysql 驅動-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <!--mybatis-->
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>2.0.0</version>
    </dependency>
    <!--引入 seata 分布式事務組件 -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    </dependency>
    <!-- 實現(xiàn) Seata 對 HttpClient 的集成支持  -->
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-http</artifactId>
        <version>1.1.0</version>
    </dependency>
    <!-- Apache HttpClient 依賴 -->
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.11</version>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <!-- 引入 springBoot 版本號 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- 引入 spring cloud 版本號 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!-- 引入 spring cloud alibaba 適配的版本號 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>${spring-cloud-alibaba.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

@RestController
@RequestMapping("/stock")
publicclass StockController {

    @Autowired
    private StockService stockService;

    @PostMapping("/deduct")
    public Boolean deduct(@RequestBody Stock stock) {
        try {
            stockService.deduct(stock.getProductCode(), stock.getCount());
            // 正?？鄢龓齑妫祷?true
            returntrue;
        } catch (Exception e) {
            // 失敗扣除庫存，返回 false
            returnfalse;
        }
    }
}

@Component
publicclass StockService {

    @Autowired
    private StockMapper stockMapper;

    @Transactional
    public void deduct(String productCode, int count){
        Stock stock = new Stock();
        stock.setProductCode(productCode);
        stock.setCount(count);
        // 扣減庫存
        stockMapper.update(stock);
    }
}

<update id="update" parameterType="com.example.cloud.seata.client.entity.Stock">
    update tb_stock
    set `count` = `count` - #{count}
    where product_code = #{productCode}
</update>

@MapperScan("com.example.cloud.seata.client")
@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class,args);
    }
}

spring.application.name=seata-client-stock
server.port=9002

# 添加數(shù)據(jù)源配置
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/seata-stock
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

# 配置mybatis全局配置文件掃描
mybatis.config-locatinotallow=classpath:mybatis/mybatis-config.xml
# 配置mybatis的xml配置文件掃描目錄
mybatis.mapper-locatinotallow=classpath:mybatis/mapper/*.xml

# 添加Seata 配置項
# Seata 應用編號，默認為spring.application.name
seata.application-id=seata-client-stock
# Seata 事務組編號，用于 TC 集群名
seata.tx-service-group=my_test_tx_group
# Seata 服務配置項，配置對應的虛擬組和分組的映射，其中127.0.0.1:8091為 seata 服務端的監(jiān)聽端口
seata.service.vgroup-mapping.my_test_tx_group=default
seata.service.grouplist.default=127.0.0.1:8091

CREATE TABLE`tb_order` (
`id`intNOTNULL AUTO_INCREMENT,
`user_id`varchar(255) DEFAULTNULL,
`product_code`varchar(255) DEFAULTNULL,
`count`intDEFAULT'0',
`money`intDEFAULT'0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDBDEFAULTCHARSET=utf8;


CREATETABLEIFNOTEXISTS`undo_log`
(
    `branch_id`     BIGINT       NOTNULLCOMMENT'branch transaction id',
    `xid`           VARCHAR(128) NOTNULLCOMMENT'global transaction id',
    `context`       VARCHAR(128) NOTNULLCOMMENT'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOTNULLCOMMENT'rollback info',
    `log_status`    INT(11)      NOTNULLCOMMENT'0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOTNULLCOMMENT'create datetime',
    `log_modified`  DATETIME(6)  NOTNULLCOMMENT'modify datetime',
    UNIQUEKEY`ux_undo_log` (`xid`, `branch_id`)
    KEY`ix_log_created` (`log_created`)
) ENGINE = InnoDB AUTO_INCREMENT = 1DEFAULTCHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';

@RestController
@RequestMapping("/order")
publicclass OrderController {

    privatestaticfinal Logger LOGGER = LoggerFactory.getLogger(OrderController.class);

    @Autowired
    private OrderService orderService;


    @GetMapping("/create")
    public String create(@RequestParam("userId") String userId,
                          @RequestParam("productCode") String productCode,
                          @RequestParam("orderCount") Integer orderCount) {
        try {
            orderService.create(userId, productCode, orderCount);
            return"訂單創(chuàng)建成功！";
        } catch (Exception e) {
            LOGGER.error("錯誤信息", e);
            return"訂單創(chuàng)建失??！";
        }
    }
}

@Component
publicclass OrderService {

    @Autowired
    private OrderMapper orderMapper;

    /**
     * GlobalTransactional 表示當前服務需要開啟分布式事務操作，當通過 http 發(fā)起遠程調用的時候，seata 會將當前的全局事務會話 ID 傳遞到目標服務中。
     */
    @GlobalTransactional
    public void create(String userId, String productCode, int orderCount) throws Exception {
        // 扣減庫存
        reduceStock(productCode, orderCount);

        Order order = new Order();
        order.setUserId(userId);
        order.setProductCode(productCode);
        order.setCount(orderCount);
        order.setMoney(orderCount * 100);
        // 創(chuàng)建訂單
        orderMapper.insert(order);
    }


    /**
     * 通過 seata 包裝的 HttpClient 工具發(fā)起服務遠程調用
     */
    private void reduceStock(String productCode, Integer orderCount) throws IOException {
        // 參數(shù)拼接
        JSONObject params = new JSONObject()
                .fluentPut("productCode", productCode)
                .fluentPut("count", orderCount);
        // 執(zhí)行調用
        HttpResponse response = DefaultHttpExecutor.getInstance().executePost("http://127.0.0.1:9002", "/stock/deduct", params, HttpResponse.class);
        // 解析結果
        Boolean success = Boolean.valueOf(EntityUtils.toString(response.getEntity()));
        if (!success) {
            thrownew RuntimeException("扣減庫存失敗");
        }
    }
}

<insert id="insert" parameterType="com.example.cloud.seata.client.entity.Order">
    insert into tb_order(id, user_id, product_code, `count`, money)
    values(#{id}, #{userId}, #{productCode}, #{count}, #{money})
</insert>

@MapperScan("com.example.cloud.seata.client")
@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class,args);
    }
}

spring.application.name=seata-client-order
server.port=9001

# 添加數(shù)據(jù)源配置
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/seata-order
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

# 配置mybatis全局配置文件掃描
mybatis.config-locatinotallow=classpath:mybatis/mybatis-config.xml
# 配置mybatis的xml配置文件掃描目錄
mybatis.mapper-locatinotallow=classpath:mybatis/mapper/*.xml

# 添加Seata 配置項
# Seata 應用編號，默認為spring.application.name
seata.application-id=seata-client-order
# Seata 事務組編號，用于 TC 集群名
seata.tx-service-group=my_test_tx_group
# Seata 服務配置項，配置對應的虛擬組和分組的映射，其中127.0.0.1:8091為 seata 服務端的監(jiān)聽端口
seata.service.vgroup-mapping.my_test_tx_group=default
seata.service.grouplist.default=127.0.0.1:8091