SpringCloud之Seata基本介绍与安装

目录

基本介绍

概述

核心组件

 四种方案

部署TC服务（安装）

下载 

修改registry.conf 

nacos添加配置

建表(仅db) 

启动 

基本介绍

概述

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。

阿里巴巴作为国内最早一批进行应用分布式改造的企业，很早就遇到微服务架构下的分布式事务问题。阿里巴巴对于分布式事务问题先后发布了以下解决方案：

  • 2014 年，阿里中间件团队发布 TXC（Taobao Transaction Constructor），为集团内应用提供分布式事务服务。

  • 2016 年，TXC 在经过产品化改造后，以 GTS（Global Transaction Service） 的身份登陆阿里云，成为当时业界唯一一款云上分布式事务产品。在阿云里的公有云、专有云解决方案中，开始服务于众多外部客户。

  • 2019 年起，基于 TXC 和 GTS 的技术积累，阿里中间件团队发起了开源项目 Fescar（Fast & EaSy Commit And Rollback, FESCAR），和社区一起建设这个分布式事务解决方案。

  • 2019 年 fescar 被重命名为了seata（simple extensiable autonomous transaction architecture）。

核心组件

Seata的核心组件可分为Seata服务端和Seata客户端两类

Seata 定义了 3 个核心组件：

  • TC（Transaction Coordinator）：事务协调器，维护全局和分支事务的状态，协调全局事务提交或回滚 ，直接调度事务参与者RM。负责将RM的反馈结果响应给TM，并听从TM的最终决议，将具体决议（提交或回滚）发送给RM执行。相当于中间人，主要负责维护全局事务和分支事务的状态。

  • TM（Transaction Manager）：事务管理器，定义全局事务的范围、开始全局事务、提交或回滚全局事务。 它是事务的发起者（具体的微服务）。根据RM第一阶段的执行结果，进行决议。并将决议反馈给TC。相当于发号施令的

  • RM（Resource Manager）：资源管理器，管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。 其实就是事务的参与者。获取TC的执行命令具去执行分支事务的第一阶段以及第二阶段，并将执行结果反馈给TC，相当于具体做事的

三个组件相互协作，TC 以 Seata 服务器（Server）形式独立部署，TM 和 RM 则是以 Seata Client 的形式集成在微服务中运行。 

 四种方案

 整体的架构如图：

Seata基于上述架构提供了四种不同的分布式事务解决方案：

  • XA模式：强一致性分阶段事务模式，牺牲了一定的可用性，无业务侵入

支持XA协议 事务的数据库。Java 应用，通过 JDBC 访问数据库。

执行阶段（E xecute）：XA start/XA end/XA prepare + SQL + 注册分支

完成阶段（F inish）：XA commit/XA rollback

  • TCC模式：最终一致的分阶段事务模式，有业务侵入

不依赖于底层数据资源的事务支持：

一阶段 prepare 行为：调用 自定义 的 prepare 逻辑。

二阶段 commit 行为：调用 自定义 的 commit 逻辑。

二阶段 rollback 行为：调用 自定义 的 rollback 逻辑。

所谓 TCC 模式，是指支持把 自定义 的分支事务纳入到全局事务的管理中。

  • AT模式：最终一致的分阶段事务模式，无业务侵入，也是Seata的默认模式

基于 支持本地 ACID 事务 的 关系型数据库：

一阶段 prepare 行为：在本地事务中，一并提交业务数据更新和相应回滚日志记录。

二阶段 commit 行为：马上成功结束，自动 异步批量清理回滚日志。

二阶段 rollback 行为：通过回滚日志，自动 生成补偿操作，完成数据回

  • SAGA模式：长事务模式，有业务侵入

Saga模式是SEATA提供的长事务解决方案，在Saga模式中，业务流程中每个参与者都提交本地事务，当出现某一个参与者失败则补偿前面已经成功的参与者，一阶段正向服务和二阶段补偿服务都由业务开发实现。

