# seata整合案例 [TOC] ## **准备环境** 1. 创建四个数据库，如下 ``` jeecg_order（订单数据库） jeecg_account（账户数据库） jeecg_product（商品数据库） seata（seata数据库） ``` 以上数据库脚本已存放至jeecg-cloud-test-seata示例中，文件位置如下图所示     2. 示例代码： jeecg-cloud-test-seata-order（下单服务） jeecg-cloud-test-seata-product（库存服务） jeecg-cloud-test-seata-account（账户服务） 该示例场景用于下单时检测库存是否车充足，余额是否充足，有一个不满足是则回滚事务 3. seata服务端：本次实践的seata版本为v1.4.2，下载地址 [http://seata.io/zh-cn/blog/download.html](http://seata.io/zh-cn/blog/download.html) 安装服务端 下载下来进行解压，目录结构如下：  进入bin目录启动seata，seata默认端口是8091  window下运行`seata-server.bat` linux下运行`seata-server.sh` ## **测试分布式事务** 1. 修改file.conf文件（如果需要使用nacos则修改type=nacos），如下图  2. 修registry.conf（如果需要使用nacos则修改type=nacos）,如下图   3. 启动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 ```