前言：

异常处理在前两篇文章已经基本说完了，这篇文章我们来说一说SpringCloud下的事务。众所周知，事务可以在系统出现异常时，保证数据的一致性和完整性。如果没有使用事务，我们的系统数据可能不准确，这样就失去了使用系统的意义。在SpringCloud微服务架构下，我们的服务可能部署在不同的物理服务器上，如果只使用本地事务一定不能保证数据的一致性和完整性，所以我们需要用到分布式事务。我在寻找分布式解决方案时，我优先选择的是代码侵入性小、代码修改量少和使用简单的方案。这样可以减少我们已完成代码的改变。最后一番权衡，我选择了阿里爸爸家的Seata分布式事务框架。

正文：

seata分布式事务的介绍与使用官方文档上都有，官网文档地址：Seata。请大家自行阅读吧！我这里主要讲一下SpringCloud的Greenwich版本，如何集成Seata分布式框架。我这里选择Seata版本是1.2.0（目前最近版本1.3.0）。

一、下载seata-server：

根据系统下载合适版本，下载地址如下：

https://github.com/seata/seata/releases

二、配置seata-server：

1. 建表（MySQL版本）：

一共三张表：全局事务（global_table）、分支事务（branch_table）、全局锁（lock_table）。建表语句如下：

CREATE TABLE `global_table` (
  `xid` varchar(128) NOT NULL,
  `transaction_id` bigint(20) DEFAULT NULL,
  `status` tinyint(4) NOT NULL,
  `application_id` varchar(32) DEFAULT NULL,
  `transaction_service_group` varchar(32) DEFAULT NULL,
  `transaction_name` varchar(128) 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=utf8;

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=utf8;

CREATE TABLE `lock_table` (
  `row_key` varchar(128) NOT NULL,
  `xid` varchar(96) DEFAULT NULL,
  `transaction_id` mediumtext,
  `branch_id` mediumtext,
  `resource_id` varchar(256) DEFAULT NULL,
  `table_name` varchar(32) DEFAULT NULL,
  `pk` varchar(36) DEFAULT NULL,
  `gmt_create` datetime DEFAULT NULL,
  `gmt_modified` datetime DEFAULT NULL,
  PRIMARY KEY (`row_key`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. 修改配置文件：

seata-server-1.2.0/conf/file.conf，修改store.mode=db，修改数据库url、user、password。Tips：注意MySQL不同版本选择合适的MySQL驱动。

3. 修改配置中心文件：

seata-server-1.2.0/conf/registry.conf，修改type=eureka，修改注册中心地址。我在选择Eureka作为配置中心

4. 启动：

进入seata-server-1.2.0/bin目录，输入如下命令：

Linux版命令：

seata-server.sh -h 127.0.0.1 -p 8091 -m db 

Tips： 后台进程启动命令：

nohup ./seata-server.sh -h 127.0.0.1 -p 8091 -m db  >nohup.out 2>&1 &

Windows版命令：

.\seata-server.bat -p 8091 -h 127.0.0.1 -m db 

三、配置seata-client（seata-client与SpringCloud服务集成）：

1.  添加seata依赖：

   <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        <exclusions>
            <exclusion>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
            </exclusion>
            <exclusion>
                 <groupId>io.seata</groupId>
                 <artifactId>seata-spring-boot-starter</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
   <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
        <version>1.2.0</version>
    </dependency>

2. 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,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

3. 配置参数：

配置参数可以将seata-server中的两个文件file.conf和registry.conf放到resource文件下，也可在YAML文件中配置。我选择的是在YAML文件中配置，这样的好处是可以根据环境配置不同的参数。

seata:
  enabled: true
  application-id: ${spring.application.name}
  tx-service-group: tx_group
  client:
    rm:
      async-commit-buffer-limit: 1000
      report-retry-count: 5
      table-meta-check-enable: false
      report-success-enable: false
      lock:
        retry-interval: 10
        retry-times: 30
        retry-policy-branch-rollback-on-conflict: true
    tm:
      commit-retry-count: 5
      rollback-retry-count: 5
    undo:
      data-validation: true
      log-serialization: jackson
      log-table: undo_log
    log:
      exceptionRate: 100
  service:
    vgroupMapping:
      tx_group: seata-server
    grouplist:
      default: 127.0.0.1:8091
  transport:
    shutdown:
      wait: 3
    thread-factory:
      boss-thread-prefix: NettyBoss
      worker-thread-prefix: NettyServerNIOWorker
      server-executor-thread-prefix: NettyServerBizHandler
      share-boss-worker: false
      client-selector-thread-prefix: NettyClientSelector
      client-selector-thread-size: 1
      client-worker-thread-prefix: NettyClientWorkerThread
      worker-thread-size: default
      boss-thread-size: 1
    type: TCP
    server: NIO
    heartbeat: true
    serialization: seata
    compressor: none
    enable-client-batch-send-request: true
  config:
    type: file
  registry:
    type: eureka
    eureka:
      application: seata-server
      weight: 1
      service-url: http://user:123456@localhost/eureka

4. 配置数据源代理：

4.1 创建数据源配置类：

package com.hippo.online.config;

import com.alibaba.druid.pool.DruidDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;

/**
 * 功能描述: <br>
 * 〈DataSourceConfig〉
 *
 * @Author:hanxinghua
 * @Date: 2020/9/16
 */
@Configuration
public class DataSourceConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource(){
        DruidDataSource druidDataSource = new DruidDataSource();
        return druidDataSource;
    }

    @Primary
    @Bean("dataSource")
    public DataSourceProxy dataSource(DataSource druidDataSource){
        return new DataSourceProxy(druidDataSource);
    }

}

4.2  取消默认数据源：

@SpringBootApplication(exclude={DataSourceAutoConfiguration.class})

5. 初始化GlobalTransactionScanner：

引入seata-spring-boot-starter、spring-cloud-starter-alibaba-seata等jar自动配置

四、使用：

在Server层方法上引入@GlobalTransactional注解，例如：

    @Override
    @GlobalTransactional(rollbackFor = Exception.class)
    public Result<Long> update(OrderEditInfoDTO order) {
        // 查询客户单价
        UserPriceEntity userPriceEntity = this.callUnitPrice(ClientInfo.getLocalUId());
        order.setUserPriceEntity(userPriceEntity);
        Result<Long> result = orderFeignClient.update(order);
        if (ResultCode.SUCCESS.code() != result.getCode()) {
            throw new InternalServerException("call-orderFeignClient.update");
        }
        return result;
    }

五、Tips：

如果你的SpringCloud微服务架构采用同一个业务模块分为生产者和消费者两块，@GlobalTransactional一定要加在消费者中。如果你生产者消息都有Result类进行封装返回，一定要在消费者中判断Result类的code是否为200成功，不成功需要抛出一个异常触发Seata分布式事务回滚。

如果你的系统调用了其他系统或者第三方系统的接口，你可能就需要做一些反补措施保证数据的准确性和一致性。我感觉有点类似于TCC。

此外，Seata分布式事务框架我们是第一次用，网络上的资料不是很多，也不知道会遇到什么样的问题。但是大厂出品，品质应该没啥大问题。如有疑问，请多多交流！