当前位置: 首页 > news >正文

【SpringCloud】Seata微服务事务

Seata微服务事务

  • 分布式事务问题:
    • 本地事务
    • 分布式事务
    • 演示分布式事务问题:
      • 示例1
  • 分布式事务理论
    • CAP定理
      • 一致性
      • 可用性
      • 分区容错
      • 矛盾
    • Base理论
    • 解决分布式事务的思路
  • 初识Seata
    • Seata的架构
    • 部署TC服务
    • 微服务集成Seata
      • 引入依赖
      • 配置TC地址
    • 其他服务
  • 动手实践
    • XA模式
      • 两阶段提交
      • Seata的XA模型
      • 优缺点
      • 实现XA模式
        • 示例2
    • AT模式
      • Seata的AT模型
      • AT和XA的区别:
      • 脏写问题
      • 优缺点
      • 实现AT模式
      • 示例3

分布式事务问题:

本地事务

本地事务,也就是传统的单机事务,在传统数据库事务中,必须要满⾜四个原则:

ACID原则

分布式事务

分布式事务,就是指不是在单个服务或单个数据库架构下,产⽣的事务,例如:

  • 跨数据源的分布式事务 【一个业务访问多个数据库】
  • 跨服务的分布式事务 【一个业务访问多个服务的事务】
  • 综合情况 【一个业务访问多个数据库和多个服务的事务】

在数据库⽔平拆分、服务垂直拆分之后,⼀个业务操作通常要跨多个数据库、服务才能完成。

例如电商行业中⽐较常⻅的下单付款案例,包括下面几个行为:

创建新订单—>

扣减商品库存—>

从⽤户账户余额扣除金额

订单的创建、库存的扣减、账户扣款在每⼀个服务和数据库内是⼀个本地事务,可以保证ACID原则。

但是当我们把三件事情看做⼀个"业务",要满⾜保证“ 业务” 的原⼦性,要么所有操作全部成功,要么全部失败,不允许出现部分成功部分失败的现象,这就是分布式系统下的事务了。 此时ACID难以满⾜,这是分布式事务要解决的问题。

演示分布式事务问题:

示例1

springcloud_alibaba_Seata1.rar

shop_order服务新增如下代码:

shop_product新增如下代码:

测试:

成功情况:

没有访问order/prod/0前,数据库表order没有记录,并且product表的pid为0的西游记商品的库存数量为84。

访问后:

发现新增了一条order记录,并且product表的stock由84变为了83。结合业务来说,此时的状态是成功无异常。

失败情况:

我们在product里面模拟在product表商品id为0的商品减库存时遇到异常的情况:

修改为这个,再次测试:

此时访问页面,发现报500异常:

当shop_product出现异常后,问题出现了,shop_product的id为0的stock减了,由83变为了82,并且shop_order表没有订单。

说明我们这里的事务管理没生效!

分布式事务理论

解决分布式事务问题,需要⼀些分布式系统的基础知识作为理论指导。

CAP定理

Consistency(⼀致性)

Availability(可⽤性)

Partition tolerance (分区容错性)

一致性

Consistency(⼀致性):⽤户访问分布式系统中的任意节点,得到的数据必须⼀致。 ⽐如现在包含两个节点,其中的初始数据是⼀致的:

当我们修改其中⼀个节点的数据时,两者的数据产⽣了差异:

要想保住⼀致性,就必须实现node01 到 node02的数据同步:

可用性

Availability (可用性):⽤户访问集群中的任意健康节点,必须能得到响应,⽽不是超时或拒绝。 如图,有三个节点的集群,访问任何⼀个都可以及时得到响应:

当有部分节点因为⽹络故障或其它原因⽆法访问时,代表节点不可⽤:

分区容错

Partition(分区):因为⽹络故障或其它原因导致分布式系统中的部分节点与其它节点失去连接,形成独⽴分区。

Tolerance(容错):在集群出现分区时,整个系统也要持续对外提供服务。

