- 前言
- 一、搭建seata1.4.2服务端
- 1.下载seata1.4.2
- 2.创建相关数据库和表
- 3.配置Seata 1.4.2
- 4.启动seata1.4.2
- 二、客户端使用seata1.4.2
- 1.准备工作
- 2.测试seata1.4.2
- 3.测试结果
- 总结
前言
seata官网
搭建环境: mac os
spring-boot.version 2.3.7.RELEASE
spring-cloud-alibaba.version 2.2.2.RELEASE
spring-cloud.version Hoxton.SR9
数据库mysql.8.0+
一、搭建seata1.4.2服务端 1.下载seata1.4.2
下载地址 https://github.com/seata/seata/releases
解压后进入conf文件夹可以看到registry.conf配置文件比以往版本新增了一个dataId的配置,官网原话是
从v1.4.2版本开始，已支持从一个Nacos dataId中获取所有配置信息,你只需要额外添加一个dataId配置项, 所以后面所有的配置都是围绕这个方式来实现的
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "file"
nacos {
serverAddr = "127.0.0.1:8848"
namespace = ""
group = ""
username = ""
password = ""
dataId = "seataServer.properties" //新增的配置,
}
2.创建相关数据库和表
由于store没有使用file模式,而是采用的db模式,所以先创建相关数据库和表
创建数据库: 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 = InnoDB
DEFAULT 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 = InnoDB
DEFAULT 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 = InnoDB
DEFAULT CHARSET = utf8;
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 = InnoDB
DEFAULT 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);
3.配置Seata 1.4.2
这里为了方便区分不同的应用，在nacos新建命名空间seata,这里创建后的命名空间，这里的命名空间id会在之后的配置中使用到
在nacos中编写上面配置的seataServer.properties文件(为了简单把客户端的内容也一起配置了进去,所以下面客户端会共用此配置文件实际情况分开配置更好)
根据参考配置文件config.txt来编写
https://github.com/seata/seata/blob/develop/script/config-center/config.txt
transport.type=TCP transport.server=NIO transport.heartbeat=true transport.enableClientBatchSendRequest=true 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 transport.serialization=seata transport.compressor=none # server server.recovery.committingRetryPeriod=1000 server.recovery.asynCommittingRetryPeriod=1000 server.recovery.rollbackingRetryPeriod=1000 server.recovery.timeoutRetryPeriod=1000 server.undo.logSaveDays=7 server.undo.logDeletePeriod=86400000 server.maxCommitRetryTimeout=-1 server.maxRollbackRetryTimeout=-1 server.rollbackRetryTimeoutUnlockEnable=false server.distributedLockExpireTime=10000 # store #model改为db store.mode=db store.lock.mode=file store.session.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 #修改数据驱动，这里是mysql8，使用mysql5的话请修改 store.db.driverClassName=com.mysql.cj.jdbc.Driver # 改为上面创建的seata服务数据库 store.db.url=jdbc:mysql://127.0.0.1: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.distributedLockTable=distributed_lock 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.sentinel.masterName="" # store.redis.sentinel.sentinelHosts="" store.redis.maxConn=10 store.redis.minConn=1 store.redis.maxTotal=100 store.redis.database=0 # store.redis.password="" store.redis.queryLimit=100 # log log.exceptionRate=100 # metrics metrics.enabled=false metrics.registryType=compact metrics.exporterList=prometheus metrics.exporterPrometheusPort=9898 # service # 自己命名一个vgroupMapping service.vgroupMapping.fsp_tx_group=default service.default.grouplist=127.0.0.1:8091 service.enableDegrade=false service.disableGlobalTransaction=false # client 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.rm.tccActionInterceptorOrder=-2147482648 client.tm.commitRetryCount=5 client.tm.rollbackRetryCount=5 client.tm.defaultGlobalTransactionTimeout=60000 client.tm.degradeCheck=false client.tm.degradeCheckAllowTimes=10 client.tm.degradeCheckPeriod=2000 client.tm.interceptorOrder=-2147482648 client.undo.dataValidation=true client.undo.logSerialization=jackson client.undo.onlyCareUpdateColumns=true client.undo.logTable=undo_log client.undo.compress.enable=true client.undo.compress.type=zip client.undo.compress.threshold=64k
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = "nacos" #改为nacos
nacos {
application = "seata-server"
serverAddr = "localhost:8848" #改为自己的nacos地址
group = "SEATA_GROUP" #改为自己的group
namespace = "ef11b50a-4d85-48a3-9096-ab4c87df509f" #改为自己的nacos的namespace,这里填写的是刚才创建seata命名空间的id
cluster = "default"
username = "nacos" #改为自己nacos的用户名
password = "nacos" #改为自己nacos的密码
}
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "nacos" #改为nacos
nacos {
serverAddr = "localhost:8848" #改为自己的nacos地址
namespace = "ef11b50a-4d85-48a3-9096-ab4c87df509f" #改为自己的nacos的namespace,这里填写的是刚才创建seata命名空间的id
group = "SEATA_GROUP"
username = "nacos" #改为自己nacos的用户名
password = "nacos" #改为自己nacos的密码
dataId = "seataServer.properties" #改为自己的配置文件dataId,这里用的默认的
}
4.启动seata1.4.2
二、客户端使用seata1.4.2
1.准备工作
在每个微服务的数据库创建表
-- 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 = InnoDB
AUTO_INCREMENT = 1
DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';
2.测试seata1.4.2
pom文件中引入依赖,注意引入seata的版本一定要与seata服务端版本一致
com.alibaba.cloud spring-cloud-starter-alibaba-seata io.seata seata-spring-boot-starter io.seata seata-spring-boot-starter 1.4.2
编写yml配置文件
seata:
#事务群组（可以每个应用独立取名，也可以使用相同的名字），要与服务端nacos-config.txt中service.vgroup_mapping中存在,并且要保证多个群组情况下后缀名要保持一致-tx_group
enabled: true
enable-auto-data-source-proxy: true #是否开启数据源自动代理,默认为true
tx-service-group: fsp_tx_group #要与配置文件中的vgroupMapping一致
registry: #registry根据seata服务端的registry配置
type: nacos #默认为file
nacos:
application: seata-server #配置自己的seata服务
server-addr: ${spring.cloud.nacos.discovery.server-addr} #根据自己的seata服务配置
username: nacos #根据自己的seata服务配置
password: nacos #根据自己的seata服务配置
cluster: default # 配置自己的seata服务cluster, 默认为 default
group: SEATA_GROUP #根据自己的seata服务配置
namespace: ef11b50a-4d85-48a3-9096-ab4c87df509f ##改为自己的nacos的namespace,这里填写的是刚才创建seata命名空间的id
config:
type: nacos #默认file,如果使用file不配置下面的nacos,直接配置seata.service
nacos:
server-addr: ${spring.cloud.nacos.discovery.server-addr} #配置自己的nacos地址
group: SEATA_GROUP #配置自己的dev
username: nacos #配置自己的username
password: nacos #配置自己的password
dataId: seataServer.properties # #配置自己的dataId,由于搭建服务端时把客户端的配置也写在了seataServer.properties,所以这里用了和服务端一样的配置文件,实际客户端和服务端的配置文件分离出来更好
namespace: ef11b50a-4d85-48a3-9096-ab4c87df509f @#改为自己的nacos的namespace,这里填写的是刚才创建seata命名空间的id
如果搭建服务端的时候, 服务端配置文件没有写客户端的配置,这里就需要在nacos编写上一步seata配置的dataId文件(客户端的配置文件),此例子不需要单独写客户端seata配置文件
在启动类上添加注解@EnableAutoDataSourceProxy
//seata1.1版本后使用注解开启DataSourceProxy, 之前版本需要手动写DataSourceProxy配置使seata管理数据库 @EnableAutoDataSourceProxy
所有事务相关微服务都做好以上配置
在事务发起的方法上添加注解@GlobalTransactional
//seata事务控制注解,name自定义保证唯一性
@GlobalTransactional(name = "save-funds", rollbackFor = Exception.class)
public Boolean saveFundsRevise(FundsRevise fundsRevise){
//业务逻辑
}
3.测试结果
启动项目,seata日志可以看到相关微服务和对应数据库
发起请求执行事务,seata日志可以看到相关回滚日志记录,并且查看数据库数据回滚成功
特别注意如果修改seata服务器配置记得一定要重启
参考博文
Seata1.4.2+Nacos搭建使用 https://blog.csdn.net/ww_run/article/details/120099870
