Seata 的 AT 模式

简介: Seata 的 AT 模式



概述

  Seata 的 AT 模式是 Seata 的默认模式,它的原理是依赖于数据库事务,以数据库事务保证本地事务分支特性,结合 Seata的 Undo 日志记录做事务补偿,来实现的一种二阶段事务。总体来讲,Seata 的AT模式使用起来比较简单,对业务代码的侵入性比较低。

Demo

  这里附上seata的学习代码demo,开箱即用。包含AT/TCC/XA等模式的使用案例https://download.csdn.net/download/lmj3732018/88864802

Springcloud 整合 Seata

数据库脚本

AT 模式需要在每个本地事务分支所在的数据库中添加一个 undo_log 表,用于存储本地事务分支的事务记录。

数据库脚本地址:https://github.com/apache/incubator-seata/blob/v1.7.0/script/client/at/db/mysql.sql

服务依赖

 Seata 的依赖版本最好参照官网推荐的版本对照,否则,可能出现不兼容的一些问题,同时 Seata 客户端与服务端的版本也最好保持一致

POM依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
 
<!--nacos 注册中心-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
 
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
 
<!-- seata-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

Springboot 配置

seata:
  application-id: ${spring.application.name}
  # 这个值要与服务端 service.vgroupMapping.default_tx_group=default 相对应,服务端的值default与下面的 cluster: default 对应。
  tx-service-group: default_tx_group
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 192.168.122.120:8848
      namespace: seata-id
      group: SEATA_GROUP
      username: nacos
      password: nacos
      cluster: default
  config:
    type: nacos
    nacos:
      server-addr: 192.168.122.120:8848
      namespace: seata-id
      group: SEATA_GROUP
      data-id: seataServer.properties
      username: nacos
      password: nacos

代码改造

代码上的改造比较简单,只需在事务发起者的接口方法上添加一个@GlobalTransactional(name="createOrder",rollbackFor=Exception.class)注解。分支事务那边则不用做任何处理

@Override
    //@Transactional
    @GlobalTransactional(name="createOrder",rollbackFor=Exception.class)
    public Order saveOrder(OrderVo orderVo) {
        log.info("=============用户下单=================");
        log.info("当前 XID: {}", RootContext.getXID());
         
        // 保存订单
        Order order = new Order();
        order.setUserId(orderVo.getUserId());
        order.setCommodityCode(orderVo.getCommodityCode());
        order.setCount(orderVo.getCount());
        order.setMoney(orderVo.getMoney());
        order.setStatus(OrderStatus.INIT.getValue());
     
        Integer saveOrderRecord = orderMapper.insert(order);
        log.info("保存订单{}", saveOrderRecord > 0 ? "成功" : "失败");
         
        //扣减库存
        storageFeignService.deduct(orderVo.getCommodityCode(), orderVo.getCount());
 
        if(true){
            throw new RuntimeException();
        }
 
        //扣减余额
        Boolean debit= accountFeignService.debit(orderVo.getUserId(), orderVo.getMoney());
 
//        if(!debit){
//            // 解决 feign整合sentinel降级导致Seata失效的处理
//            throw new RuntimeException("账户服务异常降级了");
//        }
         
        //更新订单
        Integer updateOrderRecord = orderMapper.updateOrderStatus(order.getId(),OrderStatus.SUCCESS.getValue());
        log.info("更新订单id:{} {}", order.getId(), updateOrderRecord > 0 ? "成功" : "失败");
         
        return order;
         
    }

AT模式下的数据隔离

写隔离

AT模式下通过全局锁来保证写操作的隔离性,避免产生脏读。当全局事务A在操作某一条记录时,会给这条记录加一个全局锁,所谓的全局锁实际是指这条记录的ID,当本地事务提交,而全局事务没提交时。我们虽然通过直接操作数据库可以看到这条提交的数据,但是当开启另一个全局事务去操作这条数据时,则会先判断全局锁的存在,如果存在则默认将当前事务回滚(也可修改策略为不断尝试获取全局锁)。

读隔离

AT模式默认情况下,如果数据库的隔离级别为“读已提交”,则全局事务的隔离级别为"读未提交"。AT模式仅仅对 带有 "select  for update"的语句会检查全局锁。

相关文章
|
22天前
|
自然语言处理 监控 Dubbo
Seata常见问题之使用tcc模式配置yml如何解决
Seata 是一个开源的分布式事务解决方案,旨在提供高效且简单的事务协调机制,以解决微服务架构下跨服务调用(分布式场景)的一致性问题。以下是Seata常见问题的一个合集
68 4
|
2月前
|
数据库
|
3月前
|
SQL API 数据库
Seata AT模式问题之抛出异常触发回滚如何解决
Seata是一款开源的分布式事务解决方案,旨在提供高效且无缝的分布式事务服务;在集成和使用Seata过程中,开发者可能会遇到不同的异常问题,本合集针对Seata常见异常进行系统整理,为开发者提供详细的问题分析和解决方案,助力高效解决分布式事务中的难题
303 1
|
2月前
|
Java 数据库连接 API
分布式事物【XA强一致性分布式事务实战、Seata提供XA模式实现分布式事务】(五)-全面详解(学习总结---从入门到深化)
分布式事物【XA强一致性分布式事务实战、Seata提供XA模式实现分布式事务】(五)-全面详解(学习总结---从入门到深化)
53 0
|
21天前
|
NoSQL Java 数据库
Seata常见问题之xa模式下插入一条数据再更新这条数据会报错如何解决
Seata 是一个开源的分布式事务解决方案,旨在提供高效且简单的事务协调机制,以解决微服务架构下跨服务调用(分布式场景)的一致性问题。以下是Seata常见问题的一个合集
108 2
|
22天前
|
Java 关系型数据库 微服务
Seata常见问题之项目一直启动不成功如何解决
Seata 是一个开源的分布式事务解决方案,旨在提供高效且简单的事务协调机制,以解决微服务架构下跨服务调用(分布式场景)的一致性问题。以下是Seata常见问题的一个合集
53 0
|
22天前
|
存储 Java Nacos
Seata常见问题之xa模式出现错误xid is not valid如何解决
Seata 是一个开源的分布式事务解决方案,旨在提供高效且简单的事务协调机制,以解决微服务架构下跨服务调用(分布式场景)的一致性问题。以下是Seata常见问题的一个合集
58 4
|
2月前
|
数据库 开发者
Seata的 TCC 模式
Seata的 TCC 模式
|
1月前
|
SQL 关系型数据库 数据库
学习分布式事务Seata看这一篇就够了,建议收藏
学习分布式事务Seata看这一篇就够了,建议收藏
|
2月前
|
关系型数据库 MySQL 数据库
分布式事务Seata
分布式事务Seata