<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.7.0</version>
</dependency>

seata:
  enabled: true
  application-id: your-application-id
  tx-service-group: your-tx-service-group
  service:
    vgroup-mapping:
      your-tx-service-group: default
    grouplist:
      default: 127.0.0.1:8091

@GlobalTransactional
public void createOrder(Order order) {
    orderService.create(order);
    inventoryService.deduct(order.getProductId(), order.getQuantity());
}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jta-atomikos</artifactId>
</dependency>

@Configuration
public class JtaConfig {
    @Bean(initMethod = "init", destroyMethod = "close")
    public UserTransactionManager atomikosTransactionManager() {
        UserTransactionManager manager = new UserTransactionManager();
        manager.setForceShutdown(true);
        return manager;
    }
    
    @Bean
    public JtaTransactionManager transactionManager() {
        return new JtaTransactionManager(
            new UserTransactionServiceImp(), 
            atomikosTransactionManager()
        );
    }
}

@Transactional
public void updateMultipleDatabases() {
    db1Repository.save(entity1);
    db2Repository.save(entity2);
}

public interface PaymentTCC {
    @TwoPhaseBusinessAction(name = "pay", commitMethod = "confirm", rollbackMethod = "cancel")
    boolean tryPay(@BusinessActionContextParameter(paramName = "orderId") Long orderId, 
                  @BusinessActionContextParameter(paramName = "amount") BigDecimal amount);
    
    boolean confirm(BusinessActionContext context);
    boolean cancel(BusinessActionContext context);
}

@GlobalTransactional
public void placeOrder(Order order) {
    // 嘗試支付
    paymentTCC.tryPay(order.getId(), order.getAmount());
    // 其他業(yè)務(wù)操作...
}

public void executeOrderSaga(Order order) {
    try {
        // 創(chuàng)建訂單
        Long orderId = orderService.create(order);
        // 扣減庫存
        inventoryService.deduct(order.getProductId(), order.getQuantity());
        // 支付處理
        paymentService.process(orderId, order.getAmount());
    } catch (Exception e) {
        // 執(zhí)行補(bǔ)償
        paymentService.refund(orderId);
        inventoryService.refund(order.getProductId(), order.getQuantity());
        orderService.cancel(orderId);
    }
}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

@Transactional
public void createOrder(Order order) {
    // 1. 創(chuàng)建訂單
    orderMapper.insert(order);
    // 2. 發(fā)送消息
    rabbitTemplate.convertAndSend("order.exchange", "order.created", order);
}

@RabbitListener(queues = "order.queue")
public void handleOrderCreated(Order order) {
    inventoryService.deduct(order.getProductId(), order.getQuantity());
}