矛盾

在分布式系统中,系统间的⽹络不能100%保证健康,⼀定会有故障的时候,而服务有必须对外保证服务。因此Partition Tolerance不可避免。

当节点接收到新的数据变更时,就会出现问题了:

如果此时要保证⼀致性,就必须等待⽹络恢复,完成数据同步后,整个集群才对外提供服务,服务处于阻塞状态,不可用。

如果此时要保证可⽤性,就不能等待⽹络恢复,那node01、node02与node03之间就会出现数据不⼀致。

也就是说,在P⼀定会出现的情况下,A和C之间只能实现⼀个。

Base理论

BASE理论是对CAP的⼀种解决思路,包含三个思想:

  • Basically Available (基本可⽤):分布式系统在出现故障时,允许损失部分可⽤性,即保证核心可⽤。
  • Soft State(软状态):在⼀定时间内,允许出现中间状态,比如临时的不⼀致状态。
  • Eventually Consistent(最终⼀致性):虽然无法保证强⼀致性,但是在软状态结束后,最终达到数据⼀致。

解决分布式事务的思路

分布式事务最⼤的问题是各个子事务的⼀致性问题,因此可以借鉴CAP定理和BASE理论,有两种解决思路:

  • AP模式:各⼦事务分别执⾏和提交,允许出现结果不⼀致,然后采⽤弥补措施恢复数据即可,实现最终⼀致。
  • CP模式:各个⼦事务执⾏后互相等待,同时提交,同时回滚,达成强⼀致。但事务等待过程中,处于弱可⽤状态。

但不管是哪⼀种模式,都需要在⼦系统事务之间互相通讯,协调事务状态,也就是需要⼀个事务协调者 (TC):

这⾥的子系统事务,称为分⽀事务;有关联的各个分⽀事务在⼀起称为全局事务

初识Seata

Seata是 2019 年 1 ⽉份蚂蚁⾦服和阿⾥巴巴共同开源的分布式事务解决⽅案。致⼒于提供⾼性能和简单易⽤的分布式事务服务,为⽤户打造⼀站式的分布式解决⽅案。 官⽹地址:http://seata.io/,其中的⽂档、播客中提供了大量的使用说明、源码分析。

Seata的架构

Seata事务管理中有三个重要的角色:

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

整体的架构如图:

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

  • XA模式:强⼀致性分阶段事务模式,牺牲了⼀定的可用性,⽆业务侵入。
  • TCC模式:最终⼀致的分阶段事务模式,有业务侵入。
  • AT模式:最终⼀致的分阶段事务模式,⽆业务侵入,也是Seata的默认模式。
  • SAGA模式:⻓事务模式,有业务侵入

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

部署TC服务

1.⾸先我们要下载seata-server包,地址在http://seata.io/zh-cn/blog/download.html

seata-server-1.4.2.zip

2.解压

3.修改配置:conf目录下的registry.conf文件:

registry {# file 、nacos 、eureka、redis、zk、consul、etcd3、sofatype = "nacos"nacos {application = "seata-tc-server"serverAddr = "127.0.0.1:8848"group = "DEFAULT_GROUP"namespace = ""cluster = "SH"username = "nacos"password = "nacos"}eureka {serviceUrl = "http://localhost:8761/eureka"application = "default"weight = "1"}redis {serverAddr = "localhost:6379"db = 0password = ""cluster = "default"timeout = 0}zk {cluster = "default"serverAddr = "127.0.0.1:2181"sessionTimeout = 6000connectTimeout = 2000username = ""password = ""}consul {cluster = "default"serverAddr = "127.0.0.1:8500"aclToken = ""}etcd3 {cluster = "default"serverAddr = "http://localhost:2379"}sofa {serverAddr = "127.0.0.1:9603"application = "default"region = "DEFAULT_ZONE"datacenter = "DefaultDataCenter"cluster = "default"group = "SEATA_GROUP"addressWaitTime = "3000"}file {name = "file.conf"}
}config {# file、nacos 、apollo、zk、consul、etcd3type = "nacos"nacos {serverAddr = "127.0.0.1:8848"namespace = ""group = "SEATA_GROUP"username = "nacos"password = "nacos"dataId = "seataServer.properties"}consul {serverAddr = "127.0.0.1:8500"aclToken = ""}apollo {appId = "seata-server"## apolloConfigService will cover apolloMetaapolloMeta = "http://192.168.1.204:8801"apolloConfigService = "http://192.168.1.204:8080"namespace = "application"apolloAccesskeySecret = ""cluster = "seata"}zk {serverAddr = "127.0.0.1:2181"sessionTimeout = 6000connectTimeout = 2000username = ""password = ""nodePath = "/seata/seata.properties"}etcd3 {serverAddr = "http://localhost:2379"}file {name = "file.conf"}
}

