Java之SpringCloud Alibaba【六】【Alibaba微服务分布式事务组件—Seata】

一、事务简介

事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元(unit)。
在关系数据库中，一个事务由一组SQL语句组成。

事务应该具有4个属性:

原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

原子性(atomicity) ∶个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。
一致性(consistency) ∶事务必须是使数据库从一个一致性状态变到另一个一致性状态，事务的中间状态不能被观察到的。

隔离性（(isolation):一个事务的执行不能被其他事务干扰。
即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。

隔离性又分为四个级别:
读未提交(read uncommitted)、
读已提交(read committed，解决脏读)、
可重复读(repeatable read，解决虚读)、
串行化(serializable，解决幻读)。

持久性(durability):持久性也称永久性(permanence)，指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。

接下来的其他操作或故障不应该对其有任何影响。

任何事务机制在实现时，都应该考虑事务的ACID特性，包括:本地事务、分布式事务，及时不能都很好的满足，也要考虑支持到什么程度。

二、本地事务

@Transaction

大多数场景下，我们的应用都只需要操作单一的数据库，这种情况下的事务称之为本地事务(Local Transaction)。

本地事务的ACID特性是数据库直接提供支持。
本地事务应用架构如下所示:

在这里插入图片描述
在JDBC编程中，我们通过java.sql.Connection对象来开启、关闭或者提交事务。

代码如下所示:

Connection conn = .../获取数据库连接
conn.setAutoCommit(false);//开启事务
try{//...执行增删改查sqlconn.commit();//提交事务
}catch (Exception e){conn.rollback( );//事务回滚
}finally{conn.close();//关闭链接
}

三、分布式事务

1、分布式事务Seata使用

Seatas是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。

Seata将为用户提供了AT、TCC、SAGA和XA事务模式，为用户打造一站式的分布式解决方案。

AT模式是阿里首推的模式,阿里云上有商用版本的GTS (Global Transaction Service 全局事务服务)
官网: https://seata.io/zh-cn/index.html
源码: https://github.com//seata//seata
官方Demo: https://github.com/seata/seata-samples
seata版本: v1.4.0

（1）Seata的三大角色

在Seata的架构中，一共有三个角色:

TC(Transaction Coordinator)-事务协调者
维护全局和分支事务的状态，驱动全局事务提交或回滚。

TM (Transaction Manager)-事务管理器
定义全局事务的范围:开始全局事务、提交或回滚全局事务。

RM(Resource Manager)-资源管理器
管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

其中，TC为单独部署的Server服务端，TM和RM为嵌入到应用中的 Client客户端。

在Seata 中，一个分布式事务的生命周期如下:

常见分布式事务解决方案
1、seata阿里分布式事务框架
2、消息队列
3、saga
4、XA
他们有一个共同点，都是"两阶段(2PC)。
"两阶段"是指完成整个分布式事务，划分成两个步骤完成。

实际上，这四种常见的分布式事务解决方案，分别对应着分布式事务的四种模式:

AT、TCC、Saga、XA;
四种分布式事务模式，都有各自的理论基础，分别在不同的时间被提出每种模式都有它的适用场景，同样每个模式也都诞生有各自的代表产品;

而这些代表产品，可能就是我们常见的(全局事务、基于可靠消息、最大努力通知、TCC)。

今天，我们会分别来看4种模式(AT、TCC、Saga、XA)的分布式事务实现。在看具体实现之前，先讲下分布式事务的理论基础。

分布式事务理论基础

解决分布式事务，也有相应的规范和协议。分布式事务相关的协议有2PC、3PC。

由于三阶段提交协议X3PC非常难实现，目前市面主流的分布式事务解决方案都是2PC协议。

这就是文章开始提及的常见分布式事务解决方案里面那些列举的都有一个共同点"两阶段"的内在原因。

有些文章分析2PC时，几乎都会用TCC两阶段的例子，第一阶段try，第二阶段完成confirm或cancel。其实2PC并不是专为实现TCC设计的,2PC具有普适性。

——协议一样的存在，目前绝大多数分布式解决方案都是以两阶段提交协议2PC为基础的。

TCC (Try-Confirm-Cancel)实际上是服务化的两阶段提交协议。

（2）Seata的三大角色2PC两阶段提交协议:

