当前位置： 代码迷 >> 综合 >> seata 分布式事务的环境搭建与使用
  详细解决方案

seata 分布式事务的环境搭建与使用

热度：76   发布时间：2023-11-21 00:12:36.0

文章目录

  • 一、seata介绍
    • 1. 什么是 seata
    • 2. seata 的基本原理
  • 二、seata 环境搭建
    • 1. 服务器端环境搭建
      • 1.1 数据库及表的创建
      • 1.2 修改服务器端配置文件
      • 1.3 同步config.txt文件到nacos配置中心
    • 2. 客户端环境搭建
      • 2.1 引入pom依赖
      • 2.2 在application.yml文件中配置seata信息
      • 2.3 代理数据源配置
  • 三、简单测试

一、seata介绍

1. 什么是 seata

seata 是一个分布式事务的解决方案，具有高性能和易用性的微服务架构。其前身是fescar。
seata给用户提供了AT、TCC、XA和SAGA事务模型。
版本已经更新到了1.4.1，本文采用1.4.0版本进行搭建和测试。
在这里插入图片描述
文献资料：http://seata.io
github地址：https://github.com/seata/seata/

2. seata 的基本原理

首先我们先看一张分布式环境下，服务与服务之间的调用关系图：
在这里插入图片描述
其实分布式事务是由一批分支事务组成的全局事务，通常分支事务只是本地事务。
在这里插入图片描述
seata的核心主要有三部分组成：

  • 事务协调器（TC）：维护全局事务和分支事务的状态，驱动全局事务提交或者回滚。
  • 事务管理器（TM）：定义全局事务的范围：开启全局事务，提交或回滚全局事务（在分布式环境中相当于事务的发起方）。
  • 资源管理器（RM）：管理分支事务正在处理的资源，与TC进行对话以注册分支事务并报告分支事务的状态。并驱动分支事务的提交或者回滚（在分布式环境中相当于事务的参与者）。
    在这里插入图片描述
    seata管理的分布式事务的生命周期：
  • 首先，需要构建一个全局事务的协调者TC。
  • 发起方与参与方与全局事务协调者TC建立长连接。
  • 发起方向全局事务协调者申请一个全局事务XID，缓存在本地线程中。
  • 当发起方调用参与方的服务接口时，会将申请到的全局事务XID放入请求头中。
  • 参与方从请求头中获取XID，如果获取成功，则会向全局事务协调者注册(为参与方)，缓存XID到本地线程。执行完成之后提交本地事务，插入undo_log日志（后期用于回滚使用）。
  • 调用完成参与方服务接口，如果整个业务流程没有异常，则会通知全局事务协调者，全局事务协调者通知所有的参与方提交事务。事务提交成功后，删除undo_log日志。
  • 调用完成参与方服务接口，如果整个业务流程存在异常，则会通知全局事务协调者，全局事务协调者通知所有的参与方回滚事务。事务回滚时候，删除undo_log日志。
    在这里插入图片描述

二、seata 环境搭建

seata环境搭建会使用到mysql及nacos环境。具体搭建步骤可参照之前发布的文章，如有不详细的地方，请指正。

1. 服务器端环境搭建

下载seata1.4.0：https://github.com/seata/seata/releases
下载完成后解压，找到seata\conf\README.md文件，从下方获取相应的客户端配置及服务端信息配置
在这里插入图片描述

  • [client] 主要是客户端配置，undo_log日志等。
  • [server] 服务端部署脚本，比如使用db存储模式的时候，会从这里获取建表语句。
    在这里插入图片描述
  • [config-center] 存储配置中心的初始化脚本，将使用配置.txt作为初始配置
    在这里插入图片描述

1.1 数据库及表的创建

创建seata数据库，创建以下表

-- -------------------------------- 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_gmt_modified_status` (`gmt_modified`, `status`),KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8;-- 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 = utf8;-- 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),`gmt_create`     DATETIME,`gmt_modified`   DATETIME,PRIMARY KEY (`row_key`),KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8;

在每一个数据库中创建undo_log表

-- for AT mode you must to init this sql for you business database. the seata server not need it.
CREATE TABLE IF NOT EXISTS `undo_log`
(`branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',`xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',`context`       VARCHAR(128) 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 KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';

创建业务库user及表sys_user

