• seata-分布式事务


    1 事务

    事务(TRANSACTION)是作为单个逻辑工作单元执行的一系列SQL操作,这些操作作为一个整体一起向系统提交,要么都执行、要么都不执行。

    1.1 ACID事务的特点

    1. 原⼦性:即不可分割性,事务要么全部被执⾏,要么就全部不被执⾏。
    2. ⼀致性或可串性。事务的执⾏使得数据库从⼀种正确状态转换成另⼀种
    正确状态
    3. 隔离性。在事务正确提交之前,不允许把该事务对数据的任何改变提供
    给任何其他事务
    4. 持久性。事务正确提交后,其结果将永久保存在数据库中,即使在事务
    提交后有了其它故障,事务的处理结果也会得到保存。

    1.2 事务并发带来的问题

    脏读(Dirty read): 当一个事务正在访问数据并且对数据进行了修改, 而这种修改还没有提交到
    数据库中,这时另外一个事务也访问了这个数据, 然后使用了这个数据。因为这个数据是还没有
    提交的数据,那么另外一个事 务读到的这个数据是“脏数据”,依据“脏数据”所做的操作可能是不正
    确的。
    丢失修改(Lost to modify): 指在一个事务读取一个数据时,另外一个 事务也访问了该数据,那
    么在第一个事务中修改了这个数据后,第二个事务 也修改了这个数据。这样第一个事务内的修改
    结果就被丢失,因此称为丢失 修改。 例如:事务1读取某表中的数据A=20,事务2也读取A=20,
    事务1修 改A=A-1,事务2也修改A=A-1,最终结果A=19,事务1的修改被丢失。
    不可重复读(Unrepeatableread): 指在一个事务内多次读同一数据。 在这个事务还没有结束
    时,另一个事务也访问该数据。那么,在第一个事务 中的两次读数据之间,由于第二个事务的修
    改导致第一个事务两次读取的数 据可能不太一样。这就发生了在一个事务内两次读到的数据是不
    一样的情 况,因此称为不可重复读。
    幻读(Phantom read): 幻读与不可重复读类似。它发生在一个事务 (T1)读取了几行数据,接
    着另一个并发事务(T2)插入了一些数据时。在 随后的查询中,第一个事务(T1)就会发现多了
    一些原本不存在的记录,就 好像发生了幻觉一样,所以称为幻读。

    1.3 我们可以使用事务的隔离级别来解决

          READ-UNCOMMITTED(读取未提交): 最低的隔离级别,允许读取尚未提交 的数据变更,可能会导致脏读、幻读或不可重复读。
        READ-COMMITTED(读取已提交): 允许读取并发事务已经提交的数据,可 以阻止脏读,但是幻读或不可重复读仍有可能发生。
          REPEATABLE-READ(可重复读): 对同一字段的多次读取结果都是一致 的,除非数据是被本身事务自己所修改,可以阻止脏读和不可重复读,但幻 读仍有可能发生。
          SERIALIZABLE(可串行化): 最高的隔离级别,完全服从ACID的隔离级 别。所有的事务依次逐个执行,这样事务之间就完全不可能产生干扰,也就 是说,该级别可以防止脏读、不可重复读以及幻读。

    2. 分布式事务

    2.1 如何解决分布式问题

    使用消息中间件

    手写代码解决分布式事务

    使用第三方组件--->Seata阿里巴巴的产品

    2.2 介绍seata

    Seata部署指南

    Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式,为用户打造一站式的分布式解决方案。

     

    Seata的执行流程如下:

    1. A服务【订单微服务】的TM[事务发起者]向TC[seata服务端]申请开启一个全局事务,TC就会创建一个全局事务并返回一个唯一的XID

    2. A服务开始远程调用B服务【账户微服务】,此时XID会在微服务的调用链上传播

    3. B服务的RM向TC注册分支事务,并将其纳入XID对应的全局事务的管辖

    4. B服务执行分支事务,向数据库做操作

    5. 全局事务调用链处理完毕,TM根据有无异常向TC发起全局事务的提交或者回滚

    6. TC协调其管辖之下的所有分支事务, 决定是否回滚

    TM:事务发起者【在哪个方法上添加了全局事务注解的】

    TC : 事务管理器【seata的服务端】

    RM: 每个操作数据库的微服务

    XID: 全局事务id

    TM和RM都属于微服务代码

    TC: seata服务器。

    2.3 搭建seata服务器

    (1)下载seata1.3.0

    Release v1.3.0 · seata/seata · GitHub

    (2) 解压  

     

    (3)修改conf/file.conf

    让seata集群信息可以共享,我们应该修改它的保存位置:

     

    (4)创建数据库并导入表结构  

     (5)指定seata的注册中心地址和配置中心的内容

     

     需要把哪些配置项放入nacos配置中心呢!

     

     使用nacos/nacos-fonfig.sh 把配置信息放入nacos配置中心

     如果想人为指定nacos配置中心的地址

    2.4 配置微服务客户端

    1)在每个数据库中创建unlog表

     

     

    (2)在每个微服务中添加seata依赖

     
           
                com.alibaba.cloud
                spring-cloud-starter-alibaba-seata
           

    (3)修改每个微服务的配置文件

     注意:MySQL的驱动名称如果为8.0一定要为com.mysql.cj.jdbc.Driver. 如果为5.7一下的可以用com.mysql.jdbc.Driver

  • 相关阅读:
    Bootstrap-- 逻辑运算符
    搬家公司 马蹄集
    [附源码]java毕业设计青少年计算机知识学习系统
    初识网页与浏览器
    SpringBoot:(五)自动配置原理解析
    JavaFX作业
    基于Admin.NET框架的前端的一些改进和代码生成处理(1)
    PyQt5的安装
    gradle-7.5.1-all 百度网盘下载
    总结:linux笔记-004
  • 原文地址:https://blog.csdn.net/m0_58380757/article/details/126546072