文章目录

（二十）SpringCloud Alibaba Seata处理分布式事务1、分布式问题2、Seata简介2.1 是什么2.2 能干嘛2.3 去那下2.4 怎么玩 3、Seata-Server安装3.1 官网地址3.2 下载版本3.3 解压3.4 mysql5.7数据库新建库seata3.5 在seata库里建表3.6 修改 registry.conf配置文件3.7 先启动Nacos端口号88483.8 再启动seata-server 4、订单/库存/账户业务数据库准备4.1 说明4.2 分布式事务业务说明4.3 创建业务数据库4.3 按照上述3库分别建对应业务表4.4 按照上述3库分别建对应的回滚日志表 5、订单/库存/账户业务微服务准备5.1 业务需求5.2 新建订单Order-Module5.3 新建库存Storage-Module5.4 新建账户Account-Module 6、Test6.1 测试之前数据库情况：6.2 访问：6.3 访问之后数据库情况：6.4 后台情况：6.4 超时异常，没加@GlobalTransactional：6.5 超时异常，添加@GlobalTransactional 7、Seata之原理简介7.1 Seata7.2 再看TC/TM/RM三大组件7.3 AT模式如何做到对业务的无侵入

（二十）SpringCloud Alibaba Seata处理分布式事务

1、分布式问题

分布式前：

单机单库没这个问题从1：1 -> 1:N -> N: N

分布式之后：

一句话：一次业务操作需要跨多个数据源或需要跨多个系统进行远程调用，就会产生分布式事务问题

2、Seata简介

2.1 是什么

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

官网地址：http://seata.io/zh-cn/

2.2 能干嘛

一个典型的分布式事务过程

分布式事务处理过程的——ID+三组件模型

Transaction ID XID：全局唯一的事务ID

3组件概念:

Transaction Coordinator(TC) ：事务协调器，维护全局事务的运行状态，负责协调并驱动全局事务的提交或回滚;Transaction Manager™ ：控制全局事务的边界，负责开启一个全局事务，并最终发起全局提交或全局回滚的决议;Resource Manager(RM) ：控制分支事务，负责分支注册，状态汇报，并接收事务协调器的指令，驱动分支（本地）事务的提交和回滚；

2.3 去那下

发布说明:https://github.com/seata/seata/releases

2.4 怎么玩

Spring 本地@Transactional

全局@GlobalTransactional：SEATA的分布式交易解决方案

3、Seata-Server安装

3.1 官网地址

http://seata.io/zh-cn/blog/download.html

3.2 下载版本

seata-server-0.9.0

3.3 解压

seata-server-0.9.0.zip解压到指定目录并修改conf目录下的file.conf配置文件

先备份原始file.conf文件

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

file.conf修改：

service模块：vgroup_mapping.my_test_tx_group = "fsp_tx_group"

store模块：

mode = “db”

url = “jdbc:mysql://127.0.0.1:3306/seata” user = “root” password = “你自己的密码”

3.4 mysql5.7数据库新建库seata

3.5 在seata库里建表

建表db_store.sql在\seata-server-0.9.0\seata\conf目录里面

赋值db_store.sql里的内容，粘贴到SQLYog中执行

3.6 修改 registry.conf配置文件

修改seata-server-0.9.0\seata\conf目录下的registry.conf配置文件

