Seata搭建

下载地址

地址链接

file.conf 配置文件修改

• service 修改事务组名称&＃xff0c;符合 *.tx_group 格式

service {#transaction service group mappingvgroup_mapping.my_test_tx_group &＃61; "rentao_tx_group"#only support when registry.type&＃61;file, please don&＃39;t set multiple addressesdefault.grouplist &＃61; "127.0.0.1:8091"#disable seatadisableGlobalTransaction &＃61; false
}


• store 事务日志保存位置修改

## transaction log store, only used in seata-server
store {## store mode: file 文件储存、db 数据库存储mode &＃61; "db"## file store propertyfile {## store location dirdir &＃61; "sessionStore"}## database store propertydb {## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.datasource &＃61; "dbcp"## mysql/oracle/h2/oceanbase etc.db-type &＃61; "mysql"driver-class-name &＃61; "com.mysql.jdbc.Driver"## mysql/oracle/h2/oceanbase etc. 配置自己的数据库信息url &＃61; "jdbc:mysql://127.0.0.1:3306/seata"user &＃61; "root"password &＃61; "password"}
}


创建数据库&＃xff0c;导入结构


创建 seata 库&＃xff1a;执行以下
CREATE DATABASE seata;
-- the table to store GlobalSession data
drop table if exists &＃96;global_table&＃96;;
#TM
create table &＃96;global_table&＃96; (&＃96;xid&＃96; varchar(128) not null,&＃96;transaction_id&＃96; bigint,&＃96;status&＃96; tinyint not null,&＃96;application_id&＃96; varchar(32),&＃96;transaction_service_group&＃96; varchar(32),&＃96;transaction_name&＃96; varchar(128),&＃96;timeout&＃96; int,&＃96;begin_time&＃96; bigint,&＃96;application_data&＃96; varchar(2000),&＃96;gmt_create&＃96; datetime,&＃96;gmt_modified&＃96; datetime,primary key (&＃96;xid&＃96;),key &＃96;idx_gmt_modified_status&＃96; (&＃96;gmt_modified&＃96;, &＃96;status&＃96;),key &＃96;idx_transaction_id&＃96; (&＃96;transaction_id&＃96;)
);-- the table to store BranchSession data
drop table if exists &＃96;branch_table&＃96;;
#RM
create table &＃96;branch_table&＃96; (&＃96;branch_id&＃96; bigint not null,&＃96;xid&＃96; varchar(128) not null,&＃96;transaction_id&＃96; bigint ,&＃96;resource_group_id&＃96; varchar(32),&＃96;resource_id&＃96; varchar(256) ,&＃96;lock_key&＃96; varchar(128) ,&＃96;branch_type&＃96; varchar(8) ,&＃96;status&＃96; tinyint,&＃96;client_id&＃96; varchar(64),&＃96;application_data&＃96; varchar(2000),&＃96;gmt_create&＃96; datetime,&＃96;gmt_modified&＃96; datetime,primary key (&＃96;branch_id&＃96;),key &＃96;idx_xid&＃96; (&＃96;xid&＃96;)
);-- the table to store lock data
drop table if exists &＃96;lock_table&＃96;;
create table &＃96;lock_table&＃96; (&＃96;row_key&＃96; varchar(128) not null,&＃96;xid&＃96; varchar(96),&＃96;transaction_id&＃96; long ,&＃96;branch_id&＃96; long,&＃96;resource_id&＃96; varchar(256) ,&＃96;table_name&＃96; varchar(32) ,&＃96;pk&＃96; varchar(36) ,&＃96;gmt_create&＃96; datetime ,&＃96;gmt_modified&＃96; datetime,primary key(&＃96;row_key&＃96;)
);


registry.conf 注册方式修改

registry {# file 、nacos 、eureka、redis、zk、consul、etcd3、sofatype &＃61; "nacos"nacos {serverAddr &＃61; "localhost:8848"namespace &＃61; ""cluster &＃61; "default"}...
}


业务库数据准备

• 可能有n个 rm 对应的子业务库&＃xff0c;在每个业务库增加回滚日志表

-- the table to store seata xid data
-- 0.7.0&＃43; add context
-- you must to init this sql for you business databese. the seata server not need it.
-- 此脚本必须初始化在你当前的业务数据库中&＃xff0c;用于AT 模式XID记录。与server端无关&＃xff08;注&＃xff1a;业务数据库&＃xff09;
-- 注意此处0.3.0&＃43; 增加唯一索引 ux_undo_log
drop table &＃96;undo_log&＃96;;
CREATE TABLE &＃96;undo_log&＃96; (&＃96;id&＃96; bigint(20) NOT NULL AUTO_INCREMENT,&＃96;branch_id&＃96; bigint(20) NOT NULL,&＃96;xid&＃96; varchar(100) NOT NULL,&＃96;context&＃96; varchar(128) NOT NULL,&＃96;rollback_info&＃96; longblob NOT NULL,&＃96;log_status&＃96; int(11) NOT NULL,&＃96;log_created&＃96; datetime NOT NULL,&＃96;log_modified&＃96; datetime NOT NULL,&＃96;ext&＃96; varchar(100) DEFAULT NULL,PRIMARY KEY (&＃96;id&＃96;),UNIQUE KEY &＃96;ux_undo_log&＃96; (&＃96;xid&＃96;,&＃96;branch_id&＃96;)
) ENGINE&＃61;InnoDB AUTO_INCREMENT&＃61;1 DEFAULT CHARSET&＃61;utf8;

默认AT模式的加载流程

• 一阶段加载

在一阶段&＃xff0c;Seata会拦截“业务SQL”

1&＃xff1a;解析SQL语义&＃xff0c;找到“业务SQL" 要更新的业务数据&＃xff0c;在业务数据被更新前&＃xff0c;
将其保存成"before image” &＃xff08;未变更之前的原始数据&＃xff0c;用于rollback的数据回滚 &＃xff09;2&＃xff1a;执行“业务SQL" 更新业务数据&＃xff0c;在业务数据更新之后,3其保存成"after image”&＃xff0c;最后生成行锁。


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

• 二阶段提交

二阶段如果顺利提交的话&＃xff0c;因为"业务SQL"在一阶段已经提交至数据库&＃xff0c;
所以Seata框架只需将一阶段保存的快照数据和行锁删掉&＃xff0c;完成数据清理即可


• 二阶段回滚

二阶段如果是回滚的话&＃xff0c;Seata 就需要回滚一阶段已经执行的 “业务SQL"&＃xff0c;还原业务数据。回滚方式便是用"before image"还原业务数据&＃xff1b;但在还原前要首先要校验脏写&＃xff0c;
对比“数据库当前业务数据”和"after image"。如果两份数据完全一致就说明没有脏写&＃xff0c;可以用"before image"还原业务数据&＃xff0c;如果不一致就说明有别的业务操作对此数据已出现脏写, 出现脏写就需要转人工处理。


• remark

seata 相关表只有过程中持有数据&＃xff0c;不管全局成功还是失败&＃xff0c;数据是成功变更还是进行
回退&＃xff0c;表里均不会有数据产生