2PC(两阶段提交，Two-Phase Commit)
顾名思义，分为两个阶段:
Prepare和CommitPrepare:提交事务请求
基本流程如下图:

在这里插入图片描述
在这里插入图片描述
1.询问协调者向所有参与者发送事务请求，询问是否可执行事务操作，然后等待各个参与者的响应。

2.执行各个参与者接收到协调者事务请求后，执行事务操作(例如更新一个关系型数据库表中的记录)，并将Undo和Redo 信息记录事务日志中。

3.响应如果参与者成功执行了事务并写入Undo和Redo信息，则向协调者返回YES响应，否则返回NO响应。当然，参与者也可能宕机，从而不会返回响应。

（3）中断事务

在执行Prepare步骤过程中，如果某些参与者执行事务失败、宕机或与协调者之间的网络中断，那么协调者就无法收到所有参与者的YES响应，或者某个参与者返回了No响应，此时，协调者就会进入回退流程，对事务进行回退。

流程如下图红色部分(将Commit请求替换为红色的Rollback请求):

2、2PC的问题

1.同步阻塞参与者在等待协调者的指令时，其实是在等待其他参与者的响应，在此过程中，参与者是无法进行其他操作的，也就是阻塞了其运行。
倘若参与者与协调者之间网络异常导致参与者一直收不到协调者信息，那么会导致参与者一直阻塞下去。

2.单点在2PC中，一切请求都来自协调者，所以协调者的地位是至关重要的，如果协调者宕机，那么就会使参与者一直阻塞并一直占用事务资源。

如果协调者也是分布式，使用选主方式提供服务，那么在一个协调者挂掉后，可以选取另一个协调者继续后续的服务，可以解决单点问题。
但是，新协调者无法知道上一个事务的全部状态信息(例如已等待Prepare响应的时长等)，所以也无法顺利处理上一个事务。

3.数据不一致Commit事务过程中Comit请求Roltack请求可能因为协调者宕机或协调者与参与者网络问题丢失，那么就导致了部分参与者没有收到Conmit/Rollback请求，而其他参与者则正常收到执行了CommitRollback操作，没有收到请求的参与者则继续阻塞。

这时，参与者之间的数据就不再一致了。当参与者执行ComitRollack后会向协调者发送Ack，然而协调者不论是否收到所有的参与者的Ack，该事务也不会再有其他补救措施了，协调者能做的也就是等待超时后像事务发起者返回一个“我不确定该事务是否成功”。

4.环境可靠性依赖

协调者Prepare请求发出后，等待响应，然而如果有参与者宕机或与协调者之间的网络中断，都会导致协调者无法收到所有参与者的响应那么在2PC中，协调者会等待一定时间，然后超时后，会触发事务中断，在这个过程中协调者和所有其他参与者都是出于阻塞的。

这种机制对网络问题常见的现实环境来说太苛刻了。

下面我们分别来看4种模式(AT、TCC、Saga、XA)的分布式事务实现。

3、AT模式

AT模式是一种无侵入的分布式事务解决方案。
阿里Seata框架，实现了该模式。

在AT模式下，用户只需关注自己的"业务SQL"，用户的“业务SQL”作为一阶段，Seata 框架会自动生成事务的二阶段提交和回滚操作。
在这里插入图片描述
AT模式如何做到对业务的无侵入:

  • 一阶段

在一阶段，Seata会拦截业务SQL"，首先解析SQL语义，找到业务SQL要更新的业务数据，在业务数据被更新前，将其保存成"before image”，然后执行"业务SQL"更新业务数据，在业务数据更新之后，再将其保存成"after image”，最后生成行锁。

以上操作全部在一个数据库事务内完成，这样保证了一阶段操作的原子性。

在这里插入图片描述

  • 二阶段提交:

二阶段如果是提交的话，因为"业务SQL"在一阶段已经提交至数据库，
所以Seata 框架只需将一阶段保存的快照数据和行锁删掉，完成数据清理即可。
在这里插入图片描述

  • 二阶段回滚:

二阶段如果是回滚的话，Seata就需要回滚一阶段已经执行的业务SQL”，还原业务数据。

回滚方式便是用"before image"还原业务数据;但在还原前要首先要校验脏写，对比"数据库当前业务数据"和"after image"，如果两份数据完全一致就说明没有脏写，可以还原业务数据，如果不一致就说明有脏写，出现脏写就需要转人工处理。

