SpringCloud Alibaba - Seata 部署 TC 服务，并集成微服务

目录

一、Seata 架构

1.1、Seata 架构重要角色

1.2、部署 TC 服务

1.2.1、前言

1.2.2、下载 seata-server 包，解压

1.2.3、修改配置

1.2.4、在 nacos 中添加配置

1.2.5、创建数据库表

1.2.6、启动 TC 服务

1.3、微服务集成 Seata

1.3.1、引入依赖

1.3.2、修改配置文件（添加 Seata）

一、Seata 架构

1.1、Seata 架构重要角色

Seata 事务管理中，有以下三个重要的角色：

  1. TC (Transaction Coordinator) - 事务协调者：维护全局和分支事务的状态，协调全局事务提交或回滚。
  2. TM (Transaction Manager) - 事务管理器：定义全局事务的范围、开始全局事务、提交或回滚全局事务。
  3. RM (Resource Manager) - 资源管理器：管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

三者之间的关系

1. 分布式事务有一个入口方法，会去调用多个微服务，每调用一个微服务就相当于一个分支事务.  因此整个入口方法就定义全局事务的范围，TM 就会去监控这个入口的方法，也就知道这个事务里有多少分支事务.

2. 当入口方法被执行时，TM 会首先拦截当前这个执行的动作，然后向 TC 发送一个请求，注册全局事务.  那么接下来，就可以去执行这个入口的业务逻辑了，进一步的，分支事务也就开始执行了.

3. RM 此时就要上场了，他会在分支事务执行的时候拦截下来，然后向 TC 注册这个分支事务，告诉他说“我是属于哪个全局事务，这里有一个分支要执行了啊”.   然后 RM 就可以执行这个业务的 sql（为甚叫就资源管理器，因为资源指的是数据库，RM 就需要执行sql）.  执行完后再把当前分支事务的状态报告给 TC（执行成功了？还是回滚了？）.  这样一来，TC 就知道每一个分支事务的状态了. 

4. 等到 TM  这边的入口方法全部执行完毕了，就可以提交这个事务到 TC 了（告诉他说：“我这边处理完了，接下来看你怎么办吧~”）. 之后 TC 就会去检查刚刚注册的每一个分支事务的状态，如果都是成功的，就告诉这些 RM 说：“你们去提交吧”.  如果 TC 这边检查到有失败的，那就让他们全部回滚.

Ps：以上只是分布式事务解决方案的基本模型，不是最终的解决方案. 在后续的章节中，也会讲到的.

1.2、部署 TC 服务

1.2.1、前言

刚刚我们已经知道了 Seata 中三个重要角色，其中 tm 和 rm 是对业务的管理，而  tc 则是脱离业务之外的独立服务，需要协调 tm 和 rm，协调全局事务和分支事务.

这里我就来带大家搭建一下 Seata 的 TC 服务.

1.2.2、下载 seata-server 包，解压

首先我们要下载 seata-server 包，官网地址如下：

http://seata.io

Ps：在非中文目录解压这个 zip 包.

1.2.3、修改配置

修改 conf 目录下的 registry.conf 文件.

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"}
}

1.2.4、在 nacos 中添加配置

为了让 TC 服务的集群可以共享配置，这里我们选择了 nacos 做为统一的配置中心.

因此服务端配置文件 seataServer.properties 文件需要在 nacos 中配置好.

Ps：DataID 和 Group 要对应 registry.conf 文件中的配置 

配置内容如下：

# 数据存储方式，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=jaodfhgaduqheqh82043ht^&*(%$ioueryg0gu3q0gq3gusaioy8tq94gyu80q32g
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

Ps：以上只有数据的存储方式需要我们自己配置，其他的都可以不配置（走默认配置），上面配置的原因是方便以后修改默认配置.  

1.2.5、创建数据库表

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

分支事务表如下：

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;

1.2.6、启动 TC 服务

Windows 系统进入 bin 目录，运行 seata-server.bat 即可.

启动完成后，可以看到默认端口是 8091（当然这个端口不是给你访问的，而是给 tm 和 rm 访问的）.

之后，打开浏览器，输入 nacos 地址：localhost:8848/nacos，进入服务列表页，就可以看到 seata-tc-server 的信息，表明注册成功，如下.

1.3、微服务集成 Seata

1.3.1、引入依赖

引入的 seata 依赖中，默认的 seate starter 依赖版本太低，因此通过 exclusion 排除，引入 seata starter 1.4.2 版本.

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><exclusions><!--版本较低，1.3.0，因此排除--><exclusion><artifactId>seata-spring-boot-starter</artifactId><groupId>io.seata</groupId></exclusion></exclusions>
</dependency>
<!--seata starter 采用1.4.2版本-->
<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>${seata.version}</version>
</dependency>