无论哪种方案，都离不开TC，也就是事务的协调者。

部署TC服务（安装）

下载 

首先要下载seata-server包，地址在http://seata.io/zh-cn/blog/download.html

在非中文目录解压缩这个zip包，其目录结构如下：

修改registry.conf 

注册到nacos中 

registry {# tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等type = "nacos"nacos {# seata tc 服务注册到 nacos的服务名称，可以自定义application = "seata-tc-server"serverAddr = "127.0.0.1:8848"group = "DEFAULT_GROUP"namespace = ""cluster = "SH"username = "nacos"password = "nacos"}
}config {# 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置type = "nacos"# 配置nacos地址等信息nacos {serverAddr = "127.0.0.1:8848"namespace = ""group = "SEATA_GROUP"username = "nacos"password = "nacos"dataId = "seataServer.properties"}
}

nacos添加配置

为了让tc服务的集群可以共享配置，我们选择了nacos作为统一配置中心。因此服务端配置文件seataServer.properties文件需要在nacos中配好。

配置内容如下：

# 数据存储方式，db代表数据库
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
# 事务、日志等配置
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000# 客户端与服务端传输方式
transport.serialization=seata
transport.compressor=none
# 关闭metrics功能，提高性能
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

 其中的数据库地址、用户名、密码都需要修改成你自己的数据库信息。

 Server端存储模式（store.mode）现有file、db、redis三种（后续将引入raft,mongodb），file模式无需改动，直接启动即可。

注： file模式为单机模式，全局事务会话信息内存中读写并持久化本地文件root.data，性能较高;db模式为高可用模式，全局事务会话信息通过db共享，相应性能差些;

建表(仅db) 

tc服务在管理分布式事务时，需要记录事务相关数据到数据库中，你需要提前创建好这些表。 

全局事务会话信息由3块内容构成，全局事务-->分支事务-->全局锁，对应表global_table、branch_table、lock_table。

新建一个名为seata的数据库  ，然后执行以下sql语句

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- 分支事务表
-- ----------------------------
DROP TABLE IF EXISTS `branch_table`;
CREATE TABLE `branch_table`  (`branch_id` bigint(20) NOT NULL,`xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`status` tinyint(4) NULL DEFAULT NULL,`client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime(6) NULL DEFAULT NULL,`gmt_modified` datetime(6) NULL DEFAULT NULL,PRIMARY KEY (`branch_id`) USING BTREE,INDEX `idx_xid`(`xid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;-- ----------------------------
-- 全局事务表
-- ----------------------------
DROP TABLE IF EXISTS `global_table`;
CREATE TABLE `global_table`  (`xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`status` tinyint(4) NOT NULL,`application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`timeout` int(11) NULL DEFAULT NULL,`begin_time` bigint(20) NULL DEFAULT NULL,`application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime NULL DEFAULT NULL,`gmt_modified` datetime NULL DEFAULT NULL,PRIMARY KEY (`xid`) USING BTREE,INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;SET FOREIGN_KEY_CHECKS = 1;

启动 

进入bin目录，运行其中的seata-server.bat即可：  

启动成功后，seata-server应该已经注册到nacos注册中心了。

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

IOS渲染流程之提交图层数据至RenderThread进程

IOS渲染流程之提交图层数据至RenderThread进程

大致链路 UIView/CALayer---->CoreAnimation./Core Graphics/Core Image---->GPU Drive-->GPU 图层树/视图树 一个UIView（视图）对应一个CALayer（图层），CALayer对应显示的数据其有个content代表Bitamp&#…
阅读更多...
【第2章 Node.js基础】2.2 Node.js回调函数

【第2章 Node.js基础】2.2 Node.js回调函数

学习目标 （1）理解Node.js的回调函数； （2）掌握回调函数的使用。 什么是回调函数 回调函数是一种特殊的函数，它作为参数传递给另一个函数，并在特定的事件或条件发生时被调用。回调函数通常用于异…
阅读更多...
Jekyll框架编译GithubPages，提示没有docs

Jekyll框架编译GithubPages，提示没有docs

Jekyll Converters::Scss build issue: No such file or directory dir_chdir - /github/workspace/docs Error: No such file or directory dir_chdir - /github/workspace/docs 解决方案： 修改github page仓库中–> 设置—> pages 把里面的\docs&#xf…
阅读更多...
Microsoft Edge浏览器不兼容解决办法

Microsoft Edge浏览器不兼容解决办法

找到 Edge 的安装位置，一般在 C:\Program Files (x86)Microsoft Edge\Application\ 这个目录，把 edge.exe 或msedge.exe 修改为 chrome.exe 再重启电脑。
阅读更多...
蓝桥杯双周赛算法心得——串门（双链表数组+双dfs）

蓝桥杯双周赛算法心得——串门（双链表数组+双dfs）

大家好，我是晴天学长，树和dfs的结合，其邻接表的存图方法也很重要。需要的小伙伴可以关注支持一下哦！后续会继续更新的。💪💪💪 1) .串门 2) .算法思路 串门（怎么存图很关键&#xf…
阅读更多...
打包 广告