服务端配置⽂件seataServer.properties⽂件需要在nacos中配。

# 数据存储⽅式,db代表数据库
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://seata?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&useSSL=true
store.db.user=root
store.db.password=12345678
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

5.创建数据库

这些表主要记录全局事务、分⽀事务、全局锁信息:

 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 NULLDEFAULT 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;

6.启动TC服务:进⼊bin⽬录,运⾏其中的seata-server.bat即可默认端⼝为8091

或者运⾏指令指定端⼝:seata-server.bat -p 9000 -m file

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

微服务集成Seata

引入依赖

<!-- seata --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><exclusions><exclusion><artifactId>seata-spring-boot-starter</artifactId><groupId>io.seata</groupId></exclusion></exclusions></dependency><dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><!--seata starter 采⽤1.4.2版本--><version>1.4.2</version></dependency>

配置TC地址

在订单服务中的application.yml中,配置TC服务信息,通过注册中心nacos,结合服务名称获取TC地址:

seata:registry: # TC服务注册中心的配置,微服务根据这些信息去注册中心获取tc服务地址type: nacos # 注册中心类型 nacosnacos:server-addr: 127.0.0.1:8848 # nacos地址namespace: "" # namespace,默认为空group: DEFAULT_GROUP # 分组,默认是DEFAULT_GROUPapplication: seata-tc-server # seata服务名称username: nacospassword: nacostx-service-group: seata-demo # 事务组名称service:vgroup-mapping: # 事务组与cluster的映射关系seata-demo: SH

微服务如何根据这些配置寻找TC的地址呢? 我们知道注册到Nacos中的微服务,确定⼀个具体实例需要四个信息:

  • namespace:命名空间
  • group:分组
  • application:服务名
  • cluster:集群名

以上四个信息,在刚才的yaml⽂件中都能找到。

其他服务

其它微服务也都参考订单服务的步骤来做,完全⼀样。

动手实践

Seata中的四种不同的事务模式。

XA模式

XA 规范 是 X/Open 组织定义的分布式事务处理(DTP,Distributed Transaction Processing)标准, XA 规范 描述了全局的TM与局部的RM之间的接口,几乎所有主流的数据库都对 XA规范提供了⽀持。

两阶段提交

XA是规范,⽬前主流数据库都实现了这种规范,实现的原理都是基于两阶段提交。

正常情况:

异常情况:

⼀阶段:

  • 事务协调者通知每个事物参与者执⾏本地事务
  • 本地事务执⾏完成后报告事务执⾏状态给事务协调者,此时事务不提交,继续持有数据库锁

⼆阶段:

  • 事务协调者基于⼀阶段的报告来判断下⼀步操作
    • 如果⼀阶段都成功,则通知所有事务参与者,提交事务
    • 如果⼀阶段任意⼀个参与者失败,则通知所有事务参与者回滚事务

Seata的XA模型

Seata对原始的XA模式做了简单的封装和改造,以适应⾃⼰的事务模型,基本架构如图:

