準(zhǔn)備

名稱	版本
Nacos	1.4.5
seata	1.4.0
alibabacloud	2.2.5.RELEASE

• 本博客版本

seata官網(wǎng)地址
seata安裝包下載

• 沒(méi)有l(wèi)inux服務(wù)器，可本地搭建玩一下
• 注意alibaba版本跟seata版本一定要嚴(yán)格控制，不然會(huì)出現(xiàn)一些奇奇怪怪的問(wèn)題

默認(rèn)數(shù)據(jù)存儲(chǔ)分為2鐘，一種是存在bin目錄下的root.data文件里面，還有一種是db方式，本文使用db模式

調(diào)整db配置

• 注意mysql數(shù)據(jù)庫(kù)的版本得5.7以上。-
• 修改配置文件之前，別慌，先copy一遍再說(shuō)，養(yǎng)成好習(xí)慣
  
• 調(diào)整模式為db, 修改db對(duì)應(yīng)的配置

準(zhǔn)備創(chuàng)建數(shù)據(jù)庫(kù)

mysql腳本下載地址

• 先把整個(gè)項(xiàng)目下載，然后到這個(gè)目錄下，找到mysql.sql

seata配置nacos

• 先備份一下配置文件
  
• 刪除其他沒(méi)有用的配置，調(diào)整一下配置

配置confi.txt

到之前下載好的依賴包中copy對(duì)應(yīng)的config.txt文件，放到seata目錄下

• 修改存儲(chǔ)類型
  
• 調(diào)整為自己對(duì)應(yīng)的url地址，以及賬號(hào)和密碼

下載向nacos推送配置的腳本

• 將該腳本移動(dòng)到seata的conf配置下
  

sh nacos-config.sh -h 127.0.0.1 -p 8848 -g SEATA_GROUP -t seata -u nacos -w nacos
# h: nacos服務(wù)ip.
# p: nacos服務(wù)端口號(hào).
# g: 想要的分組信息.
# t: 第一步新建的命名空間.
# u: nacos登錄名.
# w: nacos登錄密碼

如果是本地沒(méi)有做任務(wù)的修改，直接運(yùn)行就行

• 大概運(yùn)行5分鐘左右
  
• 很奇葩的設(shè)計(jì)，搞不懂為什么不單獨(dú)弄一個(gè)文件來(lái)存儲(chǔ)所有的內(nèi)容，而是key value的方式，看起來(lái)很亂，建議單獨(dú)創(chuàng)建一個(gè)seata的命令空間用來(lái)存儲(chǔ)這些配置

啟動(dòng)seata

• window啟動(dòng)用bat文件
  
• 可以看出默認(rèn)端口為8091，也可以自定義
  
• 在服務(wù)列表中，就可以看到多了一個(gè)seata-server的服務(wù)
• 因?yàn)閣indow版本，不好演示集群方式，所以我這里的集群數(shù)量是1

新建項(xiàng)目

在之前的基礎(chǔ)上新增一個(gè)seata項(xiàng)目

• 注意，新增后，該項(xiàng)目是沒(méi)有藍(lán)點(diǎn)的
  

• 添加+號(hào)，解決藍(lán)點(diǎn)問(wèn)題
  

• 自己手動(dòng)補(bǔ)一下seata這個(gè)目錄

• 創(chuàng)建模塊order-seata和stock-seata

order-seata項(xiàng)目 訂單項(xiàng)目

• 新增這兩個(gè)項(xiàng)目

• 庫(kù)存項(xiàng)目的結(jié)構(gòu)

數(shù)據(jù)庫(kù)腳本