registry { #file 、nacos 、eureka、redis、zk、consul、etcd3、sofa type = "nacos" nacos { serverAddr = "localhost:8848" namespace = "" cluster = "default" }

3.7 先启动Nacos端口号8848

3.8 再启动seata-server

找到目录softs\seata-server-0.9.0\seata\bin下，执行cmd，输入seata-server.bat

4、订单/库存/账户业务数据库准备

4.1 说明

以下演示都需要先启动Nacos后启动Seata，保证两个都OK

Seata没启动报错no available server to connect

4.2 分布式事务业务说明

下订单–>扣库存–>减账户（余额）

4.3 创建业务数据库

seata_order: 存储订单的数据库seata_storage:存储库存的数据库seata_account: 存储账户信息的数据库

4.3 按照上述3库分别建对应业务表

seata_order库下建t_order表

CREATE TABLE t_order( `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY, `user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id', `product_id` BIGINT(11) DEFAULT NULL COMMENT '产品id', `count` INT(11) DEFAULT NULL COMMENT '数量', `money` DECIMAL(11,0) DEFAULT NULL COMMENT '金额', `status` INT(1) DEFAULT NULL COMMENT '订单状态：0：创建中; 1：已完结' ) ENGINE=INNODB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8; SELECT * FROM t_order;

seata_storage库下建t_storage表

CREATE TABLE t_storage( `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY, `product_id` BIGINT(11) DEFAULT NULL COMMENT '产品id', `'total` INT(11) DEFAULT NULL COMMENT '总库存', `used` INT(11) DEFAULT NULL COMMENT '已用库存', `residue` INT(11) DEFAULT NULL COMMENT '剩余库存' ) ENGINE=INNODB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8; INSERT INTO seata_storage.t_storage(`id`,`product_id`,`total`,`used`,`residue`) VALUES('1','1','100','0','100'); SELECT * FROM t_storage;

seata_account库下建t_account表

CREATE TABLE t_account( `id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'id', `user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id', `total` DECIMAL(10,0) DEFAULT NULL COMMENT '总额度', `used` DECIMAL(10,0) DEFAULT NULL COMMENT '已用余额', `residue` DECIMAL(10,0) DEFAULT '0' COMMENT '剩余可用额度' ) ENGINE=INNODB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8; INSERT INTO seata_account.t_account(`id`,`user_id`,`total`,`used`,`residue`) VALUES('1','1','1000','0','1000') SELECT * FROM t_account;

4.4 按照上述3库分别建对应的回滚日志表

订单-库存-账户3个库下都需要建各自的回滚日志表

粘贴该目录：\seata-server-0.9.0\seata\conf目录下的db_undo_log.sql

然后在每个数据库中就新建该表

4.5 最终效果

5、订单/库存/账户业务微服务准备

5.1 业务需求

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

5.2 新建订单Order-Module

https://www.freesion.com/article/7552502508/

no available server to connect.

5.3 新建库存Storage-Module

5.4 新建账户Account-Module

6、Test

6.1 测试之前数据库情况：

6.2 访问：

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

6.3 访问之后数据库情况：

6.4 后台情况：

2001

2002：

2003：

6.4 超时异常，没加@GlobalTransactional：

AccountServiceImpl添加超时

public void decrease(Long userId, BigDecimal money) { System.out.println(("------->account-service中扣减账户余额开始")); //模拟超时异常，全局事务回滚 try { TimeUnit.SECONDS.sleep(20); }catch (InterruptedException e) { e.printStackTrace(); } accountDao.decrease(userId,money); System.out.println("------->account-service中扣减账户余额结束"); }

重启2003，再次访问

数据库情况

故障情况

当库存和账户余额扣减后，订单状态并没有设置为已经完成，没有从零改为1而且由于feign的重试机制，账户余额还有可能被多次扣减

6.5 超时异常，添加@GlobalTransactional

AccountServiceImpl添加超时

OrderServiceImpl@GlobalTransactional

再次测试：

查看数据库：

下单后数据库数据并没有任何改变，记录都添加不进来

7、Seata之原理简介

7.1 Seata

Simple Extensible Autonomous Transaction Architecture：简单可扩展自治事务框架

2020起初，参加工作后用1.0以后的版本

7.2 再看TC/TM/RM三大组件

TC：seata的服务器

TM：事物的发起者，业务的入口。 @GlobalTransactional(name = “txl-create-order”, rollbackFor = Exception.class)

RM：事务的参与者，一个数据库就是一个RM。

分布式事务的执行流程：

TM开启分布式事务(TM向TC注册全局事务记录)换业务场景，编排数据库，服务等事务内资源（RM向TC汇报资源准备状态）TM结束分布式事务，事务一阶段结束（TM通知TC提交/回滚分布式事务）TC汇总事务信息，决定分布式事务是提交还是回滚TC通知所有RM提交/回滚资源，事务二阶段结束。

7.3 AT模式如何做到对业务的无侵入

1）是什么

2）一阶段加载

3）二阶段提交

4）二阶段回滚

回滚资源，事务二阶段结束。