基于Seata的分布式事务方案AT模式demo

package com.example.orderservice.service; import com.example.orderservice.client.AccountFeignClient; import com.example.orderservice.client.StorageFeignClient; import com.example.orderservice.entity.Order; import com.example.orderservice.mapper.OrderMapper; import feign.FeignException; import io.seata.spring.annotation.GlobalTransactional; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoProperties; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; @Slf4j @Service public class OrderService { @Resource private OrderMapper orderMapper; @Autowired private AccountFeignClient accountFeignClient; @Autowired private StorageFeignClient storageFeignClient; //@Transactional @GlobalTransactional public Long create(Order order) { //创建订单 orderMapper.insertSelective(order); try{ //扣用户余额 accountFeignClient.deduct(order.getUserId(),order.getMoney()); //扣库存 storageFeignClient.deduct(order.getCommodityCode(),order.getCount()); }catch(FeignException e){ log.error("下单失败，原因：{}",e.contentUTF8(),e); throw new RuntimeException(e.contentUTF8(),e); } return order.getId(); } }