前言
这篇文章我会从0到1详细搭建分布式事务框架seata
的使用,那么我们首先要先了解一下什么是分布式事务?
本篇文章是本地启动seata服务并且注册到nacos中,在SpringCloud中整合seata框架请转移下方连接
点我跳转SpringCloud整合seata教程: https://blog.csdn.net/Syals/article/details/130108305?spm=1001.2014.3001.5502
Seata框架简介
Seata官方中文网址:https://seata.io/zh-cn/index.html
Seata是一款基于Java语言的分布式事务解决方案,它支持多种事务模型,包括 AT、TCC、SAGA和XA。 Seata可以与Spring、Dubbo、gRPC和Motan等流行的框架集成,使应用程序可以轻松地实现分布式事务。
这篇文章我们采用的是AT模式,也是阿里推荐的模式
Seata框架中,有三种不同的角色:
- Transaction Coordinator(TC,事务协调者 server端):它是Seata框架的核心组件,负责协调分布式事务的整个过程。当一个分布式事务发起时,TC会创建一个全局事务ID,并在分支事务开始时将该ID分配给每个事务参与者。一旦分支事务完成,TC将收集它们的状态并决定是否提交或回滚事务。
- Resource Manager(RM,资源管理器 Client端):它负责管理本地事务和资源,并协调TC完成分布式事务。在Seata框架中,RM可以是任何一种资源,如数据库、消息队列、Redis等。
- Transaction Participant(TP,事务参与者 Client端):它是参与分布式事务的应用程序,可以是服务端应用程序、客户端应用程序或任何其他支持事务的应用程序。当一个事务参与者加入一个分布式事务时,它会将全局事务ID发送给RM,并在本地事务结束时通知TC事务状态。
应用场景
这里我简单描述一个案例(图画的不好请见谅)
在分布式场景下,比如我们有一个order(订单)服务和stock(库存)服务,那么当用户下单的时候,肯定是要与数据库交互,那么订单服务和库存服务不在一个数据库(或者说在一个数据库但是他们服务所在的位置不同),肯定要在订单服务中使用RPC远程调用的方式来对库存进行扣减。
那么问题来了,当我订单服务在添加一条新的订单后,我去远程调用库存服务,订单服务添加成功,但是库存服务报错了,或者是宕机了,这时候本地事务是不会回滚的,那么这就需要使用到分布式事务了。
分布式事务可以理解为服务A和服务B共同有一个全局的事务ID,并且事务ID是由TC发放并管理,当任何一方服务报错或者出现异常等,TC则会根据全局事务ID来进行回滚,这样不管我们调用多少服务,只要有一个出现异常,那么就会将本次操作的服务全部回滚。
准备工作
1 Seata Server端搭建
1.1下载Seata Server端的服务
Seata下载地址:https://github.com/seata/seata/releases
我这里下载的是seata-server-1.3.0,spring-cloud2.2.7,nacos2.0.3
注:要根据你的SpringCloud版本和Nacos版本选择对应的Seata版本,为了避免依赖冲突问题。
下载完之后,目录结构是这样
1.2 Seata Server端的配置
修改数据库配置项
1 首先打开
conf
文件夹,找到里面的file.conf
文件,我们右键编辑它。
修改db的配置项
修改注册中心配置项
2 在
file.conf
的同级目录找到registry.conf
右键编辑打开它进行配置修改
1 修改注册中心的配置项
2 修改配置中心(还是在同一个文件中,划到最下面)
3 创建logs文件夹,跟bin目录同级
然后打开conf文件夹的
logback.xml
文件修改日志保存位置
那么到这一步呢我们就将seata的数据库和nacos配置好了,接下来最重要的一步,我们需要将seata的配置文件注册到nacos配置中心。
由于1.3.0下载的时候安装包没有附带的配置文件(其他版本不太清楚),所以我们选择去官网下载。
配置文件下载步骤
-
打开seata中文官网https://seata.io/zh-cn/index.html
-
点击首页Github JAVA
-
将文件打包下载
-
在下载好的zip压缩包中找到
script
文件夹,将scrpit文件夹复制一份到seata目录里面。(跟bin文件夹同级即可)
那么到这里我们就将所需的配置文件给下载好了,那么我们如何上传到nacos呢?通过手动创建配置文件然后复制粘贴吗?
其实seata给我们提供好了脚本,我们只需要将配置文件修改后,然后运行脚本即可自动帮我们部署到nacos的配置中心
配置文件上传nacos
- 首先进入到文件夹
script\config-center
下,可以看到有一个config.txt
文件,这个就是我们的配置文件
- 然后我们修改mode项,详情请看下图:
- 到这里我们DB的配置项就完成了,还有一项很重要的就是
service.vgroupMapping
这个配置项。 - 还是在同一个文件中,我们 ctrl + f 搜索
service.vgroupMapping
这个选项做一些配置,如下图
- 把上面这些完成之后,我们就可以使用脚本上传配置项了,首先要注意的是你的nacos必须是在启动状态,然后我们进入到
script\config-center\nacos
文件夹中
- 一个是python脚本,一个是shell脚本,我们Java程序员可以直接使用Git执行。
- 双击
nacos-config.sh
等待执行完毕,我们登陆nacos查看。 - 在这可以看到我们的配置文件上传成功了。
注意:在seata1.4.2版本之后,所有的配置项可以整合到一个配置文件中,就不用像上面这样每一个配置项都是一个配置文件。
具体的操作请跳转:https://blog.csdn.net/Syals/article/details/130218521?spm=1001.2014.3001.5501
最后一步
将这个路径下的sql文件执行到你们的数据库,就是上面配置file.conf
文件中的db指定的数据库
- 或者直接复制下面的脚本到你们的数据库执行。
-- -------------------------------- 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_status_gmt_modified` (`status` , `gmt_modified`),
KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8mb4;
-- 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 = utf8mb4;
-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
`row_key` VARCHAR(128) NOT NULL,
`xid` VARCHAR(128),
`transaction_id` BIGINT,
`branch_id` BIGINT NOT NULL,
`resource_id` VARCHAR(256),
`table_name` VARCHAR(32),
`pk` VARCHAR(36),
`status` TINYINT NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
`gmt_create` DATETIME,
`gmt_modified` DATETIME,
PRIMARY KEY (`row_key`),
KEY `idx_status` (`status`),
KEY `idx_branch_id` (`branch_id`),
KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8mb4;
CREATE TABLE IF NOT EXISTS `distributed_lock`
(
`lock_key` CHAR(20) NOT NULL,
`lock_value` VARCHAR(20) NOT NULL,
`expire` BIGINT,
primary key (`lock_key`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8mb4;
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
- 一共是4张表
启动seata
在bin目录双击seata-server.bat
文件
启动成功后是这样的,默认端口号为8091。
注意:如果你遇到了闪退或者报错等问题,你可以在bin目录的搜索栏打开cmd,使用黑窗口来运行seata-server.bat,这样的话可以避免闪退看不到报错信息的问题。
然后我们看一下nacos是否注册成功