前提：准备一个eureka项目

下面都是在eureka项目的基础上做的整合

步骤1：下载安装seata-server客户端

1.1、下载seata客户端并解压

Git官方下载地址：https://github.com/seata/seata/releases
windows系统选第二个

1.2、配置seata客户端

编辑seata客户端conf目录下的两个配置文件
注释的地方需要改成自己的，其他的默认即可
file.conf

store {mode = "db"db {datasource = "druid"dbType = "mysql"driverClassName = "com.mysql.jdbc.Driver"url = "jdbc:mysql://127.0.0.1:3306/tc" #这里改成你自己的数据库user = "root"                            #改成自己的用户名password = "123456"                     #改成自己的密码minConn = 5maxConn = 100#这三个表是给seata客户端用的，在我的项目里位于"jdbc:mysql://127.0.0.1:3306/tc"数据库下面globalTable = "global_table"           #全局表的表名branchTable = "branch_table"          #分之事务表名lockTable = "lock_table"              #锁表的表名queryLimit = 100maxWait = 5000}
}

registry.conf

registry {type = "eureka"eureka {serviceUrl = "http://localhost:8090/eureka/"  #改成自己的eureka注册中心地址application = "seata-server"                   #本客户端注册到eureka的微服务名称weight = "1"}
}

1.3、创建seata客户端用的那三个数据表（全局事务表，分之事务表，锁表）

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- Table structure for global_table
-- ----------------------------#全局事务表
DROP TABLE IF EXISTS `global_table`;
CREATE TABLE `global_table`  (`xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`status` tinyint(4) NOT NULL,`application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`timeout` int(11) NULL DEFAULT NULL,`begin_time` bigint(20) NULL DEFAULT NULL,`application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime(0) NULL DEFAULT NULL,`gmt_modified` datetime(0) NULL DEFAULT NULL,PRIMARY KEY (`xid`) USING BTREE,INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
SET FOREIGN_KEY_CHECKS = 1;#分支事务表
DROP TABLE IF EXISTS `branch_table`;
CREATE TABLE `branch_table`  (`branch_id` bigint(20) NOT NULL,`xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`status` tinyint(4) NULL DEFAULT NULL,`client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime(6) NULL DEFAULT NULL,`gmt_modified` datetime(6) NULL DEFAULT NULL,PRIMARY KEY (`branch_id`) USING BTREE,INDEX `idx_xid`(`xid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
SET FOREIGN_KEY_CHECKS = 1;#锁表
DROP TABLE IF EXISTS `lock_table`;
CREATE TABLE `lock_table`  (`row_key` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`xid` varchar(96) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`transaction_id` bigint(20) NULL DEFAULT NULL,`branch_id` bigint(20) NOT NULL,`resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`table_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`pk` varchar(36) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,`gmt_create` datetime(0) NULL DEFAULT NULL,`gmt_modified` datetime(0) NULL DEFAULT NULL,PRIMARY KEY (`row_key`) USING BTREE,INDEX `idx_branch_id`(`branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
SET FOREIGN_KEY_CHECKS = 1;

看下效果

先启动项目的eureka注册中心，再双击seata客户端的bin目录下的bat文件

看注册中心（http://localhost:8090/），seata-server注册成功

步骤2：整合自己的微服务

说明：在本项目中，微服务server1调用了微服务server2，两个微服务都会操作各自的数据库

2.1、在调用微服务的和被调用的项目里面都需要创建一个undo_log表用于回滚事务

每个参与事务的项目都需要创建一个自己的undo_log表

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- Table structure for undo_log
-- ----------------------------
DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log`  (`id` bigint(20) NOT NULL AUTO_INCREMENT,`branch_id` bigint(20) NOT NULL,`xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,`rollback_info` longblob NOT NULL,`log_status` int(11) NOT NULL,`log_created` datetime(0) NOT NULL,`log_modified` datetime(0) NOT NULL,`ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE,UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 22 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;SET FOREIGN_KEY_CHECKS = 1;

2.2、导入依赖，调用服务的和被调用的都需要添加这个依赖

<!-- https://mvnrepository.com/artifact/com.alibaba.cloud/spring-cloud-starter-alibaba-seata -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><version>2021.1</version>
</dependency>

2.3、配置yml（调用服务的和被调用的都需要，关于seata部分的配置都是一样的）

seata:enabled: trueapplication-id: ${spring.application.name}tx-service-group: seata-serverenable-auto-data-source-proxy: trueservice:default: 127.0.0.1:8091vgroup-mapping:seata-server: defaultconfig:type: filefile:name: file.confregistry:type: filefile:name: file

2.4、在需要全局事务的地方添加注解

注意这里的name就是seata客户端注册到注册中心的微服务名

@RequestMapping("get")
@GlobalTransactional(name = "seata-server", rollbackFor = Exception.class)
public String get(){StringBuilder rs = new StringBuilder("start-->");//生成订单，操作orders表Orders orders = new Orders();orders.setId(UUID.randomUUID().toString());orders.setUserId("wang");orders.setGoodId("qianBi");orders.setBuyNumber(1);ordersService.save(orders);StringBuilder stringBuilder1 = new StringBuilder("生成订单-->支付成功-->");rs.append(stringBuilder1);//减少库存，调用微服务server2，操作goods表String s = testService.get(orders.getGoodId());StringBuilder stringBuilder2 = new StringBuilder(s);rs.append(stringBuilder2);return rs.toString();
}

步骤3：测试事务回滚操作

3.1、在被调用方手动添加错误，并添加断点

3.2、查看初始时候的数据库

orders表：无订单

goods表：铅笔的库存有100只

3.3、Debug模式启动剩下的微服务项目，访问第一个服务对应接口

执行到断点时查看数据库
orders表：新增一个订单

goods表：铅笔的库存变为99只

3.4、按F9继续执行项目，发现事务回滚，数据库还原

orders表：订单回滚

goods表：库存回滚

完结撒花，附上本项目源码

https://gitee.com/yizhixiang/eureka-seata.git

SpringCloud学习之：eureka整合seata相关推荐

SpringCloud学习十：整合Swagger
Swagger的加强版Knife4jhttps://gitee.com/xiaoym/knife4j 创建自己的swagger项目jar包配合本地jar包导入到maven中一.简单的使用Swagg ...
Spring Cloud Eureka整合 Seata 实现分布式事务
一.Seata 介绍 Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务.Seata 将为用户提供了 AT.TCC.SAGA 和 XA 事务模式,为用户打造一站式的 ...
SpringCloud 整合 Seata
<分布式事务>https://blog.csdn.net/u011060911/article/details/122210788上面的文章系统介绍了分布式事务相关的理论知识,本文则通过代 ...
springcloud整合seata
springcloud整合seata 一.背景二.项目结构三.实现功能: 四.项目使用到的技术五.整合步骤 1.引入spring-cloud-starter-alibaba-seata jar包 ...
springCloud整合seata实现分布式事务
seata简介 Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务.Seata 将为用户提供了 AT.TCC.SAGA 和 XA 事务模式,为用户打造一站式的分布式 ...
SpringCloud学习教程一( 服务的注册与发现 Eureka)
本文是根据方志明的springCloud学习教程进行个人细化,记录个人学习的教程可能会做一些小的修改让文章更便于理解, 原著参考案例全部采用Spring Boot 1.5.x ,Spring Clou ...
SpringCloud 学习笔记（2 / 3）
Spring Cloud 学习笔记(1 / 3) Spring Cloud 学习笔记(3 / 3) 文章目录 56\_Hystrix之全局服务降级DefaultProperties 57\_Hystr ...
SpringCloud学习笔记（1）- Spring Cloud Alibaba
文章目录 SpringCloud学习笔记(1)- Spring Cloud Alibaba 服务治理 Nacos 服务注册 Nacos 服务发现与调用 Ribbon 负载均衡 Sentinel 服务限 ...
SpringCloud学习笔记（1）- Spring Cloud Netflix
文章目录 SpringCloud学习笔记(1)- Spring Cloud Netflix 单体应用存在的问题 Spring Cloud Eureka Eureka Server代码实现 Eureka ...

SpringCloud学习之：eureka整合seata