欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

seata分布式事务

时间:2023-06-16

目录

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{ }@Configurationpublic 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模式:

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

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

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

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

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。