Seata v1.4.2分布式事务集成

准备环境

创建四个数据库，如下

jeecg_order（订单数据库）
jeecg_account（账户数据库）
jeecg_product（商品数据库）
seata（seata数据库）

以上数据库脚本已存放至jeecg-cloud-test-seata示例中，文件位置如下图所示

示例代码：

jeecg-cloud-test-seata-order（下单服务）

jeecg-cloud-test-seata-product（库存服务）

jeecg-cloud-test-seata-account（账户服务）

该示例场景用于下单时检测库存是否车充足，余额是否充足，有一个不满足是则回滚事务

seata服务端：本次实践的seata版本为v1.4.2，下载地址 http://seata.io/zh-cn/blog/download.html

安装服务端

下载下来进行解压，目录结构如下：

进入bin目录启动seata，seata默认端口是8091

window下运行seata-server.bat

linux下运行seata-server.sh

测试分布式事务

修改file.conf文件（如果需要使用nacos则修改type=nacos），如下图

修registry.conf（如果需要使用nacos则修改type=nacos）,如下图

启动seata，如下图

输入如下信息后表示启动成功

4.微服务模块添加依赖，具体参考示例代码

<dependency>
    <groupId>org.jeecgframework.boot</groupId>
    <artifactId>jeecg-boot-starter-cloud</artifactId>
    <version>3.1.0</version>
</dependency>
<dependency>
    <groupId>org.jeecgframework.boot</groupId>
    <artifactId>jeecg-boot-starter-seata</artifactId>
    <version>3.1.0</version>
</dependency>

5.微服务模块添加配置，具体参考示例代码

seata:
  enable-auto-data-source-proxy: false
  service:
    grouplist:
      default: 127.0.0.1:8091
    vgroup-mapping:
      springboot-seata-group: default
  # seata 事务组编号 用于TC集群名
  tx-service-group: springboot-seata-group

6.启动测试

依次启动

jeecg-cloud-test-seata-order（下单服务）

jeecg-cloud-test-seata-product（库存服务）

jeecg-cloud-test-seata-account（账户服务）

启动完成如下图

浏览器输入http://localhost:5001 即可进行测试，如下图所示

测试正常下参数见截图

测试余额不足，测试库存不足，然后观察数据库订单表插入数据是否回滚

注：本示例不通过网关所以需要排除认证权限ShiroConfig.java添加如下代码

//测试模块排除
filterChainDefinitionMap.put("/test/seata/**", "anon");

可使用nacos作为seata的配置中心

新建seataServer.properties配置文件内容如下

# 数据存储方式，db代表数据库
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://localhost:3300/seata?useUnicode=true&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai
store.db.user=root
store.db.password=root
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
# 事务、日志等配置
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
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000

# 客户端与服务端传输方式
transport.serialization=seata
transport.compressor=none
# 关闭metrics功能，提高性能
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

准备环境​

测试分布式事务​

准备环境

测试分布式事务