如何使用Java开发一个基于Spring Cloud Alibaba的分布式事务应用

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

# 启用Seata的自动代理
spring.cloud.alibaba.seata.tx-service-group=my_tx_group
# Seata的注册中心地址
spring.cloud.alibaba.seata.registry.type=consul
spring.cloud.alibaba.seata.registry.address=127.0.0.1:8500

@GlobalTransactional
public void createOrder() {
    // 扣除库存的逻辑
    deductStock();
}

@GlobalTransactional
public void deductStock() {
    // 扣除库存的逻辑
}

@LocalTransactional
public void createOrderTx() {
    jdbcTemplate.update("INSERT INTO orders (order_id, user_id, amount) VALUES (?, ?, ?)", orderId, userId, amount);
}

@LocalTransactional
public void deductStockTx() {
    jdbcTemplate.update("UPDATE stock SET amount = amount - ? WHERE id = ?", amount, stockId);
}

@Test
public void testCreateOrder() {
    // 创建订单
    orderService.createOrder();

    // 断言订单状态
    Order order = jdbcTemplate.queryForObject("SELECT * FROM orders WHERE order_id = ?", new OrderRowMapper(), orderId);
    assertNotNull(order);
    assertEquals(userId, order.getUserId());
    assertEquals(amount, order.getAmount());

    // 断言库存状态
    Stock stock = jdbcTemplate.queryForObject("SELECT * FROM stock WHERE id = ?", new StockRowMapper(), stockId);
    assertNotNull(stock);
    assertEquals(originalAmount - amount, stock.getAmount());
}