在这里插入图片描述AT模式的一阶段、二阶段提交和回滚均由Seata框架自动生成，用户只需编写业务SQL”，便能轻松接入分布式事务，AT模式是一种对业务无任何侵入的分布式事务解决方案。

4、TCC模式

TCC模式需要用户根据自己的业务场景实现
Try、Confim和Cancel 三个操作;

事务发起方在一阶段执行Try方式，在二阶段提交执行Confim方法，二阶段回滚执行Cancel方法。
在这里插入图片描述缺点：侵入性比较强，并且得自己实现相关的事务控制逻辑。
优点：在整个过程当中，基本没有锁的概念，性能更加强大。
在这里插入图片描述

5、MQ【可靠消息最终一致性方案】

在这里插入图片描述

四、Seata的三大角色

1、在Seata的架构中，一共有三个角色:

TC (Transaction Coordinator)-事务协调者

维护全局和分支事务的状态，驱动全局事务提交或回滚。

TM (Transaction Manager)-事务管理器

定义全局事务的范围:开始全局事务、提交或回滚全局事务。

RM(Resource Manager)-资源管理器

管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

其中，TC为单独部署的Server服务端，TM和RM为嵌入到应用中的Client客户端。

在Seata 中，一个分布式事务的生命周期如下:

在这里插入图片描述
1.TM请求TC开启一个全局事务。

TC会生成一个XID作为该全局事务的编号。XID，会在微服务的调用链路中传播，保证将多个微服务的子事务关联在一起。

2.RM请求TC将本地事务注册为全局事务的分支事务，通过全局事务的XID进行关联。

3.TM请求TC告诉XID对应的全局事务是进行提交还是回滚。

4.TC驱动RM们将XID 对应的自己的本地事务进行提交还是回滚。

2、设计思路

AT模式的核心是对业务无侵入，是一种改进后的两阶段提交，其设计思路如图

第一阶段

业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。

核心在于对业务sql进行解析，转换成undolog，并同时入库，这是怎么做的呢?

先抛出一个概念DataSourceProxy代理数据源，通过名字大家大概也能基本猜到是什么个操作，后面做具体分析

参考官方文档:

https://seata.io/zh-cn/docs/dev/mode/at-mode.html

在这里插入图片描述分布式事务操作失败，TM向TC发送回滚请求，RIM收到协调器TC发来的回滚请求，通过XD和Branch lD找到相应的回滚日志记录，通过回滚记录生成反向的更新SQL并执行，以完成分支的回滚。

在这里插入图片描述
在这里插入图片描述相比与其它分布式事务框架，Seata架构的亮点主要有几个:

1.应用层基于SQL解析实现了自动补偿，从而最大程度的降低业务侵入性;
2.将分布式事务中TC(事务协调者）独立部署，负责事务的注册、回滚;
3.通过全局锁实现了写隔离与读隔离。

3、存在问题

性能损耗
一条Update的SQL，则需要全局事务xd获取（与TC通讯) 、before image(解析SQL，查询一次数据库) 、after image(查询一次数据库)、inser undo log(写一次数据库) 、before commit (与TC通讯，判断锁冲突)，这些操作都需要一次远程通讯RPC，而且是同步的。

另外undo log写入时blob字段的插入性能也是不高的。

每条写SQL都会增加这么多开销,粗略估计会增加5倍响应时间。

性价比
为了进行自动补偿，需要对所有交易生成前后镜像并持久化，可是在实际业务场景下，这个是成功率有多高，或者说分布式事务失败需要回滚的有多少比率?

按照二八原则预估，为了20%的交易回滚，需要将80%的成功交易的响应时间增加5倍，这样的代价相比于让应用开发一个补偿交易是否是值得?