RM⼀阶段的⼯作:

  • 注册分⽀事务到TC
  • 执⾏分⽀业务sql但不提交
  • 报告执⾏状态到TC

TC⼆阶段的⼯作:

  • TC检测各分⽀事务执⾏状态
  • 如果都成功,通知所有RM提交事务
  • 如果有失败,通知所有RM回滚事务

RM⼆阶段的⼯作:

  • 接收TC指令,提交或回滚事务

优缺点

XA模式的优点是什么?

  • 事务的强⼀致性,满⾜ACID原则。
  • 常⽤数据库都⽀持,实现简单,并且没有代码侵⼊。

XA模式的缺点是什么?

  • 因为⼀阶段需要锁定数据库资源,等待⼆阶段结束才释放,性能较差。
  • 依赖关系型数据库实现事务。

实现XA模式

Seata的starter已经完成了XA模式的⾃动装配,实现⾮常简单,步骤如下:

1)修改application.yml⽂件(每个参与事务的微服务),开启XA模式:

seata:registry: # TC服务注册中心的配置,微服务根据这些信息去注册中心获取tc服务地址type: nacos # 注册中心类型 nacosnacos:server-addr: 127.0.0.1:8848 # nacos地址namespace: "" # namespace,默认为空group: DEFAULT_GROUP # 分组,默认是DEFAULT_GROUPapplication: seata-tc-server # seata服务名称username: nacospassword: nacostx-service-group: seata-demo # 事务组名称service:vgroup-mapping: # 事务组与cluster的映射关系seata-demo: SHdata-source-proxy-mode: XA

2)给发起全局事务的⼊⼝⽅法添加@GlobalTransactional注解:

本例中是OrderServiceImpl中的create方法。

3)重启服务并测试 重启order-service,再次测试,发现无论怎样,微服务都能成功回滚。

示例2

修改pom和配置文件

<!-- seata --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><exclusions><exclusion><artifactId>seata-spring-boot-starter</artifactId><groupId>io.seata</groupId></exclusion></exclusions></dependency><dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><!--seata starter 采⽤1.4.2版本--><version>1.4.2</version></dependency>

shop_order

seata:registry: # TC服务注册中心的配置,微服务根据这些信息去注册中心获取tc服务地址type: nacos # 注册中心类型 nacosnacos:server-addr: 127.0.0.1:8848 # nacos地址namespace: "" # namespace,默认为空group: DEFAULT_GROUP # 分组,默认是DEFAULT_GROUPapplication: seata-tc-server # seata服务名称username: nacospassword: nacostx-service-group: seata-demo # 事务组名称service:vgroup-mapping: # 事务组与cluster的映射关系seata-demo: SHdata-source-proxy-mode: XA

shop_product

修改代码

shop_order

shop_product

测试:

修改代码,测试没有出现异常的情况,模拟正常下单:

修改代码,重启服务,模拟出现异常的情况:

发现⽆论怎样,微服务都能成功回滚。说明XA模式生效!

AT模式

AT模式同样是分阶段提交的事务模型,不过缺弥补了XA模型中资源锁定周期过长的缺陷。

Seata的AT模型

基本流程图:

阶段⼀RM的⼯作:

  • 注册分⽀事务
  • 记录undo-log(数据快照)
  • 执⾏业务sql并提交
  • 报告事务状态

阶段二提交时RM的⼯作:

  • 删除undo-log即可

阶段二回滚时RM的⼯作:

  • 根据undo-log恢复数据到更新前

AT和XA的区别:

简述AT模式与XA模式最⼤的区别是什么?

  • XA模式⼀阶段不提交事务,锁定资源;AT模式⼀阶段直接提交,不锁定资源。
  • XA模式依赖数据库机制实现回滚;AT模式利⽤数据快照实现数据回滚。
  • XA模式强⼀致;AT模式最终⼀致

脏写问题

在多线程并发访问AT模式的分布式事务时,有可能出现脏写问题,如图:

