【分布式事务 本地部署Seata服务】分布式事务框架Seata本地部署详细讲解

news/2025/2/3 21:08:20/

前言

这篇文章我会从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下载的时候安装包没有附带的配置文件(其他版本不太清楚),所以我们选择去官网下载。

配置文件下载步骤

  1. 打开seata中文官网https://seata.io/zh-cn/index.html

  2. 点击首页Github JAVA
    在这里插入图片描述

  3. 将文件打包下载
    在这里插入图片描述

  4. 在下载好的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 = InnoDBDEFAULT 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 = InnoDBDEFAULT 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 = InnoDBDEFAULT 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 = InnoDBDEFAULT 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是否注册成功
在这里插入图片描述


http://www.ppmy.cn/news/45745.html

相关文章

【计算机网络】学习笔记:第二章 物理层(五千字详细配图)【王道考研】

创作不易&#xff0c;本篇文章如果帮助到了你&#xff0c;还请点赞支持一下♡>&#x16966;<)!! 主页专栏有更多知识&#xff0c;如有疑问欢迎大家指正讨论&#xff0c;共同进步&#xff01; 给大家跳段街舞感谢支持&#xff01;ጿ ኈ ቼ ዽ ጿ ኈ ቼ ዽ ጿ ኈ ቼ ዽ ጿ…

TensorFlow 深度学习第二版:6~10

原文&#xff1a;Deep Learning with TensorFlow Second Edition 协议&#xff1a;CC BY-NC-SA 4.0 译者&#xff1a;飞龙 本文来自【ApacheCN 深度学习 译文集】&#xff0c;采用译后编辑&#xff08;MTPE&#xff09;流程来尽可能提升效率。 不要担心自己的形象&#xff0c;只…

精通 TensorFlow 1.x:6~10

原文&#xff1a;Mastering TensorFlow 1.x 协议&#xff1a;CC BY-NC-SA 4.0 译者&#xff1a;飞龙 本文来自【ApacheCN 深度学习 译文集】&#xff0c;采用译后编辑&#xff08;MTPE&#xff09;流程来尽可能提升效率。 不要担心自己的形象&#xff0c;只关心如何实现目标。—…

Linux驱动开发:设备树节点与属性

目录 1、设备节点&#xff08;node&#xff09; 2、属性&#xff08;property&#xff09; 3、节点的一些特性 4、节点的一些标准属性 4.1 compatible属性 4.2 model属性 4.3 status属性 4.4 reg属性 4.5 #address-cells和 #size-cells属性 5、device_node结构体 6、…

Android路由ARoute使用

一、先导入ARoute,这里分为两种情况&#xff0c;java和kotlin 在module(或library)中的build.gradle添加如下代码 java配置 android {defaultConfig {//java路由配置javaCompileOptions {annotationProcessorOptions {arguments [AROUTER_MODULE_NAME: project.getName()]}…

刷题日记①

day01 1. %m.ns 打印输出 以下程序的运行结果是&#xff08;&#xff09;_表示空格 #include <stdio.h> int main(void) {printf("%s , %5.3s\n", "computer", "computer");return 0; }A computer , puter B computer , __com C compute…

思科ASA防火墙:控制防火墙不让访问指定网站

环境&#xff1a; 内网客户机&#xff1a;win10 思科asa防火墙 外网客户机&#xff1a;server 2016 win10可以通过域名访问网站 进入asa全局模式 access-list http permit tcp 192.168.6.0 255.255.255.0 any eq www access-list 名字 permit 协议 要被控制的网段 子网…

MySQL ,MyBatis 1.参数占位符 2. ParameterType 3. SQL 语句中特殊字符处理

1.参数占位符&#xff1a; 1&#xff09;#{}&#xff1a;执行sql时&#xff0c;会将#仔占位符替换为&#xff1f;&#xff0c;将来自动设置参数值 2&#xff09;${}&#xff1a;拼SQL。会存在SQL注入问题 3.使用时机&#xff1a; * 参数传递&#xff0c;都使用#{} *如果要对表名…