### 2.2 配置Seata
seata:
enabled: true
application-id: order-service
tx-service-group: fgedu_tx_group
service:
vgroup-mapping:
fgedu_tx_group: default
registry:
type: nacos
nacos:
server-addr: 192.168.1.100:8848

## 3. 使用分布式事务
### 3.1 订单服务
@Service
public class OrderService {

@GlobalTransactional
public void createOrder(OrderDTO orderDTO) {
Order order = new Order();
order.setUserId(orderDTO.getUserId());
order.setCourseId(orderDTO.getCourseId());
orderMapper.insert(order);

userClient.deductBalance(orderDTO.getUserId(), orderDTO.getAmount());
courseClient.reduceStock(orderDTO.getCourseId(), 1);
}
}
SEATA

# 2. 创建分布式事务示例
cat > $PROJECT_DIR/order-service/src/main/java/com/fgedu/order/service/OrderService.java << 'SERVICE' package com.fgedu.order.service; import io.seata.spring.annotation.GlobalTransactional; import org.springframework.stereotype.Service; import org.springframework.beans.factory.annotation.Autowired; @Service public class OrderService { @Autowired private OrderMapper orderMapper; @Autowired private UserClient userClient; @Autowired private CourseClient courseClient; @GlobalTransactional(name = "create-order", rollbackFor = Exception.class) public void createOrder(OrderDTO orderDTO) { Order order = new Order(); order.setUserId(orderDTO.getUserId()); order.setCourseId(orderDTO.getCourseId()); order.setAmount(orderDTO.getAmount()); order.setStatus("CREATED"); orderMapper.insert(order); userClient.deductBalance(orderDTO.getUserId(), orderDTO.getAmount()); courseClient.reduceStock(orderDTO.getCourseId(), 1); } } SERVICE # 3. 创建消息队列事务 cat > $PROJECT_DIR/docs/microservice/mq_transaction.md << 'MQ' # 消息队列事务 ## 1. RocketMQ事务消息 ### 1.1 事务消息生产者 @Service public class OrderTransactionProducer { @Autowired private RocketMQTemplate rocketMQTemplate; public void sendOrderMessage(Order order) { Message message = MessageBuilder.withPayload(order).build();

rocketMQTemplate.sendMessageInTransaction(
“order-group”,
“order-topic”,
message,
null
);
}
}

### 1.2 事务监听器
@RocketMQTransactionListener
public class OrderTransactionListener implements RocketMQLocalTransactionListener {

@Override
public RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) {
try {
Order order = (Order) msg.getPayload();
orderService.createOrder(order);
return RocketMQLocalTransactionState.COMMIT;
} catch (Exception e) {
return RocketMQLocalTransactionState.ROLLBACK;
}
}

@Override
public RocketMQLocalTransactionState checkLocalTransaction(Message msg) {
Order order = (Order) msg.getPayload();
Order existOrder = orderService.getById(order.getId());

if (existOrder != null) {
return RocketMQLocalTransactionState.COMMIT;
} else {
return RocketMQLocalTransactionState.ROLLBACK;
}
}
}
MQ

echo “分布式事务配置完成”
EOF

$ chmod +x /usr/local/bin/distributed_transaction_setup.sh