解决思路就是引⼊了全局锁的概念在释放DB锁之前,先拿到全局锁,避免同⼀时刻有另外⼀个事务来操作当前数据。

优缺点

AT模式的优点:

  • ⼀阶段完成直接提交事务,释放数据库资源,性能比较好
  • 利⽤全局锁实现读写隔离
  • 没有代码侵⼊,框架⾃动完成回滚和提交

AT模式的缺点:

  • 两阶段之间属于软状态,属于最终⼀致
  • 框架的快照功能会影响性能,但比XA模式要好很多

实现AT模式

AT模式中的快照⽣成、回滚等动作都是由框架⾃动完成,没有任何代码侵⼊,因此实现非常简单。

只不过,AT模式需要⼀个表来记录全局锁、另⼀张表来记录数据快照undo_log。

1)导⼊数据库表,记录全局锁 运行seata-at.sql,其中lock_table导⼊到TC服务关联的数据库,undo_log表导⼊到微服务关联的数据库:

DROP TABLE IF EXISTS `lock_table`;
CREATE TABLE `lock_table`  (`row_key` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`xid` varchar(96) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`branch_id` bigint(20) NOT NULL,`resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`table_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`pk` varchar(36) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime NULL DEFAULT NULL,`gmt_modified` datetime NULL DEFAULT NULL,PRIMARY KEY (`row_key`) USING BTREE,INDEX `idx_branch_id`(`branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;SET FOREIGN_KEY_CHECKS = 1;

如果分库分表,则各个服务的表都需要添加这个表:

DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log`  (`branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',`xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'global transaction id',`context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'undo_log context,such as serialization',`rollback_info` longblob NOT NULL COMMENT 'rollback info',`log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',`log_created` datetime(6) NOT NULL COMMENT 'create datetime',`log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = 'AT transaction mode undo table' ROW_FORMAT = Compact;

2)修改application.yml⽂件,将事务模式修改为AT模式即可:

seata:data-source-proxy-mode: AT # 默认就是AT

3)重启服务并测试。发现⽆论怎样,微服务都能成功回滚,说明配置成功!

示例3

其余的不变,修改两个项目的yaml文件

导入sql文件,运⾏seata-at.sql,其中lock_table导⼊到TC服务关联的数据库,undo_log表导⼊到微服务关联的数据库:

/*Navicat Premium Data TransferSource Server         : localSource Server Type    : MySQLSource Server Version : 50622Source Host           : localhost:3306Target Server Type    : MySQLTarget Server Version : 50622File Encoding         : 65001*/SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- Table structure for undo_log
-- ----------------------------
DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log`  (`branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',`xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'global transaction id',`context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'undo_log context,such as serialization',`rollback_info` longblob NOT NULL COMMENT 'rollback info',`log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',`log_created` datetime(6) NOT NULL COMMENT 'create datetime',`log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = 'AT transaction mode undo table' ROW_FORMAT = Compact;-- ----------------------------
-- Records of undo_log
-- ------------------------------ ----------------------------
-- Table structure for lock_table
-- ----------------------------
DROP TABLE IF EXISTS `lock_table`;
CREATE TABLE `lock_table`  (`row_key` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`xid` varchar(96) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`branch_id` bigint(20) NOT NULL,`resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`table_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`pk` varchar(36) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime NULL DEFAULT NULL,`gmt_modified` datetime NULL DEFAULT NULL,PRIMARY KEY (`row_key`) USING BTREE,INDEX `idx_branch_id`(`branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;SET FOREIGN_KEY_CHECKS = 1;

重启服务进行测试:

首先模拟出现异常的情况:

此时查看数据库

再次模拟正常的情况:

这时查看数据库,可得:

发现⽆论怎样,微服务都能成功回滚,说明AT模式生效!

相关文章:

【SpringCloud】Seata微服务事务

Seata微服务事务 分布式事务问题&#xff1a;本地事务分布式事务演示分布式事务问题&#xff1a;示例1 分布式事务理论CAP定理一致性可用性分区容错矛盾 Base理论解决分布式事务的思路 初识SeataSeata的架构部署TC服务微服务集成Seata引入依赖配置TC地址 其他服务 动手实践XA模…...

重新阅读《马说》,感悟“伯乐相马”背后的被选择与选择的大智慧

“初闻不识曲中意&#xff0c;再听已是曲终人”。世有伯乐&#xff0c;然后有千里马。千里马常有&#xff0c;而伯乐不常有。无论你是考研考公等考试大军中的一员&#xff0c;还是已步入社会的打工人或者领导&#xff0c;当你面临被人选择或者选择人时&#xff0c;皆可从《马说…...

深入拆解TomcatJetty(三)

深入拆解Tomcat&Jetty&#xff08;三&#xff09; 专栏地址&#xff1a;https://time.geekbang.org/column/intro/100027701 1 Tomcat组件生命周期 Tomcat如何如何实现一键式启停 Tomcat 架构图和请求处理流程如图所示&#xff1a; 对组件之间的关系进行分析&#xff0c;…...

MySQL 实现简单的性能优化

一&#xff1a;硬件优化 更高的网络带宽&#xff1a;在处理大规模的远程请求时可以提高MySQL服务器的响应速度&#xff1b; 更大的内存空间&#xff1a;有助于缓存更多的数据库数据&#xff0c;减少磁盘I/O操作&#xff0c;提高整体性能&#xff1b; 换用企业级SSD&#xff1…...

AB包资源管理器

简介 ABMgr&#xff08;Asset Bundle Manager&#xff09;类是一个用于管理 Unity 中 AssetBundle 资源加载的管理器。它通过字典缓存和管理加载的 AB 包&#xff0c;同时支持同步和异步加载。还包含了卸载和清理 AB 包的方法。 功能解析&#xff1a; 主包加载与依赖管理&…...

Centos7源报错问题

原因&#xff1a;是因为centos7在024年6月份停止维护&#xff0c;导致默认镜像不能使用&#xff0c;更改镜像即可mv /etc/yum.repos.d/CentOS-Base.repo /etc/yum.repos.d/CentOS-Base.repo.backup curl -o /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/…...

Openlayers高级交互(2/20):清除所有图层的有效方法

Openlayers项目中&#xff0c;经常会放置很多的图层&#xff0c;在业务操作的时候&#xff0c;会做出删除所有图层的行为。这里面给出了一个详细的方法&#xff0c;能够有效的解决 清除所有图层的问题。 效果图 专栏名称内容介绍Openlayers基础实战 &#xff08;72篇&#xff…...

黑马JavaWeb-day02

什么是JavaScript&#xff1f; JavaScript&#xff1a;简称Js,是一门跨平台、面向对象的脚本语言。是用来控制网页行为的&#xff0c;它能使网页可交互 JavaScript和Java是完全不同的语言&#xff0c;无论是概念还是设计。但是基础语法类似。 JavaScript JavaScript引入方式…...

laravel清除不同缓存

1、清除应用程序缓存&#xff1a; php artisan cache:clear2、清除路由缓存&#xff1a; php artisan route:cache3、清除配置缓存&#xff1a; php artisan config:cache4、清除编译后的视图文件&#xff1a; php artisan view:clear5、清除事件和监听器缓存&#xff1a; ph…...

【Git】解决分支冲突、分支合并、版本回退、版本管理

解决本地冲突 1. 合并分支 假设你正在 main 分支上&#xff0c;想要合并 feature 分支。 git checkout main git merge feature如果两个分支都对同一文件做了不同的修改&#xff0c;Git 会提示你有冲突&#xff0c;并显示冲突文件。 2. 查看冲突文件 使用以下命令查看冲突…...

linux file结构体与inode结构体

在 Linux 系统中&#xff0c;inode 结构体和 file 结构体都是与文件系统相关的重要数据结构。它们各自承担着不同的角色&#xff0c;帮助操作系统管理文件和目录。以下是它们的异同点&#xff1a; inode 结构体 1.定义&#xff1a;inode&#xff08;索引节点&#xff09;是文件…...

探索迷宫的奥秘:用 C++ 打造你的迷宫游戏之旅!

✅作者简介&#xff1a;2022年博客新星 第八。热爱国学的Java后端开发者&#xff0c;修心和技术同步精进。 &#x1f34e;个人主页&#xff1a;Java Fans的博客 &#x1f34a;个人信条&#xff1a;不迁怒&#xff0c;不贰过。小知识&#xff0c;大智慧。 &#x1f49e;当前专栏…...

JSON 注入攻击 API

文章目录 JSON 注入攻击 API"注入所有东西"是"聪明的"发生了什么? 什么是 JSON 注入?为什么解析器是问题所在解析不一致 JSON 解析器互操作性中的安全问题处理重复密钥的方式不一致按键碰撞响应不一致JSON 序列化(反序列化)中的不一致 好的。JSON 解析器…...

MyBatis入门程序之客户添加、更新与删除

【图书介绍】《SpringSpring MVCMyBatis从零开始学&#xff08;视频教学版&#xff09;&#xff08;第3版&#xff09;》-CSDN博客 《SpringSpring MVCMyBatis从零开始学 视频教学版 第3版整合开发实战快速开发与项目实战框架技术精讲与整合案例 计算机与互联网 编程语言与程序…...

查缺补漏----数据结构树高总结

① 对于平衡二叉树而言&#xff0c;树高的规律&#xff1a; 高度为h的平衡二叉树的含有的最少结点数&#xff08;所有非叶节点的平衡因子均为1&#xff09;&#xff1a; n01&#xff0c;n11&#xff0c;n22 含有的最多结点数&#xff1a; (高度为h的满二叉树含有的结点数) ②…...

jenkins添加新服务

jenkins添加新服务 新建item 添加流水线 node{def envname "ENVIRONMENT:1234-dev"def projectGitUrl http://xxxxx/xxxxxx/12345.gitdef imageServer harbor.xxxxx.com //镜像仓库地址def projectAppName 12345-applicationdef projectGitBranch dev//git分…...

网络连接设备的功能与应用概述

目录 一、集线器 二、交换机 三、网桥 四、路由器 五、集线器、交换机、网桥与路由器的比较 备注 一、集线器 定义&#xff1a; 集线器&#xff08;Hub&#xff09;是一种物理层设备&#xff0c;它提供多个端口&#xff0c;用于将多个计算机或其他网络设备连接在一起&am…...

【SpringCloud】04-Gateway网关登录校验

1. 网关请求处理流程 2. 网关过滤器 3. 网关实现登录校验 Component // 参数构造器 RequiredArgsConstructor public class AuthGlobalFilter implements GlobalFilter, Ordered {private final AuthProperties authProperties;private final JwtTool jwtTool;private final A…...

FFmpeg 库的简要说明

FFmpeg 库的简要说明&#xff1a; libavutil 功能&#xff1a;提供一系列通用工具函数&#xff0c;旨在简化开发流程。 主要用途&#xff1a; 随机数生成器&#xff1a;用于生成随机数&#xff0c;适用于各种应用。 数据结构&#xff1a;提供常用的数据结构&#xff08;如链表…...

Go:error处理机制

文章目录 本篇总结的是Go中对于错误的处理机制 Go 语言的函数经常使用两个返回值来表示执行是否成功&#xff1a;返回某个值以及 true 表示成功&#xff1b;返回零值&#xff08;或 nil&#xff09;和 false 表示失败 而实际上来说&#xff0c;是需要对于第二个参数进行判断的…...

Python机器学习中的主成分分析(PCA)全面解析与应用

&#x1f3af; Python机器学习中的主成分分析&#xff08;PCA&#xff09;全面解析与应用 &#x1f4d6; 目录 &#x1f31f; 主成分分析 (PCA) 的概念和原理&#x1f50e; PCA的数学基础&#x1f6e0; Python 实现 PCA 的步骤详解&#x1f4ca; 如何选择适合的主成分数量⚙️…...

MySQL 安装和基本使用

MySQL 介绍 MySQL 的特性 MySQL 是基于开源协议发布的&#xff0c;可以免费使用&#xff0c;也可以基于源码进行二次开发。 MySQL 使用标准 SQL 语言进行管理。 MySQL 可以运行于多个系统上&#xff0c;具有跨平台特性&#xff0c;并且支持多种语言。 MySQL 使用插件式存储…...

RequestBody接收参数报错com.fasterxml.jackson.databind.exc.MismatchedInputException

目录&#xff1a; 1、错误现象2、解决办法3、最终验证 1、错误现象 报错的现象和代码如下&#xff1a; 2、解决办法 查了很多都说参数类型对不上&#xff0c;最后只有换接收方式后验证是可以的&#xff1b;最终想了一下&#xff0c;觉得是请求的是json&#xff0c;需要用json接…...

大数据治理的关键技术:构建稳固的数据基石

在这个信息爆炸的时代&#xff0c;数据已经成为企业最宝贵的资产之一。然而&#xff0c;随着数据量的爆炸性增长&#xff0c;如何有效治理这些数据成为了一个巨大的挑战。今天&#xff0c;我们就来聊聊大数据治理的关键技术&#xff0c;看看如何构建一个稳固的数据基石&#xf…...

OS管理和进程的学习

1.冯诺依曼体系结构 1.1 输入设备&#xff1a;键盘&#xff0c;鼠标&#xff0c;键盘&#xff0c;网卡&#xff08;网络接受&#xff09;&#xff0c;磁盘... 输出设备&#xff1a;显示器&#xff0c;磁盘&#xff0c;网卡&#xff08;网络发送&#xff09; .... 存储器&…...

Linux 部署 Harbor 镜像仓库详解

文章目录 安装 Docker安装 Harbor访问 Harbor 安装 Docker 本次部署流程使用的是1台阿里云ECS&#xff0c;Ubuntu 22.04&#xff0c;2核4G。 首先需要做的是在当前服务器上&#xff0c;安装好 Docker&#xff0c;参考链接如下&#xff1a; https://blog.csdn.net/weixin_4659…...

怎么把flv格式转换成mp4?将flv格式换成MP4格式的简单方法

怎么把flv格式转换成mp4&#xff1f;flv这一昔日网络视频领域的璀璨明星&#xff0c;凭借其小巧的文件体积与卓越的流媒体传输性能&#xff0c;曾在网络视频时代初期大放异彩&#xff0c;成为无数网络视频爱好者的首选。然而&#xff0c;随着科技的日新月异与多媒体设备的多元化…...

原型模式和建造模式的区别

原型模式&#xff08;Prototype Pattern&#xff09;和建造者模式&#xff08;Builder Pattern&#xff09;虽然都是创建型设计模式&#xff0c;但它们的应用场景和实现方式有着显著的区别。以下是二者的详细对比&#xff1a; 1. 意图和应用场景 原型模式&#xff1a; 意图&a…...

最新 client-java 调用 k8s ApiServer

创建权限绑定 sa-role.yaml apiVersion: v1 kind: ServiceAccount metadata:name: my-admin #账号名namespace: kube-system--- apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata:annotations:rbac.authorization.kubernetes.io/autoupdate: "true…...

TCP单包数据大于1460字节会被拆包的问题

关于TCP单包数据大于1460字节会被拆包的问题 1、问题背景&#xff1a; 最近在用STM32W5500做项目&#xff0c;需要STM32通过TCP协议发送数据到上位机并显示。当数据量小的时候上位机显示正常&#xff0c;一旦数据量大过大上位机就会出现数据丢失的情况&#xff0c;甚至数据直接…...