CREATE TABLE `sys_user` (`id` int(11) NOT NULL,`user_name` varchar(32) DEFAULT NULL,`post` varchar(32) DEFAULT NULL,`is_delete` char(2) DEFAULT '0',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

创建业务库member及表sys_member

CREATE TABLE `sys_member` (`id` int(11) NOT NULL,`member_name` varchar(32) DEFAULT NULL,`integral` decimal(11,0) DEFAULT NULL,`is_delete` char(2) DEFAULT '0',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

1.2 修改服务器端配置文件

修改seata\conf\file.conf文件
在这里插入图片描述

修改seata\conf\registry.conf文件

修改注册类型为nacos

在这里插入图片描述

修改配置中心为nacos

在这里插入图片描述
上述配置说明：

nacos.serverAddr：注册中心/配置中心地址
nacos.namespace：命名空间，如果不填写默认为public
nacos.gorup：组
nacos.username：nacos用户名
nacos.password：nacos密码

1.3 同步config.txt文件到nacos配置中心

将nacos-config.sh(下载地址： [config-center] ) copy到seata\conf\目录下
在这里插入图片描述
将config.txt（下载地址： [config-center]）copy到seata\目录下
copy到seata目录下的原因是能够使nacos-config.sh脚本读取到
在这里插入图片描述
修改config.txt文件，主要修改的几个位置：

## 事务组，之后在客户端配置时，要和这个一样
service.vgroupMapping.my_test_tx_group=default
## seata服务器地址
service.default.grouplist=192.168.0.130:8091 ##与 服务器端中file.conf中相同
store.mode=db 
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://192.168.137.128:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123456
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

执行创建命令。在gitbash中执行

sh nacos-config.sh -h 192.168.0.241 -p 8848 -g SEATA_GROUP -t 839c4f2a-612d-417a-9a7d-a4c60fc6bc33 -u nacos -w nacos

创建成功之后，在nacos的配置为：
在这里插入图片描述

config.txt原文件内容如下：

transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
service.vgroupMapping.my_test_tx_group=default
service.default.grouplist=127.0.0.1:8091
service.enableDegrade=false
service.disableGlobalTransaction=false
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000
store.mode=file
store.publicKey=
store.file.dir=file_store/data
store.file.maxBranchSessionSize=16384
store.file.maxGlobalSessionSize=512
store.file.fileWriteBufferCacheSize=16384
store.file.flushDiskMode=async
store.file.sessionReloadReadSize=100
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=username
store.db.password=password
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
store.redis.mode=single
store.redis.single.host=127.0.0.1
store.redis.single.port=6379
store.redis.maxConn=10
store.redis.minConn=1
store.redis.maxTotal=100
store.redis.database=0
store.redis.password=
store.redis.queryLimit=100
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
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

2. 客户端环境搭建

创建两个项目分别为springboot-user和springboot-member。下方配置引入为共有的，两个项目中都要引入。没有贴出代码配置为项目中私有的代码，会在文章末尾给出下载地址。

2.1 引入pom依赖

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><version>2.2.0.RELEASE</version><exclusions><exclusion><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId></exclusion></exclusions>
</dependency>
<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>1.4.0</version>
</dependency>

2.2 在application.yml文件中配置seata信息

seata:enabled: trueenable-auto-data-source-proxy: true #代理数据源tx-service-group: my_test_tx_group #要与config.txt中的一致registry:type: nacos #注册类型nacos:application: seata-serverserver-addr: 192.168.0.241:8848username: nacospassword: nacosnamespace: 839c4f2a-612d-417a-9a7d-a4c60fc6bc33config:type: nacos # 配置中心类型nacos:server-addr: 192.168.0.241:8848group: SEATA_GROUPusername: nacospassword: nacosnamespace: 839c4f2a-612d-417a-9a7d-a4c60fc6bc33service:vgroup-mapping:my_test_tx_group: default # 默认值，如果在使用事务注解时不指定，采用该默认值disable-global-transaction: falseclient:rm:report-success-enable: false

2.3 代理数据源配置

package com.lee.config;/*** @author zfl_a* @date 2021/4/5* @project springboot_user*/import com.alibaba.druid.pool.DruidDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;import javax.sql.DataSource;@Configuration
public class DataSourceConfig {
    @Bean@ConfigurationProperties(prefix = "spring.datasource")public DruidDataSource druidDataSource() {
    // 或者使用其他数据源return new DruidDataSource();}@Primary@Beanpublic DataSource dataSource(DruidDataSource druidDataSource) {
    return new DataSourceProxy(druidDataSource);}
}

三、简单测试

使用@GlobalTransactional注解，断点打在调用积分成功之后
在这里插入图片描述
这时查看数据库是否插入成功
member表
在这里插入图片描述
undo_log表
在这里插入图片描述
放行之后发起方报错，会向全局事务协调者汇报当前状态，全局事务协调者通知参与方回滚事务
在这里插入图片描述
回滚之后，member表数据清空了
在这里插入图片描述
同样undo_log表也清空了
在这里插入图片描述

项目地址：https://gitee.com/enthusiasts/springboot-seata.git

  相关解决方案

代码迷 - 您身边的软件异常，代码异常，编程异常助手（发现，解决，分享）
Copyright © 2009-2013 DAIMAMI.COM. All rights reserved.