全局锁
热点数据
相比:(XA，Seata 虽然在一阶段成功后会释放数据库锁，但一阶段在comit前全局锁的判定也拉长了对数据锁的占有时间，这个开销比XA的prepare低多少需要根据实际业务场景进行测试。

全局锁的引入实现了隔离性，但带来的问题就是阻塞，降低并发性，尤其是热点数据，这个问题会更加严重。

回滚锁释放时间

五、Seata快速开始

1、Seata Server (TC)环境搭建

https://seata.io/zh-cn/docslops/deploy-guide-beginner.html

Server端存储模式(store.mode）支持三种:

  • file:单机模式，全局事务会话信息内存中读写并持久化本地文件root.data，性能较高(默认)
  • db:高可用模式，全局事务会话信息通过db共享，相应性能差些
    • 打开config/file.conf
    • 修改mode="db"
    • 修改数据库链接信息（URL\USERNAME\PASSWORD）
  • redis: Seata-Server 1.3及以上版本支持,性能较高,存在事务信息丢失风险,请提前配置适合当前场景的redis持久化配置

资源目录: https://github.com/seata/seata/tree/1.3.0/script

  • client
    存放client端sql脚本，参数配置
  • config-center
    各个配置中心参数导入脚本，config.txt(包含server和client，原名nacos-config.txt)为通用参数文件
  • server
    server端数据库脚本及各个容器配置

db存储模式+Nacos(注册&配置中心)部署

步骤一:下载安装包
https://github.com/seata/seata/releases

在这里插入图片描述
在这里插入图片描述

2、建表（仅db模式）

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

global_table、branch_table、lock_table

创建数据库seata，执行sql脚本，文件在script/server/db/mysql.sql (seata源码）中

https://github.com/seata/seata/tree/2.x/script/server/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);

导入数据库
在这里插入图片描述
注意:如果配置了seata sever使用nacos作为配置中心，
则配置信息会从nacos读取,file.conf可以不用配置。

客户端配置registy.conf使用nacos时也要注意group要和seata server中的group一致，

默认group是"DEFAULT_GROUP"获取/seata/script/config-center/config.txt，修改配置信息。

在这里插入图片描述将script目录下载下拉复制到应用的跟目录
在这里插入图片描述在这里插入图片描述

4、seata设置集成nacos

下载好nacos之后本地启动nacos
在这里插入图片描述配置\seata\conf下的registry.conf设置对应的nacos的配置信息
在这里插入图片描述在这里插入图片描述事务分组：异地机房停电容错机制
my_test_tx_group 可以自定义 比如：（guangzhou、shanghai），对应的client也要去设置

service.vgroupMapping.default_tx_group=default

default 必须要等于 registry.confi cluster = "default"
在这里插入图片描述配置参数同步到Nacos
在nacos的安装目录下面
在这里插入图片描述在这里插入图片描述
如果是自定义的nacos需要配置自定义启动参数

sh $(SEATAPATH)/script/config-center/nacos/nacos-config.sh -h localhost -p 8848 -g SEATA_GROUuP -t 5a3c7d6c-f497-4d68-a712-2e5e3340b3ca

参数说明:
-h: host，默认值localhost
-p: port，默认值8848
-g:配置分组，默认值为’SEATA_GROUP’
-t:租户信息，对应 Nacos的命名空间ID字段,默认值为空"
访问：http://localhost:8848/nacos/
在这里插入图片描述

5、启动seata Server

  • 源码启动:执行server模块下io.seata.server.Server.java的main方法
  • 命令启动: bin/seata-server.sh -h 127.0.0.1 -p 8091 -m db -n 1 -e test

支持的启动参数
在这里插入图片描述
启动Seata Server

bin/seata-server. sh -p 8092

双击
在这里插入图片描述
启动成功
在这里插入图片描述

在这里插入图片描述

六、Seata Client快速开始

声明式事务实现(@GlobalTransactional)

接入微服务应用
业务场景:
用户下单，整个业务逻辑由三个微服务构成:

  • 订单服务:根据采购需求创建订单
  • 库存服务:对给定的商品扣除库存数量。

1、项目搭建

在这里插入图片描述在这里插入图片描述在这里插入图片描述在这里插入图片描述
在这里插入图片描述在这里插入图片描述在这里插入图片描述

2、创建数据库

DROP TABLE IF EXISTS `order_tbl`;
CREATE TABLE `order_tbl`  (`id` int NOT NULL AUTO_INCREMENT COMMENT '主键',`product_id` int NULL DEFAULT NULL COMMENT '项目id',`total_amount` int NULL DEFAULT NULL COMMENT '数量',`status` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;-- ----------------------------
-- Records of order_tbl
-- ----------------------------SET FOREIGN_KEY_CHECKS = 1;

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- Table structure for stock_tbl
-- ----------------------------
DROP TABLE IF EXISTS `stock_tbl`;
CREATE TABLE `stock_tbl`  (`id` int NOT NULL AUTO_INCREMENT COMMENT '主键',`product_id` int NULL DEFAULT NULL COMMENT '项目id',`count` int NULL DEFAULT NULL COMMENT '数量',PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;-- ----------------------------
-- Records of stock_tbl
-- ----------------------------
INSERT INTO `stock_tbl` VALUES (1, 9, 100);SET FOREIGN_KEY_CHECKS = 1;

3、完善上述两个代码

order-seata
seata-stock

在这里插入图片描述
分别启动两个项目
在这里插入图片描述
在这里插入图片描述
http://localhost:8070/order/add
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
再次访问

http://localhost:8070/order/add
在这里插入图片描述

在这里插入图片描述这里添加了事务
在这里插入图片描述
并且抛出了异常
在这里插入图片描述
但是数量依旧减掉了，因此在分布式事务场景下，这样添加事务是失效

4、在SpringCloud Alibaba事务情况，复制之前的工程创建新模块

在这里插入图片描述在这里插入图片描述
在这里插入图片描述
在这里插入图片描述在这里插入图片描述
完善依赖
在这里插入图片描述

   <dependencies><!--nacos服务注册发现--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- openfeign远程调用--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency></dependencies>

在这里插入图片描述

    <dependencies><!--nacos服务注册发现--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- openfeign远程调用--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency></dependencies>

5、完善上述对应的yml

在这里插入图片描述

  application:name: alibaba-order-seatacloud:nacos:discovery:server-addr: 127.0.0.1:8848username: nacospassword: nacos

在这里插入图片描述

  application:name: alibaba-seata-stockcloud:nacos:discovery:server-addr: 127.0.0.1:8848username: nacospassword: nacos

在这里插入图片描述

6、完善SpringCloud Alibaba相关代码

在这里插入图片描述

@EnableFeignClients

修改上述类名
在这里插入图片描述
对AlibabaStockSeataApplication 进行重新命名
在这里插入图片描述

7、启动两个项目

在这里插入图片描述
在这里插入图片描述
访问之前的库存
在这里插入图片描述
访问：http://localhost:8072/order/add
在这里插入图片描述
在这里插入图片描述在这里插入图片描述

在这里插入图片描述订单并没有添加
在这里插入图片描述
在这里插入图片描述
上述逻辑方法当中对应的内容一个成功了，一个没有成功

8、配置微服务整合seata

1）添加依赖

在这里插入图片描述

<!--seata的依赖--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId></dependency>

在这里插入图片描述

<!--seata的依赖--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId></dependency>
2）各微服务对应数据库中添加undo_log表
CREATE TABLE `undo_log` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`branch_id` bigint(20) NOT NULL,`xid` varchar(100) NOT NULL,`context` varchar(128) NOT NULL,`rollback_info` LONGBLOB NOT NULL,`log_status` int(11) NOT NULL,`log_created` datetime NOT NULL,`log_modified` datetime NOT NULL,			PRIMARY KEY(`id`),UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE = Innodb AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8

在两个数据库当中都添加改表
在这里插入图片描述

9、配置微服务整合seata

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

Selenium上传文件有多少种方式？不信你有我全

Selenium上传文件有多少种方式？不信你有我全

Selenium 封装了现成的文件上传操作。但是随着现代前端框架的发展&#xff0c;文件上传的方式越来越多样。而有一些文件上传的控件&#xff0c;要做自动化控制会更复杂一些&#xff0c;这篇文章主要讨论在复杂情况下&#xff0c;如何通过自动化完成文件上传 1.input 元素上传文…
阅读更多...
国庆作业6

国庆作业6

TCP服务器 #include "head.h" #define PORT 2580 //端口号 #define IP "192.168.31.219" //本机IP int main(int argc, const char *argv[]) {sqlite3* dbNULL;if(sqlite3_open("./my.db",&db)!SQLITE_OK){fprintf(stde…
阅读更多...
Python大数据之PySpark(四)SparkBaseCore

Python大数据之PySpark(四)SparkBaseCore

文章目录 SparkBase&Core环境搭建-Spark on YARN扩展阅读-Spark关键概念[了解]PySpark角色分析[了解]PySpark架构后记 SparkBase&Core 学习目标掌握SparkOnYarn搭建掌握RDD的基础创建及相关算子操作了解PySpark的架构及角色 环境搭建-Spark on YARN Yarn 资源调度框…
阅读更多...
面试题：熟悉设计模式吗？谈谈简单工厂模式和策略模式的区别

面试题：熟悉设计模式吗？谈谈简单工厂模式和策略模式的区别

刚刚接触设计模式的时候&#xff0c;我相信单例模式和工厂模式应该是用的最多的&#xff0c;毕竟很多的底层代码几乎都用了这些模式。自从接触了一次阿里的公众号发的一次文章关于 DDD的使用 以后&#xff0c;就逐渐接触了策略模式。现在在项目中运用最多的也是这几种设计模式了…
阅读更多...
【深蓝学院】手写VIO第4章--基于滑动窗口算法的 VIO 系统：可观性和 一致性--笔记

【深蓝学院】手写VIO第4章--基于滑动窗口算法的 VIO 系统：可观性和 一致性--笔记

0. 内容 T1. 参考SLAM14讲P247直接可写&#xff0c;注意 ξ 1 , ξ 2 \xi_1,\xi_2 ξ1​,ξ2​之间有约束&#xff08;关系&#xff09;。 套用舒尔补公式&#xff1a; marg掉 ξ 1 \xi_1 ξ1​之后&#xff0c;信息被传递到 L 1 和 L 2 L_1和L_2 L1​和L2​之间了。 T2.
阅读更多...
趋势列表上又多了两个漏洞！

趋势列表上又多了两个漏洞！

CVE-2023-24955 和 CVE-2023-29360 来自微软产品 5 月和 6 月的安全补丁报告。它们之所以特别危险&#xff0c;是因为出现了公开漏洞利用。 以下是详细信息。 第一个漏洞 CVE-2023-24955存在于 Microsoft SharePoint Server 中。它可导致远程代码执行。 它与覆盖随后由服务器执…
阅读更多...
匿名上位机V7波形显示教程-简单能用

匿名上位机V7波形显示教程-简单能用

匿名上位机V7波形显示教程-简单能用 匿名上位机V7下位机数据格式根据匿名上位机V7的手册说明文档&#xff0c;编写对应的指令在主函数中初始化ANDmessage驱动连接匿名上位机V7 匿名上位机V7下位机数据格式 DATA区域内容&#xff1a; 举例说明DATA区域格式&#xff0c;例如上文&…
阅读更多...
选择排序算法：简单但有效的排序方法

选择排序算法：简单但有效的排序方法

在计算机科学中&#xff0c;排序算法是基础且重要的主题之一。选择排序&#xff08;Selection Sort&#xff09;是其中一个简单但非常有用的排序算法。本文将详细介绍选择排序的原理和步骤&#xff0c;并提供Java语言的实现示例。 选择排序的原理 选择排序的核心思想是不断地从…
阅读更多...
NestJs和Vite使用monorepo管理项目中,需要使用共享的文件夹步骤

NestJs和Vite使用monorepo管理项目中,需要使用共享的文件夹步骤

NestJs和Vite使用monorepo管理项目中,需要使用共享的文件夹步骤 1 首先需要将nest-cli打包的功能通过webpack接管 nest-cli.json文件内容 {"$schema": "https://json.schemastore.org/nest-cli","collection": "nestjs/schematics",…
阅读更多...
FPGA project : TFT_LCD

FPGA project : TFT_LCD

实验目标&#xff1a; 驱动TFT_LCD显示十色彩条。 重点掌握的知识&#xff1a; 1&#xff0c;液晶显示器&#xff0c;简称LCD(Liquid Crystal Display)&#xff0c;相对于上一代CRT显示器(阴极射线管显示器)&#xff0c;LCD显示器具有功耗低、体积小、承载的信息量大及不伤眼…
阅读更多...
Python入门教程48：Pycharm永久镜像源的pip配置方法

Python入门教程48：Pycharm永久镜像源的pip配置方法

国内几个好用的Python镜像服务器地址&#xff1a; 清华大学镜像站&#xff1a;https://pypi.tuna.tsinghua.edu.cn/simple/阿里云镜像站&#xff1a;https://mirrors.aliyun.com/pypi/simple/中科大镜像站&#xff1a;https://pypi.mirrors.ustc.edu.cn/simple/中国科技大学镜…
阅读更多...
入门运维之MySQL管理

入门运维之MySQL管理

一、系统数据库 Mysql数据库安装完成后，自带了以下四个数据库，具体作用如下： 1.1常用工具 1.1.1 mysql 该mysql不是指mysql服务，而是指mysql的客户端工具。 语法 ：mysql [options] [database] 选项 ：-u, --user=name #指定用户名-p, --password[=name] #指定密码-h,…
阅读更多...
若依不分离+Thymeleaf select选中多个回显

若依不分离+Thymeleaf select选中多个回显

项目中遇到的场景&#xff0c;亲测实用 表单添加时&#xff0c;select选中多个&#xff0c;编辑表单时&#xff0c;select多选回显&#xff0c;如图 代码&#xff1a; // 新增代码 <label class"col-sm-3 control-label">通道&#xff1a;</label><…
阅读更多...
博途SCL区间搜索指令(判断某个数属于某个区间)

博途SCL区间搜索指令(判断某个数属于某个区间)

S型速度曲线行车位置控制，停靠位置搜索功能会用到区间搜索指令，下面我们详细介绍区间搜索指令的相关应用。 S型加减速行车位置控制(支持点动和停车位置搜索)-CSDN博客S型加减速位置控制详细算法和应用场景介绍，请查看下面文章博客。本篇文章不再赘述，这里主要介绍点动动和…
阅读更多...
二十六、设置时序电路初始状态的方法（初始值设置）（时序电路置数）2

二十六、设置时序电路初始状态的方法（初始值设置）（时序电路置数）2

方法2 在理解方法1的化简（1）这个方法后，又可以想到输入触发器R和S两个输入端的信号也无非就是0和1。那么直接用LOAD这个信号接在R和S两个输入端上即可。 先用开关判断触发器的R和S是低电平触发还是高电平触发（下图触发器可以直接看出为低电平触发，但是实际用管子搭建的触…
阅读更多...
Jmeter+jenkins接口性能测试平台实践整理

Jmeter+jenkins接口性能测试平台实践整理

最近两周在研究jmeter&#xff0b;Jenkin的性能测试平台测试dubbo接口&#xff0c;分别尝试使用maven&#xff0c;ant和Shell进行构建&#xff0c;jmeter相关设置略。 一、Jmeterjenkins&#xff0b;Shell&#xff0b;tomcat 安装Jenkins,JDK,tomcat,并设置环境变量&#xff0…
阅读更多...
Flutter+SpringBoot实现ChatGPT流实输出

Flutter+SpringBoot实现ChatGPT流实输出

FlutterSpringBoot实现ChatGPT流式输出、上下文了连续对话 最终实现Flutter的流式输出上下文连续对话。 这里就是提供一个简单版的工具类和使用案例&#xff0c;此处页面仅参考。 服务端 这里直接封装提供工具类&#xff0c;修改自己的apiKey即可使用&#xff0c;支持连续…
阅读更多...
BASH shell脚本篇5——文件处理

BASH shell脚本篇5——文件处理

这篇文章介绍下BASH shell中的文件处理。之前有介绍过shell的其它命令&#xff0c;请参考&#xff1a; BASH shell脚本篇1——基本命令 BASH shell脚本篇2——条件命令 BASH shell脚本篇3——字符串处理 BASH shell脚本篇4——函数 在Bash Shell脚本中&#xff0c;可以使用…
阅读更多...
visual studio禁用qt-vsaddin插件更新

visual studio禁用qt-vsaddin插件更新

visual studio里qt-vsaddin插件默认是自动更新的&#xff0c;由于qt-vsaddin插件新版本的操作方式与老版本相差较大&#xff0c;且新版本不稳定&#xff0c;容易出Bug&#xff0c;所以需要禁用其自动更新&#xff0c;步骤如下&#xff1a;     点击VS2019菜单栏上的【扩展】–…
阅读更多...
【计算机网络】高级IO之select

【计算机网络】高级IO之select

文章目录 1. 什么是IO&#xff1f;什么是高效 IO? 2. IO的五种模型五种IO模型的概念理解同步IO与异步IO整体理解 3. 阻塞IO4. 非阻塞IOsetnonblock函数为什么非阻塞IO会读取错误&#xff1f;对错误码的进一步判断检测数据没有就绪时&#xff0c;返回做一些其他事情完整代码myt…
阅读更多...
最新文章

Copyright @ 2022~2023