SpringBoot+Nacos+Seata实现Dubbo分布式事务管理

电玩女神 2024-04-18 08:54 83阅读 0赞

## 1.简介 ##

> 本文主要介绍SpringBoot2.1.5 + Dubbo 2.7.3 + Mybatis 3.4.2 + Nacos 1.1.3 +Seata 0.8.0整合来实现Dubbo分布式事务管理，使用Nacos 作为 Dubbo和Seata的注册中心和配置中心,使用 MySQL 数据库和 MyBatis来操作数据。

如果你还对`SpringBoot`、`Dubbo`、`Nacos`、`Seata`、`Mybatis` 不是很了解的话，这里我为大家整理个它们的官网网站，如下

*  SpringBoot：[https://spring.io/projects/spring-boot][https_spring.io_projects_spring-boot]
 *  Dubbo：[http://dubbo.apache.org/en-us/][http_dubbo.apache.org_en-us]
 *  Nacos：[https://nacos.io/zh-cn/docs/quick-start.html][https_nacos.io_zh-cn_docs_quick-start.html]
 *  Seata：[https://github.com/seata/seata/wiki/Home\_Chinese][https_github.com_seata_seata_wiki_Home_Chinese]
 *  MyBatis：[http://www.mybatis.org/mybatis-3/zh/index.html][http_www.mybatis.org_mybatis-3_zh_index.html]

在这里我们就不一个一个介绍它们是怎么使用和原理，详细请学习官方文档，在这里我将开始对它们进行整合，完成一个简单的案例，来让大家了解`Seata`来实现`Dubbo`分布式事务管理的基本流程。

## 2.环境准备 ##

## 2.1 下载nacos并安装启动 ##

nacos下载：[https://github.com/alibaba/nacos/releases/tag/1.1.3][https_github.com_alibaba_nacos_releases_tag_1.1.3]

Nacos 快速入门：[https://nacos.io/en-us/docs/quick-start.html][https_nacos.io_en-us_docs_quick-start.html]

sh startup.sh -m standalone

在浏览器打开Nacos web 控制台：http://192.168.10.200:8848/nacos/index.html

输入nacos的账号和密码 分别为nacos：nacos

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]  
这是时候naocs 就正常启动了。

## 2.2 下载seata0.8.0 并安装启动 ##

#### 2.2.1 在 [Seata Release][] 下载最新版的 Seata Server 并解压得到如下目录： ####

.
    ├──bin
    ├──conf
    ├──file_store
    └──lib

#### 2.2.2 修改 conf/registry.conf 配置， ####

目前seata支持如下的file、nacos 、apollo、zk、consul的注册中心和配置中心。这里我们以`nacos` 为例。  
将 type 改为 nacos

registry { 
      # file nacos
      type = "nacos"
    
      nacos { 
        serverAddr = "192.168.10.200:8848"
        namespace = "public"
        cluster = "default"
      }
      file { 
        name = "file.conf"
      }
    }
    
    config { 
      # file、nacos 、apollo、zk、consul
      type = "nacos"
    
      nacos { 
        serverAddr = "192.168.10.200:8848"
        namespace = "public"
        cluster = "default"
      }
    
      file { 
        name = "file.conf"
      }
    }

*  serverAddr = “192.168.10.200:8848” ：nacos 的地址
 *  namespace = “public” ：nacos的命名空间默认为`public`
 *  cluster = “default” ：集群设置未默认 `default`

**注意： seata0.9.0之后，配置如下, 其中`namespace = ""`**

registry { 
      # file nacos
      type = "nacos"
    
      nacos { 
        serverAddr = "192.168.10.200:8848"
        namespace = ""
        cluster = "default"
      }
      file { 
        name = "file.conf"
      }
    }
    
    config { 
      # file、nacos 、apollo、zk、consul
      type = "nacos"
    
      nacos { 
        serverAddr = "192.168.10.200:8848"
        namespace = ""
      }
    
      file { 
        name = "file.conf"
      }
    }

#### 2.2.3 修改 conf/nacos-config.txt配置 ####

**注意：如果你的seata是1.1之后的版本请按照如下导入方式操作**

1.  下载[https://github.com/seata/seata/blob/develop/script/config-center/][https_github.com_seata_seata_blob_develop_script_config-center]目录下的`config.txt`文件放入到`seata-server`目录下的conf中，可更改文件名为`nacos-config.txt`。
2.  下载[https://github.com/seata/seata/tree/develop/script/config-center/nacos/][https_github.com_seata_seata_tree_develop_script_config-center_nacos]目录下的nacos-config.py文件（window可用python命令执行，linux也可执行，前提先有安装python）或者nacos-config.sh文件（window下可放在git命令行执行，linux可执行文件）

transport.type=TCP
    transport.server=NIO
    transport.heartbeat=true
    transport.thread-factory.boss-thread-prefix=NettyBoss
    transport.thread-factory.worker-thread-prefix=NettyServerNIOWorker
    transport.thread-factory.server-executor-thread-prefix=NettyServerBizHandler
    transport.thread-factory.share-boss-worker=false
    transport.thread-factory.client-selector-thread-prefix=NettyClientSelector
    transport.thread-factory.client-selector-thread-size=1
    transport.thread-factory.client-worker-thread-prefix=NettyClientWorkerThread
    transport.thread-factory.boss-thread-size=1
    transport.thread-factory.worker-thread-size=8
    transport.shutdown.wait=3
    service.vgroup_mapping.order-service-seata-service-group=default
    service.vgroup_mapping.account-service-seata-service-group=default
    service.vgroup_mapping.storage-service-seata-service-group=default
    service.vgroup_mapping.business-service-seata-service-group=default
    service.enableDegrade=false
    service.disable=false
    service.max.commit.retry.timeout=-1
    service.max.rollback.retry.timeout=-1
    client.async.commit.buffer.limit=10000
    client.lock.retry.internal=10
    client.lock.retry.times=30
    store.mode=db
    store.file.dir=file_store/data
    store.file.max-branch-session-size=16384
    store.file.max-global-session-size=512
    store.file.file-write-buffer-cache-size=16384
    store.file.flush-disk-mode=async
    store.file.session.reload.read_size=100
    store.db.driver-class-name=com.mysql.jdbc.Driver
    store.db.datasource=dbcp
    store.db.db-type=mysql
    store.db.url=jdbc:mysql://192.168.10.200:3306/seata?useUnicode=true
    store.db.user=lidong
    store.db.password=cwj887766@@
    store.db.min-conn=1
    store.db.max-conn=3
    store.db.global.table=global_table
    store.db.branch.table=branch_table
    store.db.query-limit=100
    store.db.lock-table=lock_table
    recovery.committing-retry-period=1000
    recovery.asyn-committing-retry-period=1000
    recovery.rollbacking-retry-period=1000
    recovery.timeout-retry-period=1000
    transaction.undo.data.validation=true
    transaction.undo.log.serialization=jackson
    transaction.undo.log.save.days=7
    transaction.undo.log.delete.period=86400000
    transaction.undo.log.table=undo_log
    transport.serialization=seata
    transport.compressor=none
    metrics.enabled=false
    metrics.registry-type=compact
    metrics.exporter-list=prometheus
    metrics.exporter-prometheus-port=9898
    service.default.grouplist=127.0.0.1:8091

这里主要修改了如下几项：

*  store.mode :存储模式 默认file 这里我修改为db 模式 ，并且需要三个表`global_table`、`branch_table`和`lock_table`
 *  store.db.driver-class-name： 默认没有，会报错。添加了 `com.mysql.jdbc.Driver`
 *  store.db.datasource=dbcp ：数据源 dbcp
 *  store.db.db-type=mysql : 存储数据库的类型为`mysql`
 *  store.db.url=jdbc:mysql://192.168.10.200:3306/seata?useUnicode=true : 修改为自己的数据库`url`、`port`、`数据库名称`
 *  store.db.user=lidong :数据库的账号
 *  store.db.password=cwj887766@@ :数据库的密码
 *  service.vgroup\_mapping.order-service-seata-service-group=default
 *  service.vgroup\_mapping.account-service-seata-service-group=default
 *  service.vgroup\_mapping.storage-service-seata-service-group=default
 *  service.vgroup\_mapping.business-service-seata-service-group=default

也可以在 Nacos 配置页面添加，data-id 为 service.vgroup\_mapping.$\{YOUR\_SERVICE\_NAME\}-seata-service-group, group 为 SEATA\_GROUP， 如果不添加该配置，启动后会提示no available server to connect to services-server

**注意：** 配置文件末尾有空行，需要删除，否则会提示失败，尽管实际上是成功的

***db模式下的所需的三个表的数据库脚本位于`seata\conf\db_store.sql`***

`global_table`的表结构

CREATE TABLE `global_table` (
      `xid` varchar(128) NOT NULL,
      `transaction_id` bigint(20) DEFAULT NULL,
      `status` tinyint(4) NOT NULL,
      `application_id` varchar(64) DEFAULT NULL,
      `transaction_service_group` varchar(64) DEFAULT NULL,
      `transaction_name` varchar(64) DEFAULT NULL,
      `timeout` int(11) DEFAULT NULL,
      `begin_time` bigint(20) DEFAULT NULL,
      `application_data` varchar(2000) DEFAULT NULL,
      `gmt_create` datetime DEFAULT NULL,
      `gmt_modified` datetime DEFAULT NULL,
      PRIMARY KEY (`xid`),
      KEY `idx_gmt_modified_status` (`gmt_modified`,`status`),
      KEY `idx_transaction_id` (`transaction_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

`branch_table`的表结构

CREATE TABLE `branch_table` (
      `branch_id` bigint(20) NOT NULL,
      `xid` varchar(128) NOT NULL,
      `transaction_id` bigint(20) DEFAULT NULL,
      `resource_group_id` varchar(32) DEFAULT NULL,
      `resource_id` varchar(256) DEFAULT NULL,
      `lock_key` varchar(128) DEFAULT NULL,
      `branch_type` varchar(8) DEFAULT NULL,
      `status` tinyint(4) DEFAULT NULL,
      `client_id` varchar(64) DEFAULT NULL,
      `application_data` varchar(2000) DEFAULT NULL,
      `gmt_create` datetime DEFAULT NULL,
      `gmt_modified` datetime DEFAULT NULL,
      PRIMARY KEY (`branch_id`),
      KEY `idx_xid` (`xid`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

`lock_table`的表结构

create table `lock_table` (
      `row_key` varchar(128) not null,
      `xid` varchar(96),
      `transaction_id` long ,
      `branch_id` long,
      `resource_id` varchar(256) ,
      `table_name` varchar(32) ,
      `pk` varchar(32) ,
      `gmt_create` datetime ,
      `gmt_modified` datetime,
      primary key(`row_key`)
    );

#### 2.2.4 将 Seata 配置添加到 Nacos 中 ####

使用命令如下

cd conf
    sh nacos-config.sh localhost

成功后会提示

init nacos config finished, please start seata-server

在 Nacos 管理页面应该可以看到有 59 个 Group 为SEATA\_GROUP的配置

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

#### 2.2.5 启动 Seata Server ####

使用db 模式启动

cd ..
     sh ./bin/seata-server.sh

这时候在 Nacos 的服务列表下面可以看到一个名为serverAddr的服务  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]

## 3 案例分析 ##

参考官网中用户购买商品的业务逻辑。整个业务逻辑由4个微服务提供支持：

*  库存服务：扣除给定商品的存储数量。
 *  订单服务：根据购买请求创建订单。
 *  帐户服务：借记用户帐户的余额。
 *  业务服务：处理业务逻辑。

请求逻辑架构  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]

## 3.1 github地址 ##

springboot-dubbo-seata：[https://github.com/lidong1665/springboot-dubbo-seata][https_github.com_lidong1665_springboot-dubbo-seata]

*  samples-common ：公共模块
 *  samples-account ：用户账号模块
 *  samples-order ：订单模块
 *  samples-storage ：库存模块
 *  samples-business ：业务模块

#### 3.2 账户服务：AccountDubboService ####

/** * @Author: lidong * @Description 账户服务接口 * @Date Created in 2019/9/5 16:37 */
    public interface AccountDubboService { 
    
        /** * 从账户扣钱 */
        ObjectResponse decreaseAccount(AccountDTO accountDTO);
    }

#### 3.3 订单服务：OrderDubboService ####

/** * @Author: lidong * @Description 订单服务接口 * @Date Created in 2019/9/5 16:28 */
    public interface OrderDubboService { 
    
        /** * 创建订单 */
        ObjectResponse<OrderDTO> createOrder(OrderDTO orderDTO);
    }

#### 3.4 库存服务：StorageDubboService ####

/** * @Author: lidong * @Description 库存服务 * @Date Created in 2019/9/5 16:22 */
    public interface StorageDubboService { 
    
        /** * 扣减库存 */
        ObjectResponse decreaseStorage(CommodityDTO commodityDTO);
    }

#### 3.5 业务服务：BusinessService ####

/** * @Author: lidong * @Description * @Date Created in 2019/9/5 17:17 */
    public interface BusinessService { 
    
        /** * 出处理业务服务 * @param businessDTO * @return */
        ObjectResponse handleBusiness(BusinessDTO businessDTO);
    }

业务逻辑的具体实现主要体现在 订单服务的实现和业务服务的实现

订单服务的实现

@Service
    public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> implements ITOrderService { 
    
        @Reference(version = "1.0.0")
        private AccountDubboService accountDubboService;
    
        /** * 创建订单 * @Param: OrderDTO 订单对象 * @Return: OrderDTO 订单对象 */
        @Override
        public ObjectResponse<OrderDTO> createOrder(OrderDTO orderDTO) { 
            ObjectResponse<OrderDTO> response = new ObjectResponse<>();
            //扣减用户账户
            AccountDTO accountDTO = new AccountDTO();
            accountDTO.setUserId(orderDTO.getUserId());
            accountDTO.setAmount(orderDTO.getOrderAmount());
            ObjectResponse objectResponse = accountDubboService.decreaseAccount(accountDTO);
    
            //生成订单号
            orderDTO.setOrderNo(UUID.randomUUID().toString().replace("-",""));
            //生成订单
            TOrder tOrder = new TOrder();
            BeanUtils.copyProperties(orderDTO,tOrder);
            tOrder.setCount(orderDTO.getOrderCount());
            tOrder.setAmount(orderDTO.getOrderAmount().doubleValue());
            try { 
                baseMapper.createOrder(tOrder);
            } catch (Exception e) { 
                response.setStatus(RspStatusEnum.FAIL.getCode());
                response.setMessage(RspStatusEnum.FAIL.getMessage());
                return response;
            }
    
            if (objectResponse.getStatus() != 200) { 
                response.setStatus(RspStatusEnum.FAIL.getCode());
                response.setMessage(RspStatusEnum.FAIL.getMessage());
                return response;
            }
    
            response.setStatus(RspStatusEnum.SUCCESS.getCode());
            response.setMessage(RspStatusEnum.SUCCESS.getMessage());
            return response;
        }
    }

整个业务的实现逻辑

@Service
    @Slf4j
    public class BusinessServiceImpl implements BusinessService{ 
    
        @Reference(version = "1.0.0")
        private StorageDubboService storageDubboService;
    
        @Reference(version = "1.0.0")
        private OrderDubboService orderDubboService;
    
        private boolean flag;
    
        /** * 处理业务逻辑 * @Param: * @Return: */
    
        @GlobalTransactional(timeoutMills = 300000, name = "dubbo-gts-seata-example")
        @Override
        public ObjectResponse handleBusiness(BusinessDTO businessDTO) { 
            log.info("开始全局事务，XID = " + RootContext.getXID());
            ObjectResponse<Object> objectResponse = new ObjectResponse<>();
            //1、扣减库存
            CommodityDTO commodityDTO = new CommodityDTO();
            commodityDTO.setCommodityCode(businessDTO.getCommodityCode());
            commodityDTO.setCount(businessDTO.getCount());
            ObjectResponse storageResponse = storageDubboService.decreaseStorage(commodityDTO);
            //2、创建订单
            OrderDTO orderDTO = new OrderDTO();
            orderDTO.setUserId(businessDTO.getUserId());
            orderDTO.setCommodityCode(businessDTO.getCommodityCode());
            orderDTO.setOrderCount(businessDTO.getCount());
            orderDTO.setOrderAmount(businessDTO.getAmount());
            ObjectResponse<OrderDTO> response = orderDubboService.createOrder(orderDTO);
    
            //打开注释测试事务发生异常后，全局回滚功能
    // if (!flag) { 
    // throw new RuntimeException("测试抛异常后，分布式事务回滚！");
    // }
    
            if (storageResponse.getStatus() != 200 || response.getStatus() != 200) { 
                throw new DefaultException(RspStatusEnum.FAIL);
            }
    
            objectResponse.setStatus(RspStatusEnum.SUCCESS.getCode());
            objectResponse.setMessage(RspStatusEnum.SUCCESS.getMessage());
            objectResponse.setData(response.getData());
            return objectResponse;
        }
    }

## 3.6 使用seata的分布式事务解决方案处理dubbo的分布式事务 ##

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

我们只需要在业务处理的方法`handleBusiness`添加一个注解 `@GlobalTransactional`

@GlobalTransactional(timeoutMills = 300000, name = "dubbo-gts-seata-example")
        @Override
        public ObjectResponse handleBusiness(BusinessDTO businessDTO) { 
        
        }

*  `timeoutMills`: 超时时间
 *  `name` ：事务名称

## 3.7 准备数据库 ##

注意: MySQL必须使用`InnoDB engine`.

创建数据库 并导入数据库脚本

DROP DATABASE IF EXISTS seata;
    CREATE DATABASE seata;
    USE seata;
    
    DROP TABLE IF EXISTS `t_account`;
    CREATE TABLE `t_account` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `user_id` varchar(255) DEFAULT NULL,
      `amount` double(14,2) DEFAULT '0.00',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of t_account
    -- ----------------------------
    INSERT INTO `t_account` VALUES ('1', '1', '4000.00');
    
    -- ----------------------------
    -- Table structure for t_order
    -- ----------------------------
    DROP TABLE IF EXISTS `t_order`;
    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=64 DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of t_order
    -- ----------------------------
    
    -- ----------------------------
    -- Table structure for t_storage
    -- ----------------------------
    DROP TABLE IF EXISTS `t_storage`;
    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=2 DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of t_storage
    -- ----------------------------
    INSERT INTO `t_storage` VALUES ('1', 'C201901140001', '水杯', '1000');
    
    -- ----------------------------
    -- Table structure for undo_log
    -- 注意此处0.3.0+ 增加唯一索引 ux_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) 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;
    
    -- ----------------------------
    -- Records of undo_log
    -- ----------------------------
    SET FOREIGN_KEY_CHECKS=1;

会看到如上的4个表

这里为了简化我将这个三张表创建到一个库中,使用是三个数据源来实现。

## 3.8 我们以账号服务`samples-account`为例 ，分析需要注意的配置项目 ##

### 3.8.1 引入的依赖 ###

<?xml version="1.0" encoding="UTF-8"?>
    <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/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <artifactId>springboot-dubbo-seata</artifactId>
        <packaging>pom</packaging>
        <name>springboot-dubbo-seata</name>
        <groupId>io.seata</groupId>
        <version>1.0.0</version>
        <description>samples-account</description》
    
        <properties>
            <springboot.verison>2.1.5.RELEASE</springboot.verison>
            <java.version>1.8</java.version>
            <druid.version>1.1.10</druid.version>
            <mybatis.version>1.3.2</mybatis.version>
            <mybatis-plus.version>2.3</mybatis-plus.version>
            <nacos.version>0.2.3</nacos.version>
            <lombok.version>1.16.22</lombok.version>
            <dubbo.version>2.7.3</dubbo.version>
            <nacos-client.verison>1.1.3</nacos-client.verison>
            <seata.version>0.8.0</seata.version>
            <netty.version>4.1.32.Final</netty.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>${ springboot.verison}</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>${ springboot.verison}</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <version>${ springboot.verison}</version>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${ druid.version}</version>
            </dependency>
    
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${ mybatis.version}</version>
            </dependency>
    
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus</artifactId>
                <version>${ mybatis-plus.version}</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo</artifactId>
                <version>${ dubbo.version}</version>
                <exclusions>
                    <exclusion>
                        <artifactId>spring</artifactId>
                        <groupId>org.springframework</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${ dubbo.version}</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-config-spring</artifactId>
                <version>${ dubbo.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-registry-nacos</artifactId>
                <version>${ dubbo.version}</version>
            </dependency>
    
            
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
                <version>${ seata.version}</version>
            </dependency>
    
    
            <dependency>
                <groupId>com.alibaba.nacos</groupId>
                <artifactId>nacos-client</artifactId>
                <version>${ nacos-client.verison}</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>nacos-config-spring-boot-starter</artifactId>
                <version>${ nacos.version}</version>
                <exclusions>
                    <exclusion>
                        <artifactId>nacos-client</artifactId>
                        <groupId>com.alibaba.nacos</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>${ springboot.verison}</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>${ lombok.version}</version>
            </dependency>
    
    
            <dependency>
                <groupId>io.netty</groupId>
                <artifactId>netty-all</artifactId>
                <version>${ netty.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba.spring</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>1.0.2</version>
            </dependency>
            <dependency>
                <groupId>org.apache.httpcomponents</groupId>
                <artifactId>httpclient</artifactId>
                <version>4.5</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.47</version>
            </dependency>
        </dependencies>
    
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-deploy-plugin</artifactId>
                    <configuration>
                        <skip>true</skip>
                    </configuration>
                </plugin>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <configuration>
                        <source>${ java.version}</source>
                        <target>${ java.version}</target>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

注意：

*  `seata-all`: 这个是seata 所需的主要依赖
 *  `dubbo-spring-boot-starter`: springboot dubbo的依赖

其他的就不一一介绍，其他的一目了然，就知道是干什么的。

### 3.8.2 application.properties配置 ###

server.port=8102
    spring.application.name=dubbo-account-example
    
    #====================================Dubbo配置===============================================
    dubbo.application.id= dubbo-account-example
    dubbo.application.name= dubbo-account-example
    dubbo.protocol.id=dubbo
    dubbo.protocol.name=dubbo
    dubbo.registry.id=dubbo-account-example-registry
    dubbo.registry.address=nacos://192.168.10.200:8848
    dubbo.protocol.port=20880
    dubbo.application.qosEnable=false
    dubbo.config-center.address=nacos://192.168.10.200:8848
    dubbo.metadata-report.address=nacos://192.168.10.200:8848
    
    #====================================mysql 配置============================================
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.url=jdbc:mysql://192.168.10.200:3306/seata?useSSL=false&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
    spring.datasource.username=lidong
    spring.datasource.password=cwj887766@@
    
    
    #=====================================mybatis 配置======================================
    mybatis.mapper-locations=classpath*:/mapper/*.xml

### 3.8.3 registry.conf 配置 （naocs的配置） ###

registry {
      # file nacos
      type = "nacos"
    
      nacos {
        serverAddr = "192.168.10.200"
        namespace = "public"
        cluster = "default"
      }
      file {
        name = "file.conf"
      }
    }
    
    config {
      # file、nacos 、apollo、zk、consul
      type = "nacos"
    
      file {
        name = "file.conf"
      }
    
      nacos {
        serverAddr = "192.168.10.200"
        namespace = "public"
        cluster = "default"
      }
    }

### 3.8.5 SeataAutoConfig 配置 ###

package io.seata.samples.integration.account.config;
    
    import com.alibaba.druid.pool.DruidDataSource;
    
    import io.seata.rm.datasource.DataSourceProxy;
    import io.seata.spring.annotation.GlobalTransactionScanner;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    
    /** * @Author: llidong * @Description seata global configuration * @Date Created in 2019/9/05 10:28 */
    @Configuration
    public class SeataAutoConfig { 
    
        /** * autowired datasource config */
        @Autowired
        private DataSourceProperties dataSourceProperties;
    
        /** * init durid datasource * * @Return: druidDataSource datasource instance */
        @Bean
        @Primary
        public DruidDataSource druidDataSource(){ 
            DruidDataSource druidDataSource = new DruidDataSource();
            druidDataSource.setUrl(dataSourceProperties.getUrl());
            druidDataSource.setUsername(dataSourceProperties.getUsername());
            druidDataSource.setPassword(dataSourceProperties.getPassword());
            druidDataSource.setDriverClassName(dataSourceProperties.getDriverClassName());
            druidDataSource.setInitialSize(0);
            druidDataSource.setMaxActive(180);
            druidDataSource.setMaxWait(60000);
            druidDataSource.setMinIdle(0);
            druidDataSource.setValidationQuery("Select 1 from DUAL");
            druidDataSource.setTestOnBorrow(false);
            druidDataSource.setTestOnReturn(false);
            druidDataSource.setTestWhileIdle(true);
            druidDataSource.setTimeBetweenEvictionRunsMillis(60000);
            druidDataSource.setMinEvictableIdleTimeMillis(25200000);
            druidDataSource.setRemoveAbandoned(true);
            druidDataSource.setRemoveAbandonedTimeout(1800);
            druidDataSource.setLogAbandoned(true);
            return druidDataSource;
        }
    
        /** * init datasource proxy * @Param: druidDataSource datasource bean instance * @Return: DataSourceProxy datasource proxy */
        @Bean
        public DataSourceProxy dataSourceProxy(DruidDataSource druidDataSource){ 
            return new DataSourceProxy(druidDataSource);
        }
    
        /** * init mybatis sqlSessionFactory * @Param: dataSourceProxy datasource proxy * @Return: DataSourceProxy datasource proxy */
        @Bean
        public SqlSessionFactory sqlSessionFactory(DataSourceProxy dataSourceProxy) throws Exception { 
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(dataSourceProxy);
            factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources("classpath*:/mapper/*.xml"));
            return factoryBean.getObject();
        }
    
        /** * init global transaction scanner * * @Return: GlobalTransactionScanner */
        @Bean
        public GlobalTransactionScanner globalTransactionScanner(){ 
            return new GlobalTransactionScanner("account-gts-seata-example", "account-service-seata-service-group");
        }
    }

其中:

@Bean
        public GlobalTransactionScanner globalTransactionScanner(){
            return new GlobalTransactionScanner("account-gts-seata-example", "account-service-seata-service-group");
        }

`GlobalTransactionScanner`: 初始化全局的事务扫描器

/**
         * Instantiates a new Global transaction scanner.
         *
         * @param applicationId  the application id
         * @param txServiceGroup the default server group
         */
        public GlobalTransactionScanner(String applicationId, String txServiceGroup) {
            this(applicationId, txServiceGroup, DEFAULT_MODE);
        }

*  applicationId ：为应用id 这里我传入的是`account-gts-seata-example`
 *  txServiceGroup: 默认server的分组 这里我传入的是`account-service-seata-service-group` 这个和我们前面在nacos 配置的是保存一致。
 *  DEFAULT\_MODE：默认的事务模式 为[AT\_MODE][AT_MODE] \+ [MT\_MODE][MT_MODE]

### 3.8.6 AccountExampleApplication 启动类的配置 ###

package io.seata.samples.integration.account;
    
    import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.context.config.ConfigFileApplicationListener;
    
    @SpringBootApplication(scanBasePackages = "io.seata.samples.integration.account")
    @MapperScan({ "io.seata.samples.integration.account.mapper"})
    @EnableDubbo(scanBasePackages = "io.seata.samples.integration.account")
    public class AccountExampleApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(AccountExampleApplication.class, args);
        }
    
    }

*  `@EnableDubbo`等同于 `@DubboComponentScan`和 `@EnableDubboConfig`组合
 *  `@DubboComponentScan` 扫描 classpaths 下类中添加了 `@Service` 和 `@Reference` 将自动注入到spring beans中。
 *  @EnableDubboConfig 扫描的dubbo的外部化配置。

## 4 启动所有的sample模块 ##

启动 `samples-account`、`samples-order`、`samples-storage`、`samples-business`

并且在nocos的控制台查看注册情况: http://192.168.10.200:8848/nacos/\#/serviceManagement

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

我们可以看到上面的服务都已经注册成功。

## 5 测试 ##

### 5. 1 发送一个下单请求 ###

使用postman 发送 ：[http://localhost:8104/business/dubbo/buy][http_localhost_8104_business_dubbo_buy]

参数：

{ 
        "userId":"1",
        "commodityCode":"C201901140001",
        "name":"fan",
        "count":50,
        "amount":"100"
    }

{ 
        "status": 200,
        "message": "成功",
        "data": null
    }

这时候控制台：

2019-09-05 12:17:34.097  INFO 21860 --- [nio-8104-exec-4] i.s.s.i.c.controller.BusinessController  : 请求参数：BusinessDTO(userId=1, commodityCode=C201901140001, name=fan, count=50, amount=100)
    2019-09-05 12:17:34.146  INFO 21860 --- [nio-8104-exec-4] i.seata.tm.api.DefaultGlobalTransaction  : Begin new global transaction [192.168.10.200:8091:2021380638]
    2019-09-05 12:17:34.150  INFO 21860 --- [nio-8104-exec-4] i.s.s.i.c.service.BusinessServiceImpl    : 开始全局事务，XID = 192.168.10.200:8091:2021380638
    2019-09-05 12:17:36.966  INFO 21860 --- [nio-8104-exec-4] i.seata.tm.api.DefaultGlobalTransaction  : [192.168.10.200:8091:2021380638] commit status:Committed

事务提交成功，

我们来看一下数据库数据变化

t\_account  
![在这里插入图片描述][20190905122211274.png]  
t\_order

![在这里插入图片描述][20190905122302472.png]  
t\_storage

![在这里插入图片描述][20190905122326182.png]  
数据没有问题。

### 5.2 测试回滚 ###

我们`samples-business`将`BusinessServiceImpl`的`handleBusiness2` 下面的代码去掉注释

if (!flag) {
      throw new RuntimeException("测试抛异常后，分布式事务回滚！");
    }

使用postman 发送 ：[http://localhost:8104/business/dubbo/buy2][http_localhost_8104_business_dubbo_buy2]

.响应结果：

{ 
        "timestamp": "2019-09-05T04:29:34.178+0000",
        "status": 500,
        "error": "Internal Server Error",
        "message": "测试抛异常后，分布式事务回滚！",
        "path": "/business/dubbo/buy"
    }

控制台

2019-09-05 12:29:32.836  INFO 17264 --- [nio-8104-exec-2] i.s.s.i.c.controller.BusinessController  : 请求参数：BusinessDTO(userId=1, commodityCode=C201901140001, name=fan, count=50, amount=100)
    2019-09-05 12:29:32.843  INFO 17264 --- [nio-8104-exec-2] i.s.common.loader.EnhancedServiceLoader  : load ContextCore[null] extension by class[io.seata.core.context.ThreadLocalContextCore]
    2019-09-05 12:29:32.848  INFO 17264 --- [nio-8104-exec-2] i.s.common.loader.EnhancedServiceLoader  : load TransactionManager[null] extension by class[io.seata.tm.DefaultTransactionManager]
    2019-09-05 12:29:32.849  INFO 17264 --- [nio-8104-exec-2] io.seata.tm.TransactionManagerHolder     : TransactionManager Singleton io.seata.tm.DefaultTransactionManager@461585ac
    2019-09-05 12:29:32.859  INFO 17264 --- [nio-8104-exec-2] i.s.common.loader.EnhancedServiceLoader  : load LoadBalance[null] extension by class[io.seata.discovery.loadbalance.RandomLoadBalance]
    2019-09-05 12:29:32.893  INFO 17264 --- [nio-8104-exec-2] i.seata.tm.api.DefaultGlobalTransaction  : Begin new global transaction [192.168.10.200:8091:2021380674]
    2019-09-05 12:29:32.897  INFO 17264 --- [nio-8104-exec-2] i.s.s.i.c.service.BusinessServiceImpl    : 开始全局事务，XID = 192.168.10.200:8091:2021380674
    2019-09-05 12:29:34.143  INFO 17264 --- [nio-8104-exec-2] i.seata.tm.api.DefaultGlobalTransaction  : [192.168.10.200:8091:2021380674] rollback status:Rollbacked
    2019-09-05 12:29:34.158 ERROR 17264 --- [nio-8104-exec-2] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.RuntimeException: 测试抛异常后，分布式事务回滚！] with root cause
    
    java.lang.RuntimeException: 测试抛异常后，分布式事务回滚！
    	at io.seata.samples.integration.call.service.BusinessServiceImpl.handleBusiness(BusinessServiceImpl.java:60) ~[classes/:na]
    	at io.seata.samples.integration.call.service.BusinessServiceImpl$$FastClassBySpringCGLIB$$2ab3d645.invoke(<generated>) ~[classes/:na]
    	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749) ~[spring-aop-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at io.seata.spring.annotation.GlobalTransactionalInterceptor$1.execute(GlobalTransactionalInterceptor.java:104) ~[seata-all-0.8.0.jar:0.8.0]
    	at io.seata.tm.api.TransactionalTemplate.execute(TransactionalTemplate.java:64) ~[seata-all-0.8.0.jar:0.8.0]
    	at io.seata.spring.annotation.GlobalTransactionalInterceptor.handleGlobalTransaction(GlobalTransactionalInterceptor.java:101) ~[seata-all-0.8.0.jar:0.8.0]
    	at io.seata.spring.annotation.GlobalTransactionalInterceptor.invoke(GlobalTransactionalInterceptor.java:76) ~[seata-all-0.8.0.jar:0.8.0]
    	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at io.seata.samples.integration.call.service.BusinessServiceImpl$$EnhancerBySpringCGLIB$$cb43f7ab.handleBusiness(<generated>) ~[classes/:na]
    	at io.seata.samples.integration.call.controller.BusinessController.handleBusiness(BusinessController.java:37) ~[classes/:na]
    	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_144]
    	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_144]
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_144]
    	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_144]
    	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:908) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at javax.servlet.http.HttpServlet.service(HttpServlet.java:660) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882) ~[spring-webmvc-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-5.1.7.RELEASE.jar:5.1.7.RELEASE]
    	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:200) ~[tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:836) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1747) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_144]
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_144]
    	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.19.jar:9.0.19]
    	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_144]

我们查看数据库数据，已经回滚，和上面的数据一致。

到这里一个简单的案例基本就分析结束。感谢你的学习。

最后想一起交流技术的可以加我wx:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 6]

[https_spring.io_projects_spring-boot]: https://spring.io/projects/spring-boot
[http_dubbo.apache.org_en-us]: http://dubbo.apache.org/en-us/
[https_nacos.io_zh-cn_docs_quick-start.html]: https://nacos.io/zh-cn/docs/quick-start.html
[https_github.com_seata_seata_wiki_Home_Chinese]: https://github.com/seata/seata/wiki/Home_Chinese
[http_www.mybatis.org_mybatis-3_zh_index.html]: http://www.mybatis.org/mybatis-3/zh/index.html
[https_github.com_alibaba_nacos_releases_tag_1.1.3]: https://github.com/alibaba/nacos/releases/tag/1.1.3
[https_nacos.io_en-us_docs_quick-start.html]: https://nacos.io/en-us/docs/quick-start.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/0fad5130c5564c6ca090f9fbdb98a060.png
[Seata Release]: https://github.com/seata/seata/releases/tag/v0.8.0
[https_github.com_seata_seata_blob_develop_script_config-center]: https://github.com/seata/seata/blob/develop/script/config-center/
[https_github.com_seata_seata_tree_develop_script_config-center_nacos]: https://github.com/seata/seata/tree/develop/script/config-center/nacos/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/1bc81ff9146c4674888b954d34c12056.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/145eba4aa9db4bf987e76c607eb9b7b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/f424fc06a8094f239ddb224e8b07bd0e.png
[https_github.com_lidong1665_springboot-dubbo-seata]: https://github.com/lidong1665/springboot-dubbo-seata
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/76b1c14dca574126b9c7540f18c4fbc5.png
[AT_MODE]: https://github.com/seata/seata/wiki/AT-Mode
[MT_MODE]: https://github.com/seata/seata/wiki/MT-Mode
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/b2925ee6ff3d4636882aa364b7b5c867.png
[http_localhost_8104_business_dubbo_buy]: http://localhost:8104/business/dubbo/buy
[20190905122211274.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/5f8510e4fff740a2a4b32b4d5d4b8e0a.png
[20190905122302472.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/95291b155dbf47caa644fc3fa5bd60f5.png
[20190905122326182.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/88a7250cbcec472d98e106e815f47fb5.png
[http_localhost_8104_business_dubbo_buy2]: http://localhost:8104/business/dubbo/buy2
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9saWRvbmcxNjY1LmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/fc69a951bc0a4c9da04ae86aa0c79898.png