打包 广告

小米广告 Type android.support.v4.app.INotificationSideChannel is defined multiple times d8clsPath: Error in D:\ChannelFolder\JJChannelPackageForTest\ToolConfigPath\channels-ad\ATemp-100057\xiaomi\lib\xiaomi_ad_merge_20231104.jar:android/support/v4/app/IN…
阅读更多...
8.spark自适应查询-AQE之自适应调整Shuffle分区数量

8.spark自适应查询-AQE之自适应调整Shuffle分区数量

目录 概述主要功能自适应调整Shuffle分区数量原理默认环境配置修改配置 结束 概述 自适应查询执行（AQE）是 Spark SQL中的一种优化技术，它利用运行时统计信息来选择最高效的查询执行计划，自Apache Spark 3.2.0以来默认启用该计划。…
阅读更多...
Mall4cloud 微服务商城系统 2.0 发布

Mall4cloud 微服务商城系统 2.0 发布

导读现在 jdk17 和 spring boot 以及 spring cloud alibaba 2022 的第三方依赖已经趋于成熟，所以 mall4cloud 也一把梭哈做了升级嗷。 本次更新重点： 系统由 jdk8 最低要求升级到 jdk17spring boot 由 2.7.x 升级到 3.1.xjavax 升级到 jakartaspring-cl…
阅读更多...
extractvalue报错注入理论及实战

extractvalue报错注入理论及实战

报错注入 什么是报错注入 构造语句，让错误信息中夹杂可以显示数据库内容的查询语句，返回报错提示中包括数据库中的内容 如上图所示，通过group by的报错，我们可以知道列数是多少 输入正确的查询数据库的SQL语句，虽然可…
阅读更多...
Cube MX 开发高精度电流源跳坑过程/SPI连接ADS1255/1256系列问题总结/STM32 硬件SPI开发过程

Cube MX 开发高精度电流源跳坑过程/SPI连接ADS1255/1256系列问题总结/STM32 硬件SPI开发过程

文章目录 概要整体架构流程技术名词解释技术细节小结 概要 1.使用STM32F系列开发一款高精度恒流电源，用到了24位高精度采样芯片ADS1255/ADS1256系列。 2.使用时发现很多的坑，详细介绍了每个坑的具体情况和实际的解决办法。 坑1：波特率设置…
阅读更多...
小白学爬虫：通过关键词搜索1688商品列表数据接口|1688商品列表数据接口|1688商品列表数据采集|1688API接口

小白学爬虫：通过关键词搜索1688商品列表数据接口|1688商品列表数据接口|1688商品列表数据采集|1688API接口

