【SpringCloud】Spring Cloud Alibaba 之 Seata 分布式事务中间件（三十五）
2021-01-02 13:29
标签：uid 本地 nba manage 回滚 arc arch hid adsi 单体应用中，一个业务操作需要调用三个模块完成，此时数据的一致性由本地事务来保证。 随着业务需求的变化，单体应用被拆分成微服务应用，原来的三个模块被拆分成三个独立的应用，分别使用独立的数据源，业务操作需要调用三个服务来完成。此时每个服务内部的数据一致性由本地事务来保证，但是全局的数据一致性问题没法保证。 在微服务架构中由于全局数据一致性没法保证产生的问题就是分布式事务问题。简单来说，一次业务操作需要操作多个数据源或需要进行远程调用，就会产生分布式事务问题。 Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。 官网：http://seata.io/ 全局唯一的事务id Transaction Coordinator(TC)：事务协调器,维护全局事务的运行状态,负责协调并驱动全局事务的提交或回滚 Transaction Manager(TM)：控制全局事务的边界,负责开启一个全局事务,并最终发起全局提交或全局回滚的决议 Resource Manager(RM)：控制分支事务,负责分支注册、状态汇报,并接受事务协调的指令,驱动分支(本地)事务的提交和回滚 过程图： 说明： 1、TM 向 TC 申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的 XID； 2、XID 在微服务调用链路的上下文中传播； 3、RM 向 TC 注册分支事务，将其纳入 XID 对应的全局事务的管辖； 4、TM 向 TC 发起针对 XID 的全局提交或回滚决议； 5、TC 调度 XID 下管辖的全部分支事务完成提交或回滚请求。 Seata分TC、TM和RM三个角色，TC（Server端）为单独服务端部署，TM和RM（Client端）由业务系统集成。 1、下载服务端压缩包，地址：https://github.com/seata/seata/releases 本例下载的是 seata-server-1.2.0.tar.gz，并解压 2、修改事务日志存储模式为 由于我们使用了db模式存储事务日志，所以我们需要创建一个seat数据库，建表sql在seat项目的github找到， 地址：https://github.com/seata/seata/tree/1.2.0/script/server/db 目录 mysql.sql 中 3、修改注册中心，使用nacos作为注册中心，即修改 conf目录中 registry.conf 文件，如下： 4、启动Nacos服务、在启动Seata服务 【SpringCloud】Spring Cloud Alibaba 之 Seata 分布式事务中间件（三十五） 标签：uid 本地 nba manage 回滚 arc arch hid adsi 原文地址：https://www.cnblogs.com/h--d/p/12994365.html什么是分布式事务问题？
单体应用
微服务应用
小结
Seata 是什么?
Seata 组成
Transaction ID(XID)
三组件
Seata 分布式事务处理过程
Seata 部署
Seata服务端（TC）部署
db 及数据库连接信息，即修改 conf目录中 flie.conf 文件，如下： 1 ## transaction log store, only used in seata-server
2 store {
3 ## store mode: file、db
4 mode = "db"
5
6 ## file store property
7 file {
8 ## store location dir
9 dir = "sessionStore"
10 # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
11 maxBranchSessionSize = 16384
12 # globe session size , if exceeded throws exceptions
13 maxGlobalSessionSize = 512
14 # file buffer size , if exceeded allocate new buffer
15 fileWriteBufferCacheSize = 16384
16 # when recover batch read size
17 sessionReloadReadSize = 100
18 # async, sync
19 flushDiskMode = async
20 }
21
22 ## database store property
23 db {
24 ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
25 datasource = "druid"
26 ## mysql/oracle/postgresql/h2/oceanbase etc.
27 dbType = "mysql"
28 driverClassName = "com.mysql.cj.jdbc.Driver"
29 url = "jdbc:mysql://localhost:3306/seata"
30 user = "admin"
31 password = "123456"
32 minConn = 5
33 maxConn = 30
34 globalTable = "global_table"
35 branchTable = "branch_table"
36 lockTable = "lock_table"
37 queryLimit = 100
38 maxWait = 5000
39 }
40 }
1 -- -------------------------------- The script used when storeMode is ‘db‘ --------------------------------
2 -- the table to store GlobalSession data
3 CREATE TABLE IF NOT EXISTS `global_table`
4 (
5 `xid` VARCHAR(128) NOT NULL,
6 `transaction_id` BIGINT,
7 `status` TINYINT NOT NULL,
8 `application_id` VARCHAR(32),
9 `transaction_service_group` VARCHAR(32),
10 `transaction_name` VARCHAR(128),
11 `timeout` INT,
12 `begin_time` BIGINT,
13 `application_data` VARCHAR(2000),
14 `gmt_create` DATETIME,
15 `gmt_modified` DATETIME,
16 PRIMARY KEY (`xid`),
17 KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
18 KEY `idx_transaction_id` (`transaction_id`)
19 ) ENGINE = InnoDB
20 DEFAULT CHARSET = utf8;
21
22 -- the table to store BranchSession data
23 CREATE TABLE IF NOT EXISTS `branch_table`
24 (
25 `branch_id` BIGINT NOT NULL,
26 `xid` VARCHAR(128) NOT NULL,
27 `transaction_id` BIGINT,
28 `resource_group_id` VARCHAR(32),
29 `resource_id` VARCHAR(256),
30 `branch_type` VARCHAR(8),
31 `status` TINYINT,
32 `client_id` VARCHAR(64),
33 `application_data` VARCHAR(2000),
34 `gmt_create` DATETIME(6),
35 `gmt_modified` DATETIME(6),
36 PRIMARY KEY (`branch_id`),
37 KEY `idx_xid` (`xid`)
38 ) ENGINE = InnoDB
39 DEFAULT CHARSET = utf8;
40
41 -- the table to store lock data
42 CREATE TABLE IF NOT EXISTS `lock_table`
43 (
44 `row_key` VARCHAR(128) NOT NULL,
45 `xid` VARCHAR(96),
46 `transaction_id` BIGINT,
47 `branch_id` BIGINT NOT NULL,
48 `resource_id` VARCHAR(256),
49 `table_name` VARCHAR(32),
50 `pk` VARCHAR(36),
51 `gmt_create` DATETIME,
52 `gmt_modified` DATETIME,
53 PRIMARY KEY (`row_key`),
54 KEY `idx_branch_id` (`branch_id`)
55 ) ENGINE = InnoDB
56 DEFAULT CHARSET = utf8;
1 registry {
2 # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
3 type = "file"
4
5 nacos {
6 application = "seata-server"
7 serverAddr = "localhost:8848"
8 namespace = ""
9 cluster = "default"
10 username = ""
11 password = ""
12 }
13 }
文章标题：【SpringCloud】Spring Cloud Alibaba 之 Seata 分布式事务中间件（三十五）
文章链接：http://soscw.com/index.php/essay/39589.html