SpringCloudAlibaba随笔目录
二、 SpringCloudAlibaba项目之Nacos搭建及服务注册
三、SpringCloudAlibaba项目之生产者与消费者
四、SpringCloud Alibaba项目之Ribbon负载均衡
五、SpringCloud Alibaba项目之 OpenFeign远程调用
六、SpringCloud Alibaba项目之Nacos-config配置中心
七、SpringCloud Alibaba项目之Sentinel流量控制
八、SpringCloudAlibaba项目之Seata分布式事务
九、SpringCloudAlibaba项目之GateWay网关
十、SpringCloudAlibaba项目之SkyWalking链路 追 踪
SpringCloudAlibaba项目之Seata分布式事务
1、分布式事务
事务是数据库的概念,数据库事务(ACID:原子性、一致性、隔离性和持久性);
分布式事务的产生,是由于数据库的拆分和分布式架构(微服务)带来的,在常规情况下,我们在一个进程中操作一个数据库,这属于本地事务,如果在一个进程中操作多个数据库,或者在多个进程中操作一个或多个数据库,就产生了分布式事务;
(1)数据库分库分表就产生了分布式事务;
(2)项目拆分服务化也产生了分布式事务;
2、Seata简介
Seata 是一款开源的分布式事务解决方案,致力于在微服务架构下提供高性能和简单易用的分布式事务服务。
Seata为用户提供了AT、TCC、SAGA和XA事务模式,为用户打造一站式的分布式解决方案;
四种事务模式中,XA模式正在开发中…,其他事务模式已经实现;
目前使用的流行度情况是:AT > TCC > Saga;
我们可以参看seata各公司使用列表:
https://github.com/seata/seata/issues/1246 ; 大部分公司都采用的AT事务模式;
Seata已经在国内很多团队开始落地,其中不乏有大公司;
Github:https://github.com/seata/seata/releases
官网文档:https://seata.io/zh-cn/docs/overview/what-is-seata.html
在Seata的架构中,一共有三个角色:
TC (Transaction Coordinator) – 事务协调者
维护全局和分支事务的状态,驱动全局事务提交或回滚;
TM (Transaction Manager) – 事务管理器
定义全局事务的范围:开始全局事务、提交或回滚全局事务;
RM (Resource Manager) – 资源管理器
管理分支事务处理的资源,与TC交互以注册分支事务和报告分支事务的状态,并驱动分支事务提交或回滚;
其中TC为单独部署的 Server 服务端,TM和RM为嵌入到应用中的 Client 客户端;
在Seata中,一个分布式事务的生命周期如下:
TM请求TC开启一个全局事务,TC会生成一个XID作为该全局事务的编号,XID会在微服务的调用链路中传播,保证将多个微服务的子事务关联在一起;
RM请求TC将本地事务注册为全局事务的分支事务,通过全局事务的XID进行关联;
TM请求TC告诉XID对应的全局事务是进行提交还是回滚;
TC驱动RM将XID对应的自己的本地事务进行提交还是回滚;
3、Seata服务端部署(TC事务协调者)
因为TC需要进行全局事务和分支事务的记录,所以需要对应的存储,目前,TC有三种存储模式( store.mode ):
file模式:适合单机模式,全局事务会话信息在内存中读写,并持久化本地文件 root.data,性能较高;
db模式:(mysql 5.7+)适合集群模式,全局事务会话信息通过 db 共享,相对性能差点;
redis模式:解决db存储的性能问题;
这里使用windows系统演示db模式;
(1)下载安装包
seata下载地址:https://github.com/seata/seata/releases
(2)修改配置文件
(3)创建数据库表
官网已经为我们创建好了脚本,只需要引入使用即可:https://github.com/seata/seata/tree/1.4.0/script/server/db
;
运行mysql.sql文
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS global_table
(
xid
VARCHAR(128) NOT NULL,
transaction_id
BIGINT,
status
TINYINT NOT NULL,
application_id
VARCHAR(32),
transaction_service_group
VARCHAR(32),
transaction_name
VARCHAR(128),
timeout
INT,
begin_time
BIGINT,
application_data
VARCHAR(2000),
gmt_create
DATETIME,
gmt_modified
DATETIME,
PRIMARY KEY (xid
),
KEY idx_gmt_modified_status
(gmt_modified
, status
),
KEY idx_transaction_id
(transaction_id
)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS branch_table
(
branch_id
BIGINT NOT NULL,
xid
VARCHAR(128) NOT NULL,
transaction_id
BIGINT,
resource_group_id
VARCHAR(32),
resource_id
VARCHAR(256),
branch_type
VARCHAR(8),
status
TINYINT,
client_id
VARCHAR(64),
application_data
VARCHAR(2000),
gmt_create
DATETIME(6),
gmt_modified
DATETIME(6),
PRIMARY KEY (branch_id
),
KEY idx_xid
(xid
)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
-- the table to store lock data
CREATE TABLE IF NOT EXISTS lock_table
(
row_key
VARCHAR(128) NOT NULL,
xid
VARCHAR(96),
transaction_id
BIGINT,
branch_id
BIGINT NOT NULL,
resource_id
VARCHAR(256),
table_name
VARCHAR(32),
pk
VARCHAR(36),
gmt_create
DATETIME,
gmt_modified
DATETIME,
PRIMARY KEY (row_key
),
KEY idx_branch_id
(branch_id
)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
总共三张表,global_table(存储全局会话数据)、branch_table(存储分支会话数据)、lock_table(存储锁数据)
4、Seata服务端搭建-nacos
(1)修改注册中心
(2)修改配置中心
(3)启动seata
5、Seata客户端搭建
(1)pom.xml文件引入依赖
<dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-seataartifactId> dependency>
接口调用需要openfeign依赖
<dependency> <groupId>org.springframework.cloudgroupId> <artifactId>spring-cloud-starter-openfeignartifactId> dependency>
(2)各微服务对应的数据库中添加undo_log表
CREATE TABLE undo_log
(
id
bigint(20) NOT NULL AUTO_INCREMENT,
branch_id
bigint(20) NOT NULL,
xid
varchar(100) NOT NULL,
context
varchar(128) NOT NULL,
rollback_info
longblob NOT NULL,
log_status
int(11) NOT NULL,
log_created
datetime NOT NULL,
log_modified
datetime NOT NULL,
PRIMARY KEY(id
),
UNIQUE KEY ux_undo_log
(xid
,branch_id
)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8
(3)将配置注册到nacos注册中心
到https://github.com/seata/seata 下,先将整个文件下载下来,将内部的script脚本文件复制一份到seata的根目录下
修改内部script\config\config.txt文件内容
关于config.txt文件中vgroupMapping.default_tx_group和在项目里配置的要一致
执行script\config-center\nacos\nacos-config.sh把config.txt文件导入到nacos配置中心
注意:执行出现找不到config.txt的话修改一下nacos-config.sh里面关于config.txt的路径指向你本地的即可。如果电脑无法运行.sh文件,安装git即可。
(3) 各微服务 添加配置
application.properties
#配置seata的注册中心
seata.enabled=true
seata.application-id=${spring.application.name}
#配置事务分组
seata.tx-service-group=default_tx_group
seata.registry.type=nacos
seata.registry.nacos.server-addr=127.0.0.1:8848
seata.registry.nacos.application=seata-server
seata.registry.nacos.namespace=
seata.registry.nacos.username=nacos
seata.registry.nacos.password=nacos
seata.registry.nacos.group=SEATA_GROUP
#配置seata的配置中心
seata.config.type=nacos
seata.config.nacos.server-addr=127.0.0.1:8848
seata.config.nacos.namespace=
seata.config.nacos.username=nacos
seata.config.nacos.password=nacos
seata.config.nacos.group=SEATA_GROUP
消费者
OrderController
/**
* 订单服务
*/
@RestController
@RequestMapping("/order")
public class OrderController {
@Resource
private StockOpenFeignService stockOpenFeignService;
@Resource
private OrderService orderService;
/**
* 新增订单
* @return
*/
@RequestMapping("/addOrder")
@GlobalTransactional //分布式事务注解,这个一般放在业务层,这里图方便
public String addOrder(){
Order order = new Order("袜子");
int id = orderService.addOrder(order);
System.out.println("订单新增成功-id:" + id);
//调用库存扣减
String result = stockOpenFeignService.subStock(id);
return new Result(200,"订单服务-订单新增成功",result).toString();
}
}
StockOpenFeignService
/**
* 库存服务接口
* name:指定调用rest接口所对应的服务名
* path:指定调用rest接口所在的StockController指定的@RequestMapping
*/
@FeignClient(name = "service-seata-stock",path = "stock")
public interface StockOpenFeignService {
//声明需要调用的rest接口对应的方法
/**
* 库存扣减
* @return
*/
@PostMapping("/subStock")
String subStock(int id);
}
生产者
StockController
/**
* 库存服务
*/
@RestController
@RequestMapping("/stock")
public class StockController {
@Value("${server.port}")
private String port;
@Resource
private StockService stockService;/**
* 库存扣减
* @return
*/
@PostMapping("/subStock")
public String subStock(@RequestBody int id) {
System.out.println("进入库存扣减接口");int num = stockService.subStock(id);
Result result = null;
if(num > 0){
System.out.println("库存扣减成功-id:" + id);
result = new Result(200,"扣减库存服务-库存成功");
}else {
result = new Result(201,"扣减库存服务-库存失败");
}
return result.toString();
}
}
总结: 实践是检验真理的唯一标准。
参考链接:https://blog.csdn.net/calonmo/article/details/106630754
Original: https://www.cnblogs.com/qiantao/p/15741320.html
Author: QianTM
Title: SpringCloudAlibaba项目之Seata分布式事务
原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/572508/
转载文章受原作者版权保护。转载请注明原作者出处!