create database seata_order;
use seata_order;CREATE TABLE `order_tbl` (`id` int(11) NOT NULL AUTO_INCREMENT,`product_id` varchar(200) DEFAULT NULL,`total_amount` decimal(10,3) DEFAULT NULL,`statu` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8

• 新增數(shù)據(jù)庫(kù)

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.lcs.springcloud</groupId><artifactId>springcloudalibaba</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>order-nacos</artifactId><packaging>jar</packaging><dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>3.8.1</version><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><exclusions><exclusion><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId></exclusion></exclusions></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><exclusions><exclusion><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-netflix-ribbon</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency></dependencies><build><finalName>order</finalName></build>
</project>

application.yml

server:port: 8190spring:application:name: order-seatacloud:nacos:discovery:namespace: publicserver-addr: localhost:8848username: nacospassword: nacosdatasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:db-type: mysqldriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://192.168.10.108:3306/seata_order?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useCursorFetch=trueusername: rootpassword: 12312312
mybatis:mapper-locations: classpath:mapper/*.xml

啟動(dòng)類

package com.lcs.springcloud;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication
@MapperScan("com.lcs.springcloud.dao")
@EnableFeignClients
public class OrderSeataApplication {public static void main(String[] args) {SpringApplication.run(OrderSeataApplication.class);}
}

實(shí)體類

package com.lcs.springcloud.entity;import java.math.BigDecimal;public class OrderTbl {private Integer id;private String product_id;private BigDecimal total_amount;private Integer statu;public OrderTbl() {}public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getProduct_id() {return product_id;}public void setProduct_id(String product_id) {this.product_id = product_id;}public BigDecimal getTotal_amount() {return total_amount;}public void setTotal_amount(BigDecimal total_amount) {this.total_amount = total_amount;}public Integer getStatu() {return statu;}public void setStatu(Integer statu) {this.statu = statu;}@Overridepublic String toString() {return "OrderTbl{" +"id=" + id +", product_id='" + product_id + '\'' +", total_amount=" + total_amount +", statu=" + statu +'}';}
}

dao類

package com.lcs.springcloud.dao;import com.lcs.springcloud.entity.OrderTbl;
import org.springframework.stereotype.Repository;@Repository
public interface OrderDao {void insert(OrderTbl orderTbl);
}

service類

package com.lcs.springcloud.service;import com.lcs.springcloud.dao.OrderDao;
import com.lcs.springcloud.entity.OrderTbl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class OrderService {@AutowiredOrderDao orderDao;public void insert(OrderTbl orderTbl) {orderDao.insert(orderTbl);}
}

controller類

package com.lcs.springcloud.controller;import com.lcs.springcloud.entity.OrderTbl;
import com.lcs.springcloud.feign.StockOpenFeign;
import com.lcs.springcloud.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.math.BigDecimal;@RestController
@RequestMapping("/order")
public class OrderController {@AutowiredOrderService orderService;@AutowiredStockOpenFeign stockOpenFeign;@RequestMapping("/add")public String add(){OrderTbl orderTbl = new OrderTbl();orderTbl.setProduct_id("10");orderTbl.setTotal_amount(new BigDecimal(3000));orderTbl.setStatu(0);orderService.insert(orderTbl);String reduct = stockOpenFeign.reduct(orderTbl.getProduct_id());return "add order "+reduct;}
}

feign類

package com.lcs.springcloud.controller;import com.lcs.springcloud.entity.OrderTbl;
import com.lcs.springcloud.feign.StockOpenFeign;
import com.lcs.springcloud.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.math.BigDecimal;@RestController
@RequestMapping("/order")
public class OrderController {@AutowiredOrderService orderService;@AutowiredStockOpenFeign stockOpenFeign;@RequestMapping("/add")public String add(){OrderTbl orderTbl = new OrderTbl();orderTbl.setProduct_id("10");orderTbl.setTotal_amount(new BigDecimal(3000));orderTbl.setStatu(0);orderService.insert(orderTbl);String reduct = stockOpenFeign.reduct(orderTbl.getProduct_id());return "add order "+reduct;}
}

mapper類

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lcs.springcloud.dao.OrderDao"><!-- 主鍵自增長(zhǎng)的插入 --><insert id="insert" parameterType="com.lcs.springcloud.entity.OrderTbl" useGeneratedKeys="true" keyProperty="id">insert into order_tbl(product_id,total_amount,statu) values(#{product_id},#{total_amount},#{statu});</insert>
</mapper>

stock-seata 庫(kù)存項(xiàng)目

數(shù)據(jù)庫(kù)腳本

 create database seata_stock;
use seata_stock;CREATE TABLE `stock_tbl` (`id` int(11) NOT NULL AUTO_INCREMENT,`product_id` varchar(200) DEFAULT NULL,`count` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8INSERT INTO `seata_stock`.`stock_tbl` (`id`, `product_id`, `count`) VALUES (1, '10', 100);

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.lcs.springcloud</groupId><artifactId>springcloudalibaba</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>stock-seata</artifactId><packaging>jar</packaging><dependencies><!-- Nacos服務(wù)注冊(cè)發(fā)現(xiàn)--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!--繼承了父項(xiàng)目，不需要添加版本號(hào)--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- jdbc --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId><version>2.3.5.RELEASE</version></dependency><!-- mybatis --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.2</version><!-- 排除沖突的jar包文件--><exclusions><exclusion><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></exclusion></exclusions></dependency><!--Mysql驅(qū)動(dòng)器--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.18</version><scope>runtime</scope></dependency><!-- druid--><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.9</version></dependency></dependencies><build><finalName>order-seata</finalName></build>
</project>

application.yml

server:port: 8200spring:application:name: stock-seatacloud:nacos:discovery:namespace: publicserver-addr: localhost:8848username: nacospassword: nacosdatasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:db-type: mysqldriver-class-name: com.mysql.jdbc.Driver#url: jdbc:mysql://10.153.96.31:3306/iomm-collection?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useCursorFetch=trueurl: jdbc:mysql://112.74.51.171:3306/seata_stock?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useCursorFetch=trueusername: rootpassword: Zy_746498
mybatis:mapper-locations: classpath:mapper/*.xml

啟動(dòng)類

package com.lcs.springcloud;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@MapperScan("com.lcs.springcloud.dao")
public class StockSeataApplication {public static void main(String[] args) {SpringApplication.run(StockSeataApplication.class,args);}
}

實(shí)體類

package com.lcs.springcloud.entity;public class StockTbl {private Integer id;private String product_id;private Integer count;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getProduct_id() {return product_id;}public void setProduct_id(String product_id) {this.product_id = product_id;}public Integer getCount() {return count;}public void setCount(Integer count) {this.count = count;}
}

dao類

package com.lcs.springcloud.dao;import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;@Repository
public interface StockDao {void updateStock(@Param("product_id")String product_id);
}

service類

package com.lcs.springcloud.service;import com.lcs.springcloud.dao.StockDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class StockService {@AutowiredStockDao stockDao;public String updateStock(String product_id) {try {stockDao.updateStock(product_id);return "扣減庫(kù)存成功";}catch (Exception e){return "更新庫(kù)存失敗";}}
}

controller類

package com.lcs.springcloud.controller;import com.lcs.springcloud.service.StockService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/stock")
public class StockController {@AutowiredStockService stockService;@Value("${server.port}")String port;@RequestMapping("/reduct")public String reduct(@RequestParam(value = "product_id") String product_id){return stockService.updateStock(product_id);}}

mapper類

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lcs.springcloud.dao.StockDao"><!-- 主鍵自增長(zhǎng)的插入 --><update id="updateStock"  parameterType="java.lang.String" >update stock_tbl  SET count= count-1 where product_id=#{product_id}</update>
</mapper>

測(cè)試

前提： 保持已經(jīng)開(kāi)啟nacos，不知道的可以先學(xué)習(xí)一下nacos

• 訂單表 默認(rèn)為空
  
• 庫(kù)存表默認(rèn)為100個(gè)庫(kù)存

運(yùn)行http://localhost:8190/order/add

結(jié)果如下：

• 訂單表新增一條記錄，庫(kù)存表-1，說(shuō)明項(xiàng)目搭建成功

特殊情況

已知： order和stock是兩個(gè)庫(kù)
把order的controller代碼，改一下

package com.lcs.springcloud.controller;import com.lcs.springcloud.entity.OrderTbl;
import com.lcs.springcloud.feign.StockOpenFeign;
import com.lcs.springcloud.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.math.BigDecimal;@RestController
@RequestMapping("/order")
public class OrderController {@AutowiredOrderService orderService;@AutowiredStockOpenFeign stockOpenFeign;@RequestMapping("/add")@Transactionalpublic String add(){OrderTbl orderTbl = new OrderTbl();orderTbl.setProduct_id("10");orderTbl.setTotal_amount(new BigDecimal(3000));orderTbl.setStatu(0);//1. 插入訂單orderService.insert(orderTbl);//2. 扣減庫(kù)存String reduct = stockOpenFeign.reduct(orderTbl.getProduct_id());// 3. 出現(xiàn)問(wèn)題int a= 1/0;return "add order "+reduct;}
}

• 都知道0不能作為分母，必報(bào)錯(cuò)， 大家說(shuō)一下這個(gè)接口是多少？
  訂單插入進(jìn)行了回滾，庫(kù)存表進(jìn)行扣減庫(kù)存，為什么？
  這是因?yàn)?#64;transaction事物是不支持跨庫(kù)回滾的。

分布式事務(wù)

代碼版本在上續(xù)上面做改動(dòng)，請(qǐng)保證上面能先運(yùn)行后， 再看該步驟

order-seata項(xiàng)目變動(dòng)

pom.xml

 <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><version>2.2.5.RELEASE</version></dependency><dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>3.3.0</version></dependency>

• 為什么加了一個(gè)cglib的包？
  
• 報(bào)cg相關(guān)的一個(gè)錯(cuò)，猜測(cè)估計(jì)是依賴沖突的問(wèn)題，查了一下項(xiàng)目依賴，發(fā)現(xiàn)只有可能cglib的問(wèn)題
  

application.yml

server:port: 8190spring:application:name: order-seatacloud:nacos:discovery:namespace: publicserver-addr: localhost:8848username: nacospassword: nacosalibaba:seata:tx-service-group: default_tx_groupdatasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:db-type: mysqldriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/seata_order?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useCursorFetch=trueusername: rootpassword: 123456
mybatis:mapper-locations: classpath:mapper/*.xmlseata:registry:#配置seata的注冊(cè)中心type: nacosnacos:### nacos服務(wù)器地址server-addr: localhost:8848username: nacospassword: nacos### nacos服務(wù)名application: seata-serverconfig:type: nacosnacos:### nacos服務(wù)器地址server-addr: localhost:8848username: nacospassword: nacosgroup: SEATA_GROUP

• 為什么叫這個(gè)名字，看自己seata-server的配置
  
  
• 這里標(biāo)紅的，就是我們需要填寫的名字，在網(wǎng)上可以查到很多叫g(shù)uangzhou的，這是因?yàn)閯e人重命名咯

controller

• 注解改為@GlobalTransactional，表示是分布式事務(wù)

stock-seata項(xiàng)目變動(dòng)

pom.xml

 <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><version>2.2.5.RELEASE</version></dependency><dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>3.3.0</version></dependency>

application.yml

server:port: 8200spring:application:name: stock-seatacloud:nacos:discovery:namespace: publicserver-addr: localhost:8848username: nacospassword: nacosalibaba:seata:tx-service-group: default_tx_groupdatasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:db-type: mysqldriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/seata_stock?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useCursorFetch=trueusername: rootpassword: 123456
mybatis:mapper-locations: classpath:mapper/*.xmlseata:registry:#配置seata的注冊(cè)中心type: nacosnacos:### nacos服務(wù)器地址server-addr: localhost:8848username: nacospassword: nacos### nacos服務(wù)名application: seata-serverconfig:type: nacosnacos:### nacos服務(wù)器地址server-addr: localhost:8848username: nacospassword: nacosgroup: SEATA_GROUP

• 跟order項(xiàng)目類似，就是client跟seata以及nacos進(jìn)行通信

腳本

CREATE TABLE `undo_log` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`branch_id` bigint(20) NOT NULL,`xid` varchar(100) NOT NULL,`context` varchar(128) NOT NULL,`rollback_info` longblob NOT NULL,`log_status` int(11) NOT NULL,`log_created` datetime NOT NULL,`log_modified` datetime NOT NULL,`ext` varchar(100) DEFAULT NULL,PRIMARY KEY (`id`),UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

• 涉及到分布式事務(wù)的庫(kù)，都需要新增該undo-log得表，他會(huì)記錄修改前，以及修改后的sql，以便逆向回滾
• 例如你執(zhí)行了新增，逆向就是刪除

效果

• order表
  
• 庫(kù)存表

執(zhí)行http://localhost:8190/order/add，查看數(shù)據(jù)庫(kù)，出現(xiàn)異常后

• 之前使用@transation是，訂單回滾，庫(kù)存減咯
• 選擇使用@globaTransation注解，訂單回滾，庫(kù)存不變

分布式事務(wù)原理

nacos配置問(wèn)題

啟動(dòng)后，在bin下面多了一個(gè)store開(kāi)頭的文件夾，why?
我不是改成db模式嗎？為什么配置沒(méi)有生效，查了半天，才發(fā)現(xiàn)nacos的配置，竟然是默認(rèn)的

• 搜索store.mode*改成db

啟動(dòng)項(xiàng)目后，竟然報(bào)數(shù)據(jù)庫(kù)的一個(gè)錯(cuò)誤，怎么可能，我數(shù)據(jù)庫(kù)的配置，都是copy的項(xiàng)目里面，不可能出問(wèn)題，那原因只有一個(gè)，就是nacos里面的初始化配置又有問(wèn)題

• 修改nacos這三個(gè)的配置，再啟動(dòng)項(xiàng)目，seata得bin下面，沒(méi)有文件夾生成，說(shuō)明切換成db模式成功

seata的幾個(gè)表都是什么情況

• seata的表

• 這是seata的一個(gè)流程圖
  
• 輸入http://localhost:8190/order/add，在進(jìn)入方法的時(shí)候打入斷點(diǎn)
  
  
• global_table表生成了一個(gè)xid 拼接方式是ip+端口再加一個(gè)唯一id
• xid 全局事務(wù)id
• application_id 應(yīng)用id
• transaction_service_group 分組
• transaction_name 事物加在那個(gè)方法上面（以前有個(gè)版本會(huì)標(biāo)注在具體類具體方法），新版本后，變動(dòng)了，好奇他底層是什么映射的，知道的，可以下方交流一下
  
• 斷點(diǎn)執(zhí)行到這里
  
• branch_table 表新增了一條數(shù)據(jù)，這個(gè)是分支Xid
  
• 訂單庫(kù)的undo-log，也新增了一條數(shù)據(jù)
  
• lock_table表變化會(huì)存儲(chǔ)鎖表的信息
• pk就是主鍵的id

#到order庫(kù)調(diào)用該sql，查看blob存放的內(nèi)容
select CONVERT(t.rollback_info USING utf8) from undo_log t

• 如下圖
  
• 因?yàn)槭遣迦胝Z(yǔ)句，所以beforeImage之前是沒(méi)有數(shù)據(jù)的，afterImage存放的就是修改后的數(shù)據(jù)

斷點(diǎn)走完后，所有的seata表數(shù)據(jù)都會(huì)回滾，如果遇到異常退出的情況，請(qǐng)先清空表數(shù)據(jù)

代碼下載