SpringCloudAlibaba技术栈学习（八）Seata分布式事务解决方案
第八章 Seata-分布式事务
代码地址：源码地址
1. 事务简介
事务特性：
A：原子性(Atomicity)，一个事务中的所有操作，要么全部完成，要么全部不完成
B：一致性(Consistency)，在一个事务执行之前和执行之后数据库都必须处于一致性状态
C：隔离性(Isolation)，在并发环境中，当不同的事务同时操作相同的数据时，事务之间互不影响
D：持久性(Durability)，指的是只要事务成功结束，它对数据库所做的更新就必须永久的保存下来
分布式架构下的事务问题：一个大事务下可能涉及到多个微服务需要进行数据库操作，可能一个微服务操作成功，一个操作失败，不好保证事务的一致性，原子性。
2. 分布式事务解决方案
2.1 全局事务
需要三种角色：
AP: Application 应用系统 (微服务)
TM: Transaction Manager 事务管理器 (全局事务管理)
RM: Resource Manager 资源管理器 (数据库)
借用教程里的图片，教程地址：视频地址
表决，执行
2.2 可靠消息服务
利用第六章说到的MQ事务消息，解决分布式事务问题。
在第六章，我们实现的是order+user两个微服务的事务消息，这里再加一个product减库存的事务进去，实现步骤：
①在product模块创建service类，继承RocketMQListener<>泛型里填消息传来的对象类，Order
②添加注解RocketMQMessageListener指定监听的消息主题
③重写onMessage方法，实现减库存操作。代码如下：
@Service
@RocketMQMessageListener(
consumerGroup = "shop-user"
,topic = "order-topic"
)
public class ReduceInventoryService implements RocketMQListener<Order> {
@Autowired
ProductService productService;
@Override
public void onMessage(Order order) {
productService.reduceInventory(order.getPid(),order.getNumber());
}
}
2.3 最大努力通知
略
2.4 TCC事务
Try，Confirm，Cancel类似于全局事务
3. Seata
3.1 Seata整合
①首先下载seata，下载地址
②修改配置，这部分由于各版本不同，修改的地方也不尽相同。大概就是把类型设置成nacos还有加入service.vgroup_mapping.service-order=default这种格式的配置，和微服务一一对应。
③初始化配置：
cd conf
nacos-config.sh 127.0.0.1
初始化完成后，可以在nacos的配置列表中看到很多seata的配置。
④启动seate
cd bin
seata-server.bat -p 9000 -m file
启动成功后可以在nacos的服务列表中看到seata的服务。serverAddr
⑤在数据库中创建表：
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 = 1
DEFAULT CHARSET = utf8;
⑥在微服务中引入依赖：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
⑦在各个微服务的config包下编写配置类：
@Configuration
public class DataSourceProxyConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DruidDataSource druidDataSource() {
return new DruidDataSource();
}
@Primary
@Bean
public DataSourceProxy dataSource(DruidDataSource druidDataSource) {
return new DataSourceProxy(druidDataSource);
}
}
⑧把seata conf路径下的的registry.conf文件复制到各个微服务的resource包中。
⑨修改各个微服务的bootstrap文件，使其读取seata的配置。（这里微服务自己的配置不知道怎么放到nacos上去了，只能放在application.yml里面）
spring:
application:
name: service-product
cloud:
nacos:
config:
server-addr: localhost:8848 # nacos的服务端地址
namespace: public
group: SEATA_GROUP
alibaba:
seata:
tx-service-group: ${spring.application.name}
⑩在事务的开始添加注解@GlobalTransactional即可利用seata完成分布式事务的处理。
3.2 Seata运行流程
把分布式事务看成微服务调用微服务的过程，在事务开始的地方注册了一个全局的XID，之后每条分支的XID都与之相等。
在微服务调用另一个微服务时，由被调用的微服务注册分支事务，产生一个BranchID，这个分支事务的BranchID是独一无二的，但是XID和这条链路上的其他分支一样。
分支事务之中undo_log和业务逻辑共同操作，undo_log记录业务逻辑操作数据库前后的状态。
当分支事务处理完后，会上报处理结果，由TC判断是否回滚，
本文地址：https://blog.csdn.net/qq_41109942/article/details/107573333