栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

seata分布式事务

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

seata分布式事务

目录

1.分布式事务由来

2.安装步骤

3. 准备业务库

4.order module 搭建

5.seata之原理


1.分布式事务由来

分布式事务之前:单机单库没这个问题

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

ID+三组件模型

ID:全局唯一的id

三组件:

Transaction Coordinator TC:事务协调器

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

Transaction Manager TM:定义全局事务的范围:开始全局事务、提交、回滚

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

2.安装步骤

下载版本

将压缩包解压到指定目录并修改conf目录下的file.conf配置文件

file.conf主要修改:自定义事务组名称+事务日志存储模式为db+数据库连接信息

service模块:

        vgroup_mapping.my._test_tx_group = "自定义名称"

store模块:

        mode = db

修改数据库的链接配置

mysql新建seata库

在seata库里建表

修改seata/conf目录下的registry.conf配置文件

注册到nacos

3. 准备业务库

创建订单库,库存库,账户库

订单库中建立订单表,库存库中建立库存表,账户库中建立账户表。同时在各个库中建立事务回滚表,建表sql  seata/conf/db_undo_log.sql

4.order module 搭建

pom配置:


    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-discovery


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


  io.seata
  seata-all
  0.9.0


   org.springframework.cloud
   spring-cloud-starter-openfeign

yml配置:

spring:
    cloud:
        alibaba:
            seata:
               tx-service-group: 和 seata-server里面配置的组一致

config配置:

mybatis配置:

@Configuration
@MapperScan("{com.xxx.springcloud.alibaba.dao}")
public class MyBatisConfig{
    

}
@Configuration
public class DataSourceProxyConfig{
    
    @Value("${mybatis.mapperLocations}")
    private String mapperLocations;
    
    @Bean
    @ConfigurationProperties(prefix="spring.datasource")
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }
    
    @Bean
    public DataSourceProxy dataSourceProxy(DataSource dataSource){
            return new DataSourceProxy(dataSource);
    }
    
    @Bean
    public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception{
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(dataSourceProxt);
            sqlSessionFactoryBean.setMapperLocations(new PathMathingResourcePatternResolver().getResources(mapperLocations));
            sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
            return sqlSessionFactoryBean.getObject();
    }
}

file.conf,registry.conf 配置文件拷贝到resources目录下

主启动类:

@EnableDiscoveryClient
@EnableFeignClients
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源的自动创建    
public class SeataOrderAPP{

    public static void main(String[] args){
        SpringApplication.run(SeataOrderApp.class ,args);
    
        }

}

@GlobalTransactional

5.seata之原理

seata简写: 简单可扩展的自治事务框架。

阿里云把seata改成GTS

seata特色功能:

        TCC模式,AT模式,XA模式,SAGA模式

默认是AT模式:提供无侵入自动补偿的事务模式,目前支持mysql,oracle。

AT模式:

两阶段提交协议的演变:+

一阶段:业务数据和回滚日志记录在同一个本地事务中提交,释放本地锁和连接资源。

二阶段:提交异步化,非常快速的完成。

回滚通过一阶段的回滚日志进行反向补偿。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/735957.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号