持续创造，加快成长！这是我参加「日新计划 10 月更文挑战」的第15天，点击检查活动详情

每日英语:

The only way to achieve the impossible is to believe it is possible.

翻译：完成不或许的仅有办法就是要信任凡事皆有或许。 ——《爱丽丝梦游仙境2》

Seata分布式业务

微服务架构，服务间调用呈现反常是会呈现业务问题的，并且是跨服务间的业务问题（分布式业务），前五弹尽管解说了业务以及分布式业务相关知识点，但分布式业务究竟该怎么处理呢？

订单问题分析

1、查询购物车记载
2、库存递减   ->mall-goods-service服务
3、订单明细
4、增加订单   ->当时服务 本地业务(mall-order-service)
5、删去购物车记载  ->mall-cart-service

上面是我们订单的具体操作过程，整个看起来没有任何问题，但其实存在业务问题，假如上述操作1和2都操作成功了，可是3操作产生反常，2是可依据反常完成本地业务回滚，但1处是无法完成本地业务回滚的，由于它跨应用了，操作流程现已完毕。这个问题就是我们说的分布式业务问题。可以选用当时干流分布式业务处理方案Seata来处理。

Seata介绍

分布式事务第六弹——Seata分布式事务

Seata 是一款开源的分布式业务处理方案，致力于在微服务架构下供给高性能和简略易用的分布式业务服务。在 Seata 开源之前，Seata 对应的内部版本在阿里经济体内部一向扮演着分布式一致性中间件的角色，协助经济体平稳的度过历年的双11，对各BU业务进行了有力的支撑。经过多年沉积与积累，商业化产品先后在阿里云、金融云进行售卖。2019.1 为了打造更加完善的技能生态和普惠技能成果，Seata 正式宣告对外开源，开放以来，广受欢迎，不到一年现已成为最受欢迎的分布式业务处理方案。

分布式事务第六弹——Seata分布式事务

Seata AT形式

Seata 将为用户供给了 AT、TCC、SAGA 和 XA 业务形式，为用户打造一站式的分布式处理方案。其间AT形式最受欢迎，使用也非常简略，但它内涵的原理不简略。

AT形式前提：

1:基于支撑本地 ACID 业务的关系型数据库。
2:Java 应用，经过 JDBC 拜访数据库。

全体机制： 2PC协议的演变

1PC:业务数据和回滚日志记载在同一个本地业务中提交，释放本地锁和衔接资源。
2PC:
    1)提交异步化，非常快速地完成。
    2)回滚经过一阶段的回滚日志进行反向补偿。

AT形式作业机制

分布式事务第六弹——Seata分布式事务

以一个示例来说明整个 AT 分支的作业过程。

业务表：product

Field Type Key
id bigint(20) PRI
name varchar(100)
since varchar(100)

履行修正操作：（SQL句子如下）

update product set name = 'xz2' where name = 'xz';

1PC:

a.解析SQL句子，得到类型为UPDATE,表为product，条件where name = 'xz'。

b.依据解析的SQL句子进行要操作的成果查询：

select * product where name ='xz'

得到的修正前数据成果如下：

id name since
1 xz 2022

c.履行业务SQL

查询修正后的成果：

select id, name, since from product where id = 1;

查询修正后的数据成果如下：

id name since
1 xz2 2022

d. 镜像备份

将修正前的成果和修正后的成果增加到数据库表undo_log中。

e. 提交前，向TC注册分支恳求product表中id=1的数据的大局锁。

f. 本地业务提交。

8. 本地业务提交成果上报给TC。

2PC-提交：

a. 收到 TC 的分支提交恳求，把恳求放入一个异步使命的行列中，马上返回提交成功的成果给 TC。

b. 异步使命阶段的分支提交恳求将异步和批量地删去相应 UNDO LOG 记载。

2PC-回滚：

a. 收到 TC 的分支回滚恳求，敞开一个本地业务，履行如下操作。

b. 经过 XID 和 Branch ID 查找到相应的 UNDO LOG 记载。

c. 数据校验：拿 UNDO LOG 中的后镜与当时数据进行比较，假如有不同，说明数据被当时大局业务之外的动作做了修正。这种情况，需求依据装备策略来做处理，详细的说明在另外的文档中介绍。

d. 依据 UNDO LOG 中的前镜像和业务 SQL 的相关信息生成并履行回滚的句子：

update product set name = 'xz' where id = 1;

e. 提交本地业务。并把本地业务的履行成果（即分支业务回滚的成果）上报给 TC。

undo_log表，在每个需求履行分布式业务操作的数据库中增加

-- 注意此处0.7.0+ 增加字段 context
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,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

订单分布式业务

首先我们需求装置seata-server，我们选用docker方式装置：

docker run --name seata-server -p 8091:8091 -d  seataio/seata-server:1.0.0

分布式业务装备过程依照如下操作：

1:需求履行分布式业务的工程中引入依靠包spring-cloud-starter-alibaba-seata
2:装备署理数据源DataSourceProxy
3:将MyBatisPlus数据源切换成署理数据源
4:指定seata-server装备
    a.导入file.conf
    b.导入register.conf
5:装备工程中的分布式业务组
6:开端履行分布式业务的办法上增加注解@GlobalTransactional

1)导入依靠包

在mall-order-service和mall-goods-service中引入如下依靠包：

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

2)装备有理数据源

在mall-order-service和mall-goods-service中创立如下装备类：

@Configuration
public class SeataDataSourceConfig {
​
  @Bean
  @ConfigurationProperties(prefix = "spring.datasource")
  public DataSource druidDataSource() {
    return new DruidDataSource();
   }
  //创立署理数据源
  @Bean
  public DataSourceProxy dataSourceProxy(DataSource druidDataSource) {
    return new DataSourceProxy(druidDataSource);
   }
​
  //替换MybatisSqlSessionFactoryBean的DataSource
  @Bean
  public MybatisSqlSessionFactoryBean sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
    // 这儿用 MybatisSqlSessionFactoryBean 替代了 SqlSessionFactoryBean，不然 MyBatisPlus 不会生效
    MybatisSqlSessionFactoryBean mybatisSqlSessionFactoryBean = new MybatisSqlSessionFactoryBean();
    mybatisSqlSessionFactoryBean.setDataSource(dataSourceProxy);
    return mybatisSqlSessionFactoryBean;
   }
}

3)导入装备文件

将file.conf和registry.conf导入到mall-order-service和mall-goods-service的resources下，一起装备mall-order-service和mall-goods-service的bootstrap.yml文件，在该文件中增加如下装备：

   alibaba:
    seata:
     tx-service-group: tx_shop

文件参考如下：

file.conf:

service {
  #vgroup->rgroup
  vgroup_mapping.tx_shop = "default"
  #only support single node
  default.grouplist = "192.168.xxx.xxx:8091"
  #degrade current not support
  enableDegrade = false
  #disable
  disable = false
}

registry.conf:

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  type = "file"
​
  file {
   name = "file.conf"
  }
}
​
config {
  # file、nacos 、apollo、zk、consul、etcd3、springCloudConfig
  type = "file"
​
  file {
   name = "file.conf"
  }
}

4)增加注解@GlobalTransactional

在com.xz.mall.order.service.impl.OrderServiceImpl#add办法上增加注解@GlobalTransactional

总结

本篇首要介绍了一下Seata分布式业务是怎么处理实际开发过程中遇到的跨库业务问题的，侧重介绍了一下AT形式作业机制，期望大家在往后的开发作业中能够去体验一下基于Seata的分布式业务操作。