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

news2024/12/23 17:57:26

前言

这篇文章我会从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 = 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是否注册成功
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/433029.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

VMware ESXi 8.0U1 Unlocker OEM BIOS 集成网卡驱动和 NVMe 驱动 (集成驱动版)

发布 ESXi 8.0U1 集成驱动版,在个人电脑上运行企业级工作负载 请访问原文链接:https://sysin.org/blog/vmware-esxi-8-u1-sysin/,查看最新版。原创作品,转载请保留出处。 作者主页:sysin.org 2023-04-18, VMware vSp…

【真北直播笔记】董越:简明DevOps学习地图

缘起 真北敏捷社区的宗旨是:求知、连接。求知就是学习,家里没矿的话,学习是一个人最重要的动力之源。连接就是把人拉在一起,我们相信人与人的互动会带来美好的变化。今天的直播是把大家拉在一起学习,就是求知、连接。 …

【万人推荐】黑客成长技术清单

最近两天,在reddit安全板块和Twitter上有个GitHub项目很火,叫“Awesome Hacking”。 “Awesome Hacking”在reddit上有超过四百个赞,但管理员后来认为不适合该板块(Awesome类项目没有新的内容),给了“rejec…

十大排序算法之插入排序、希尔排序、选择排序

个人主页:平行线也会相交 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 平行线也会相交 原创 收录于专栏【数据结构初阶(C实现)】 本篇主要讲解八大排序算法中的三种排序,分别是:插入排序、希尔排…

家用洗地机有什么优缺点?实用的洗地机分享

随着科技的不断发展,家庭清洁设备也在不断更新换代。现在市场上最常见的家用清洁设备包括洗地机、扫地机器人和吸尘器。这些设备各有优缺点,但在清洁效果、清洁范围和清洁方式等方面存在差异。洗地机是一种专业的清洁设备,它能够深度清洁地面…

SpringCloud之Gateway组件简介

网关的理解 网关类似于海关或者大门,出入都需要经过这个网关。别人不经过这个网关,永远也看不到里面的东西。可以在网关进行条件过滤,比如大门只有对应的钥匙才能入内。网关和大门一样,永远暴露在最外面 不使用网关 前端需要记住每…

Javascript进阶专题总结(函数、异步编程、设计模式)

函数式编程什么时候用 编程方法:函数式(js),面向对象(java,c),命令式 函数式(工具式操作) 优点:JavaScript种函数是一等公民,便于拆分组合可扩展性好,方便tree-shaking 缺点&…

【Linux系统】系统安全及应用二

开关安全控制一、开个安全控制1.1调整BIOS引导设置1.2GRUB限制1.3终端安全控制二、系统弱口令检查2.1安装JR工具三、网络端口扫描3.1NMAP端口扫描3.2NETSTAT,SS查看端口信息一、开个安全控制 1.1调整BIOS引导设置 将第一引导设备设为当前系统所在硬盘禁止从其他设…

1-时间复杂度分析

时间复杂度 ①what: 指执行当前算法所消耗的时间 ②简介结论: 时间复杂度由多项式T(n)中最高阶的项来决定,系数的影响忽略即可 例子: 操作数量T(n) 时间复杂度O(f(n)) 常数,比如 100000(即&#xff1…

ChatGPT将批量文档翻译成中文的方法

文档翻译成中文软件是指在处理文档时,自动将文档中的内容翻译成中文的软件。这些软件通常采用自然语言处理技术,通过对待翻译文本的分词、词义分析、语法分析等多种技术处理,实现对文本中的单词、短语、句子等级别的翻译。 文档翻译成中文软件…

CSDN,有幸遇见 ——我的三周年创作纪念日

一生二,二生三,三生万物 三年,与 CSDN 的相遇相识相知—— 前两年都没写,一是没纪念的概念,二是纪念日这天每年总是清明节。 还有就是不知道有勋章(( Meet 遇见 那年,我六年级&a…

JVM 垃圾回收详解之垃圾收集算法+垃圾收集器

标记-清除算法 该算法分为“标记”和“清除”阶段:首先标记出所有不需要回收的对象,在标记完成后统一回收掉所有没有被标记的对象。 它是最基础的收集算法,后续的算法都是对其不足进行改进得到。 这种垃圾收集算法会带来两个明显的问题&…

Node.js—path模块

目录 1、什么是path模块2、path.resolve 拼接规范的绝对路径 常用3、path.sep 获取操作系统的路径分隔符4、 path.parse 解析路径并返回对象5、path.basename 获取路径的基础名称6、path.dirname 获取路径的目录名7、path.extname 获得路径的扩展名8、 path.join()路径拼接 1、…

Linux高性能服务器编程|阅读笔记:第2章 - IP协议详解

简介 Hello! 非常感谢您阅读海轰的文章,倘若文中有错误的地方,欢迎您指出~ ଘ(੭ˊᵕˋ)੭ 昵称:海轰 标签:程序猿|C++选手|学生 简介:因C语言结识编程,随后转入计算机专业,获得过国家奖学金,有幸在竞赛中拿过一些国奖、省奖…已保研 学习经验:扎实基础 + 多做笔…

超越ChatGPT:AgentGPT正在将自主AI带到浏览器中

你好,欢迎来到人工智能领域的新时代!今天我们介绍AgentGPT,这是一款最前沿的基于浏览器的平台,旨在革新人工智能的自主性。这项开创性的技术让你能够在舒适的网络浏览器中创建、配置和部署定制化的人工智能代理,以实现…

又涨了?2023全国程序员薪资最新统计(文末附招聘岗位)

大家好,金三银四招聘季还在进行中。刚好最近看到一份 2022 国内程序员薪酬报告,感觉挺有意思的,跟大家分享一下。 在科技迅速发展的时代,各行业对程序员的需求持续增长,程序员作科技市场的“重要基石”,薪…

nodejs+vue 高校校园食堂餐品在线订购网

食堂作为学校的一个重要的部门,为学生提供了用餐的地点,学生可以在食堂享用丰富的餐品,建立一个在校订餐网站,帮助了学生提供一个用餐订餐的系统,也帮助了食堂提供了一个餐品展示的站点。 园的食堂作为一个窗口单位&a…

【nacos配置中心】源码部分解析

启动初始化 SpringApplication.prepareContext applyInitializers 回调ApplicationContextInitializer的initialize方法 getInitializers()从applicationContext获取List<ApplicationContextInitializer<?>> initializers 这个集合是通过SpringApplication的…

Node.js -- Express中间件

1.中间件的概念 1.1 什么是中间件 中间件&#xff08;Middleware&#xff09;,特指业务流程的中间处理环节。 1.2 现实中的例子 1.3 Express中间件的调用流程 当一个请求到达Express服务器中&#xff0c;可以连续调用多个中间件&#xff0c;从而对这次请求进行预处理。 1…

OpenGL入门教程之 深入理解

一、OpenGL简介 OpenGL是一种用于渲染2D、3D矢量图形的跨语言、跨平台的应用程序编程规范。OpenGL包含一系列可以操作图形和图像的函数&#xff0c;但OpenGL没有实现这些函数&#xff0c;OpenGL仅规定每个函数应该如何执行以及其输出值(类似接口)&#xff0c;所以OpenGL仅是一…