通过关键词搜索1688商品列表数据接口可以使用1688开放平台提供的API接口实现。以下是使用关键词搜索商品列表数据的基本步骤： 1、注册并获取AppKey。 2、构造请求参数，包括搜索关键词、页码、每页条数等。 3、通过API接口链接，将请求参数发送…
阅读更多...
高校教务系统登录页面JS分析——西安外国语大学教务系统

高校教务系统登录页面JS分析——西安外国语大学教务系统

高校教务系统密码加密逻辑及JS逆向 本文将介绍高校教务系统的密码加密逻辑以及使用JavaScript进行逆向分析的过程。通过本文，你将了解到密码加密的基本概念、常用加密算法以及如何通过逆向分析来破解密码。 本文仅供交流学习，勿用于非法用途。 一、密码加…
阅读更多...
微信小程序登录后端

微信小程序登录后端

一、 概念 code code是用户登录凭证,个人理解为用户的授权码（需要用户本人授权给小程序，小程序才有权力获取到你这个用户的数据），code需要由小程序向微信服务器获取。 注意： 每个code只能使用一次，且有效…
阅读更多...
单基因泛癌+实验简单验证，要素丰富，没研究方向的赶紧上车

单基因泛癌+实验简单验证，要素丰富，没研究方向的赶紧上车

今天给同学们分享一篇生信文章“Pan-Cancer Analysis Reveals CENPI as a Potential Biomarker and Therapeutic Target in Adrenocortical Carcinoma”，这篇文章发表在J Inflamm Res期刊上，影响因子为4.5。 结果解读： 正常组织、癌症细胞系…
阅读更多...
影响金融软件开发价格的因素有哪些?

影响金融软件开发价格的因素有哪些?

随着科技的发展，金融行业逐渐向数字化和信息化转型，在这个过程中，金融软件开发成为了重要的支撑，然而，金融软件开发的价格是一个复杂的问题，受到多种因素的影响，本文将详细解析影响金融软件开发…
阅读更多...
深度图（Depth Map）

深度图（Depth Map）

文章目录 深度图深度图是什么深度图的获取方式激光雷达或结构光等传感器的方法激光雷达RGB-D相机 双目或多目相机的视差信息计算深度采用深度学习模型估计深度 深度图的应用场景扩展阅读 深度图 深度图是什么 深度图（depth map）是一种灰度图像&#xf…
阅读更多...
【qemu逃逸】HWS2017-FastCP

【qemu逃逸】HWS2017-FastCP

前言 虚拟机用户名：root 虚拟机密码：无密码 本题有符号，所以对于设备定位啥的就不多说了，直接逆向设备吧。 设备逆向 在 realize 函数中设置一个时钟任务，并且可以看到只注册了 mmio，大小为 0x100000。…
阅读更多...
SpringBoot整合Kafka (二)

SpringBoot整合Kafka (二)

📑前言 本文主要讲了SpringBoot整合Kafka文章，如果有什么需要改进的地方还请大佬指出⛺️ 上文链接：SpringBoot整合Kafka (一) 🎬作者简介：大家好，我是青衿🥇 ☁️博客首页：CSDN主页…
阅读更多...
PTL货位指引标签为仓储管理打开新思路

PTL货位指引标签为仓储管理打开新思路

PTL货位指引标签是一种新型的仓储管理技术，它通过LED灯光指引和数字显示，为仓库管理带来了全新的管理思路和效率提升，成为现代物流仓库管理中的重要工具。 首先，PTL货位指引标签为仓储管理业务带来了管理新思路。传统的仓库管理中…
阅读更多...
iOS Crash 治理：淘宝VisionKitCore 问题修复

iOS Crash 治理：淘宝VisionKitCore 问题修复

本文通过逆向系统&#xff0c;阅读汇编指令&#xff0c;逐步找到源码&#xff0c;定位到了 iOS 16.0.<iOS 16.2 WKWebView 的系统bug 。同时苹果已经在新版本修复了 Bug&#xff0c;对于巨大的存量用户&#xff0c;仍旧会造成日均 Crash pv 1200 uv 1000&#xff0c; 最终通…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023