1.3.2、修改配置文件（添加 Seata）

配置 application.yml，让微服务通过注册中心找到 seata-tc-server.

要找到 nacos 服务，就需要配置：namespace + group + serviceName + cluster

其中 cluster 的配置需要注意，通过映射配置.

内容如下：

seata:registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址# 参考tc服务自己的registry.conf中的配置type: nacosnacos: # tcserver-addr: 127.0.0.1:8848namespace: ""group: DEFAULT_GROUPapplication: seata-tc-server # tc服务在nacos中的服务名称tx-service-group: seata-demo # 事务组，根据这个获取tc服务的cluster名称service:vgroup-mapping: # 事务组与TC服务cluster的映射关系seata-demo: SH

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

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

相关文章

证书显示未受信任，生成的证书过期

证书显示未受信任，生成的证书过期

此时若是导入证书后&#xff0c;证书显示未受信任&#xff0c;则说明我们缺失最新的AppleWWDRCA证书 解决方案&#xff1a; 重新下载AppleWWDRCA并安装。即下载最新的AppleWWDRCA证书&#xff0c;双击安装到“登录”项的钥匙串下&#xff1b;然后再安装你的开发证书或者发布证书…
阅读更多...
SpringBoot中使用Servlet和Filter

SpringBoot中使用Servlet和Filter

