SpringBoot基于Dubbo和Seata的分布式事务解决方案

浅浅的花香味﹌ 2022-12-14 03:41 180阅读 0赞

## 一、分布式事务初探 ##

一般来说，目前市面上的数据库都支持本地事务，也就是在你的应用程序中，在一个数据库连接下的操作，可以很容易的实现事务的操作。

但是目前，基于SOA的思想，大部分项目都采用微服务架构后，就会出现了跨服务间的事务需求，这就称为分布式事务。

> 分布式事务的问题在面试时遇到的也不少吧！也有不少的小伙伴在面试时受挫，所以我这整理有大量的Java方面的面试资料，针对面试时会遇到的各种问题，有需要的小伙伴可以[点击进入，暗号：cscf][cscf]，免费提供！

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center]

**（1） 什么是分布式事务**

对于传统的单体应用而言，实现本地事务可以依赖Spring的@Transactional注解标识方法，实现事务非常简单。

我们以最常见的电商系统为例，简单拆分为用户客户端、订单服务、库存服务、商品服务等等，在用户下单过程中，需要同时调用各个服务，但是，每个服务都是独立部署的，数据库连接是不共享的，因此要保证这些操作全部执行，或者全部不执行，就需要分布式事务的支持。

**（2）分布式事务解决方案**

*  全局事务，基于DTP模型实现，需要三种角色即Application 应用系统，Transaction Manager事务管理器，Resource Manager资源管理器；
 *  基于可靠消息服务的分布式事务，通过消息队列实现事务的一致性；
 *  TCC，即Try、Confirm、Cancel，属于补偿型分布式事务，Try：尝试待执行的事务，Confirm：执行事务，Cancel：取消执行的事务；

**（3）Seata介绍**

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。Seata 于2019.1正式对外开源，前身是阿里巴巴2014年诞生的 TXC（Taobao Transaction Constructor）。以下是Seata官网介绍的特色服务：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_16_color_FFFFFF_t_70_pic_center]  
Seata 将为用户提供了 AT、TCC 和 XA 事务模式，为用户打造一站式的分布式解决方案。更多关于Seata的介绍，可参考其官网。

## 二、Spring Boot，Dubbo和Seata实现分布式事务案例 ##

**（1）环境准备**

运行本测试，需要你提前准备如下的软件运行环境：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 1]  
本案例，主要模仿简单的下单扣减库存的过程，架构图如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_16_color_FFFFFF_t_70_pic_center 1]  
**（2） Seata管理端**

下载Seata的最新版本，并解压后，进入seata/bin目录，启动：

sh seata-server.sh 8091 file

观察8091端口是否启动。

**（3）数据存储**

本测试服务，需要创建两张表，分别是订单表和库存表：

CREATE TABLE `t_order` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `order_no` varchar(255) DEFAULT NULL,
      `user_id` varchar(255) DEFAULT NULL,
      `commodity_code` varchar(255) DEFAULT NULL,
      `count` int(11) DEFAULT '0',
      `amount` double(14,2) DEFAULT '0.00',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
    
    CREATE TABLE `t_storage` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `commodity_code` varchar(255) DEFAULT NULL,
      `name` varchar(255) DEFAULT NULL,
      `count` int(11) DEFAULT '0',
      PRIMARY KEY (`id`),
      UNIQUE KEY `commodity_code` (`commodity_code`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

**（4） 构建Spring Boot服务**

示例代码可参考Github仓库，仓库的目录结构如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 2]

*  springboot-base：存储公共调用的基类接口，mapper接口，Model层的类等，可mvn install后，供另外三个module调用。
 *  springboot-dubbo-storage：库存服务；
 *  springboot-dubbo-order：订单服务；
 *  springboot-dubbo-client：RPC消费者，提供对外接口；

加入Seata组件后，与普通Dubbo项目的不同之处在于：

1、配置Seata数据源

/** * seata数据源 * * init datasource proxy * @Param: druidDataSource datasource bean instance * @Return: DataSourceProxy datasource proxy */
    @Bean
    public DataSourceProxy dataSourceProxy(DruidDataSource druidDataSource){ 
        return new DataSourceProxy(druidDataSource);
    }

2、Seata初始化

/** * 配置全局事务扫描器。有两个参数，一个是应用名称，一个是事务分组 * * @return */
    @Bean
    public GlobalTransactionScanner globalTransactionScanner() { 
        return new GlobalTransactionScanner("springboot-dubbo-storage", "my_test_tx_group");
    }

3、配置注册中心，目前可用的配置中心有file、nacos 、apollo、zk、consul，file类型本身不具备注册中心的动态发现和动态配置功能，官方的初衷是在不依赖第三方配置注册中心的基础上快速集成测试seata功能。配置内容在file.conf和registry.conf。

4、注解标记事务方法，在需要分布式事务的方法上，加上@GlobalTransactional注解即可。

**（5） 测试**

依次启动Seata、springboot-dubbo-storage、springboot-dubbo-order、springboot-dubbo-client后，打开postman测试，配置测试参数为：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 3]  
可以看到，在addOrder报错后，会有全局事务的rollback过程。

## 结语： ##

文章在这结束了！有写的不好的地方，请悄咪咪的告诉我，然后我改，因为我也是要面子的！  
但是写的差不代表资料差！我这还有大量的Java学习资料和教程！全部都可以 **免费** 分享，有需要的小伙伴可以[点击进入，暗号：cscf][cscf 1]

> 这只是其中的一点点哦！  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 4]

[cscf]: https://jq.qq.com/?_wv=1027&k=c0EMH2TJ
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center]: /images/20221123/5bc9a81df0c84d40879843e3cc021be7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/4c626e10123b486dbf5a43754e7a5f8f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 1]: /images/20221123/3e0cadad24c84cc48acd3c462cab6b5b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/6da8ba34fb814729acdb75f3cc5c2019.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 2]: /images/20221123/1db28faaa3a74256bf51a79abcb304f3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 3]: /images/20221123/8e5db81cc7914d3887b0c111a4be4037.png
[cscf 1]: https://jq.qq.com/?_wv=1027&k=ttbZ9yhO
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjcwNjY3_size_1_color_FFFFFF_t_70_pic_center 4]: /images/20221123/3e5965784272485b8371abdef2d6ce0e.png