Spring全家桶--SpringCloud（高级）（三）

四、Seata

4.1 Seata

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。

4.2 Seata术语

TC (Transaction Coordinator) - 事务协调者

维护全局和分支事务的状态，驱动全局事务提交或回滚。

TM (Transaction Manager) - 事务管理器

定义全局事务的范围：开始全局事务、提交或回滚全局事务。

RM (Resource Manager) - 资源管理器

管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

处理过程：

1.TM向TC申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的XID；

2.XID在微服务调用链路的上下文中传播；

3.RM向TC注册分支事务，将其纳入XID对应全局事务的管辖；

4.TM向TC发起针对XID的全局提交或回滚决议；

5.TC调度XID下管辖的全部分支事务完成提交或回滚请求。

测试访问

http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100

4.3 Seata实战

代码已全部上传至github

YuyanCai/SpringCloudDemo: 尚硅谷SpringCloud源码 (github.com)

4.4 @GlobalTransactional验证

下订单 -> 减库存 -> 扣余额 -> 改（订单）状态

数据库初始情况：

正常下单 - http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100

数据库正常下单后状况：

超时异常，没加@GlobalTransactional

模拟AccountServiceImpl添加超时

@Service
public class AccountServiceImpl implements AccountService {
    private static final Logger LOGGER = LoggerFactory.getLogger(AccountServiceImpl.class);
    @Resource
    AccountDao accountDao;
    /**
     * 扣减账户余额
     */
    @Override
    public void decrease(Long userId, BigDecimal money) {
        LOGGER.info("------->account-service中扣减账户余额开始");
        //模拟超时异常，全局事务回滚
        //暂停几秒钟线程
        try { TimeUnit.SECONDS.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); }
        accountDao.decrease(userId,money);
        LOGGER.info("------->account-service中扣减账户余额结束");
    }
}

另外，OpenFeign的调用默认时间是1s以内，所以最后会抛异常。

数据库情况

故障情况

当库存和账户金额扣减后，订单状态并没有设置为已经完成，没有从零改为1

而且由于feign的重试机制，账户余额还有可能被多次扣减

超时异常，加了@GlobalTransactional

用@GlobalTransactional标注OrderServiceImpl的create()方法。

@Service
@Slf4j
public class OrderServiceImpl implements OrderService {
    ...
    /**
     * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
     * 简单说：下订单->扣库存->减余额->改状态
     */
    @Override
    //rollbackFor = Exception.class表示对任意异常都进行回滚
    @GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
    public void create(Order order)
    {
  ...
    }
}

还是模拟AccountServiceImpl添加超时，下单后数据库数据并没有任何改变，记录都添加不进来，达到出异常，数据库回滚的效果。

4.5 集成Seata遇到的各种Bug

Error 2980

检查有没有启动seata服务

Feign调用错误

检查AccountService

1、比较是否一致

@FeignClient(value = "seata-account-service")
public interface AccountService {

server:
  port: 2003
spring:
  application:
    name: seata-account-service

2、检查yml文件

3、检查file文件和yml文件中组名是否一致