为什么要把Servlet和Filter写在一起,因为使用方式很相似 两种方式 第一种,使用Servlet和Filter 使用Servlet 继承HttpServlet 注册Servlet 使用Filter 1.自定义过滤器 2.注册过滤器 这里注意一点 使用/**无效 至少我这2.4.5版本是这样 过滤所有请求用/* 那么其实还有…
阅读更多...
如何在idea中隐藏文件或文件夹

如何在idea中隐藏文件或文件夹

例如我想要隐藏如下文件 只需要点击file->settings editor->file types->ignores Files and Folders-> 然后按照图片点击顺序操作即可 添加完毕点击apply->ok 隐藏成功后效果如下&#xff1a;
阅读更多...
力扣第 365 场周赛虚拟参赛

力扣第 365 场周赛虚拟参赛

有序三元组中的最大值 I class Solution { public:long long maximumTripletValue(vector<int>& nums) {vector<long long> num;for (auto &item:nums) {num.push_back(item*1ll);}long long z 0,f 1000000;long long ans 0;long long maxx num[0],mi…
阅读更多...
基于SpringBoot的应急物资申请管理系统设计与实现(源码+lw+部署文档+讲解等)

基于SpringBoot的应急物资申请管理系统设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作…
阅读更多...
Git使用【上】

Git使用【上】

欢迎来到Cefler的博客&#x1f601; &#x1f54c;博客主页&#xff1a;那个传说中的man的主页 &#x1f3e0;个人专栏&#xff1a;题目解析 &#x1f30e;推荐文章&#xff1a;题目大解析3 前言 先前有些git命令我在我的其它文章里面已经写过&#xff0c;若要查看可参考【Linu…
阅读更多...
蓝桥杯每日一题2023.9.28

蓝桥杯每日一题2023.9.28

AcWing 4409. 砍竹子 - AcWing 题目描述 题目分析 注&#xff1a;sqrtl的范围为long double&#xff0c;比sqrt更加精确 使用优先队列维护一段区间&#xff0c;如果连续一段相同就合并为一个区间&#xff0c;从大到小去枚举&#xff0c;每次先取出最大的一段&#xff0c;双…
阅读更多...
Ubuntu中启动HDFS后没有NameNode解决办法

Ubuntu中启动HDFS后没有NameNode解决办法

关闭进程&#xff1a; stop-dfs.sh 格式化&#xff1a; hadoop namenode -format 出现报错信息&#xff1a; 23/10/03 22:27:04 WARN fs.FileUtil: Failed to delete file or dir [/usr/data/hadoop/tmp/dfs/name/current/fsimage_0000000000000000000.md5]: it still exi…
阅读更多...
libevent源码学习笔记

libevent源码学习笔记

libevent源码学习笔记 libevent安装libevent源码解析&#xff08;1&#xff09;事件对象&#xff08;2&#xff09;事件操作&#xff08;3&#xff09;事件循环&#xff08;4&#xff09;事件处理 常用指令问题记录问题一&#xff1a;长连接的管理问题二&#xff1a;连接关闭问…
阅读更多...
【云备份项目】：环境搭建（g++、json库、bundle库、httplib库）

【云备份项目】：环境搭建（g++、json库、bundle库、httplib库）

文章目录 1. g 升级到 7.3 版本2. 安装 jsoncpp 库3. 下载 bundle 数据压缩库4. 下载 httplib 库从 Win 传输文件到 Linux解压缩 1. g 升级到 7.3 版本 &#x1f517;链接跳转 2. 安装 jsoncpp 库 &#x1f517;链接跳转 3. 下载 bundle 数据压缩库 安装 git 工具 sudo yum…
阅读更多...
2023年中国家用智能门锁市场发展概况分析：家用智能门锁线上市场销量290.4万套[图]

2023年中国家用智能门锁市场发展概况分析：家用智能门锁线上市场销量290.4万套[图]

智能门锁是指区别于传统机械锁的基础上改进的&#xff0c;在用户安全性、识别、管理性方面更加智能化简便化的锁具。智能门锁是门禁系统中锁门的执行部件。智能门锁区别于传统机械锁, 是具有安全性, 便利性, 先进技术的复合型锁具。 智能门锁级别分类 资料来源&#xff1a;共研…
阅读更多...
Linux使用之xshell、xftp保姆教学（含安装包，详细使用方法，连接失败解决方法）

Linux使用之xshell、xftp保姆教学（含安装包，详细使用方法，连接失败解决方法）

前言 链接: FTP&#xff0c;SSH服务器介绍 这是我之前写的一篇博客&#xff0c;其中介绍了Ubuntu操作系统的一些常用命令以及服务器介绍&#xff0c;这篇文章就向大家详细介绍如何安装及应用这些服务器&#xff0c;我以xshell、xftp为例。 安装包&#xff0c;使用方法&#xf…
阅读更多...
竞赛选题 大数据商城人流数据分析与可视化 - python 大数据分析

竞赛选题 大数据商城人流数据分析与可视化 - python 大数据分析

0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 基于大数据的基站数据分析与可视化 该项目较为新颖&#xff0c;适合作为竞赛课题方向&#xff0c;学长非常推荐&#xff01; &#x1f947;学长这里给一个题目综合评分(每项满分5分) 难度…
阅读更多...
unicode/utf8/utf16/utf32笔记

unicode/utf8/utf16/utf32笔记

unicode表示的字符范围是0x0000~0x10FFFF&#xff0c;最多只需要有21位&#xff0c;但是为了字节对齐&#xff0c;所以最多需要32位(4字节) utf8/utf16/utf32都是表示unicode的一种编码方式。 utf8和utf16是变长编码&#xff0c;utf32不变长。utf-8编码长度为1&#xff0c;2&a…
阅读更多...
力扣-350.两个数组的交集||

力扣-350.两个数组的交集||

Idea 首先遍历第一个数组&#xff0c;用哈希表存储每个数字及其出现的次数。 然后遍历第二个数组&#xff0c;每出现重复的数字&#xff0c;并判断该数字在哈希表的次数是不是大于0&#xff0c;如果大于则存入答案数组&#xff0c;并将哈希表次数减1&#xff0c;直接遍历结束。…
阅读更多...
【强化学习】05 —— 基于无模型的强化学习（Prediction）

【强化学习】05 —— 基于无模型的强化学习（Prediction）

文章目录 简介蒙特卡洛算法时序差分方法Example1 MC和TD的对比偏差&#xff08;Bias&#xff09;/方差&#xff08;Variance&#xff09;的权衡Example2 Random WalkExample3 AB 反向传播(backup)Monte-Carlo BackupTemporal-Difference BackupDynamic Programming Backup Boot…
阅读更多...
（unordered）map和set封装（底层红黑树）

（unordered）map和set封装（底层红黑树）

map和set封装 文章目录 map和set封装设计问题&#xff08;知其所以然&#xff09;为什么要对iterator进行封装&#xff1f;为什么要引入Self Ref Ptr这些模板参数&#xff1f;为什么是试图从non_const转变为const&#xff0c;而不是const转为non_const如何解决 为什么说能加con…
阅读更多...
【Java 进阶篇】JDBC PreparedStatement 详解

【Java 进阶篇】JDBC PreparedStatement 详解

在Java中&#xff0c;与关系型数据库进行交互是非常常见的任务之一。JDBC&#xff08;Java Database Connectivity&#xff09;是Java平台的一个标准API&#xff0c;用于连接和操作各种关系型数据库。其中&#xff0c;PreparedStatement 是 JDBC 中一个重要的接口&#xff0c;用…
阅读更多...
FileZila 实现wind10与Linux系统文件互传

FileZila 实现wind10与Linux系统文件互传

【FileZila】实现windows与Linux系统文件互传
阅读更多...
GD32F103x IIC通信

GD32F103x IIC通信

1. IIC通信 1.IIC的介绍 IIC总线有两条串行线&#xff0c;其一是时钟线SCK&#xff08;同步&#xff09;&#xff0c;其二是数据线SDA。只有一条数据线属于半双工。应用中&#xff0c;单片机常常作为主机&#xff0c;外围器件可以挂载多个。&#xff08;当然主机也可以有多个。…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023