Spring Cloud Alibaba 使用Seata解決分布式事務

為什么會產生分布式事務?

隨着業務的快速發展，網站系統往往由單體架構逐漸演變為分布式、微服務架構，而對於數據庫則由單機數據庫架構向分布式數據庫架構轉變。此時，我們會將一個大的應用系統拆分為多個可以獨立部署的應用服務，需要各個服務之間進行遠程協作才能完成事務操作。在微服務項目中通常一個大項目會被拆分為N個子項目,例如用戶中心服務,會員中心服務,支付中心服務等一系列微服務，在面臨各種業務需求時難免會產生用戶中心服務中需要調用會員中心服務,支付中心服務而產生調用鏈路;服務與服務之間通訊采用RPC遠程調用技術，但是每個服務中都有自己獨立的數據源，即自己獨立的本地事務；兩個服務相互進行通訊的時候，兩個本地事務互不影響，從而出現分布式事務產生的原因。

Seata簡介

Seata 是一款開源的分布式事務解決方案，致力於提供高性能和簡單易用的分布式事務服務。Seata 將為用戶提供了 AT、TCC、SAGA 和 XA 事務模式，為用戶打造一站式的分布式解決方案。

Seata核心術語

TC (Transaction Coordinator) - 事務協調者：維護全局和分支事務的狀態，驅動全局事務提交或回滾。

TM (Transaction Manager) - 事務管理器：定義全局事務的范圍：開始全局事務、提交或回滾全局事務。

RM (Resource Manager) - 資源管理器：管理分支事務處理的資源，與TC交談以注冊分支事務和報告分支事務的狀態，並驅動分支事務提交或回滾。

AT模式工作機制

根據官方說明當前：通過JDBC訪問支持本地 ACID 事務的關系型數據庫的Java應用程序才支持AT模式。

兩階段提交協議的演變：

• 一階段：業務數據和回滾日志記錄在同一個本地事務中提交，釋放本地鎖和連接資源。
• 二階段：
  • 提交異步化，非常快速地完成。
  • 回滾通過一階段的回滾日志進行反向補償。

更詳細可參考官方文檔: http://seata.io/zh-cn/docs/dev/mode/at-mode.html

Seata Server 部署

官方Seata配置中心信息：https://github.com/seata/seata/blob/develop/script/config-center/config.txt
官方Seata Nacos配置部署腳本：https://github.com/seata/seata/blob/develop/script/config-center/config.txt
版本信息與Seata Server下載地址可參考首頁介紹文檔：https://gitee.com/SimpleWu/spring-cloud-alibaba-example

Seata目錄結構說明：

• bin：運行腳本
• conf：配置文件
• lib：依賴包

當前部署方式采用Nacos作為注冊中心與配置中心。

registry.conf

該配置位於conf目錄,按下以下注釋區域進行修改

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  # 使用nacos作為注冊中心
  type = "nacos"

  nacos {
    # 注冊到nacos應用名稱
    application = "seata-server"
    # nacos ip
    serverAddr = "127.0.0.1:8848"
    # 所在分組
    group = "EXAMPLE-GROUP"
    # 所在命名空間
    namespace = "7e3699fa-09eb-4d47-8967-60f6c98da94a"
    # 所在集群
    #cluster = "default"
    username = "nacos"
    password = "nacos"
  }
  eureka {
    serviceUrl = "http://localhost:8761/eureka"
    application = "default"
    weight = "1"
  }
  redis {
    serverAddr = "localhost:6379"
    db = 0
    password = ""
    cluster = "default"
    timeout = 0
  }
  zk {
    cluster = "default"
    serverAddr = "127.0.0.1:2181"
    sessionTimeout = 6000
    connectTimeout = 2000
    username = ""
    password = ""
  }
  consul {
    cluster = "default"
    serverAddr = "127.0.0.1:8500"
  }
  etcd3 {
    cluster = "default"
    serverAddr = "http://localhost:2379"
  }
  sofa {
    serverAddr = "127.0.0.1:9603"
    application = "default"
    region = "DEFAULT_ZONE"
    datacenter = "DefaultDataCenter"
    cluster = "default"
    group = "SEATA_GROUP"
    addressWaitTime = "3000"
  }
  file {
    name = "file.conf"
  }
}

config {
  # file、nacos 、apollo、zk、consul、etcd3
  # 使用nacos管理配置
  type = "nacos"

  nacos {
    # nacos ip
    serverAddr = "127.0.0.1:8848"
    # 所在命名空間
    namespace = "7e3699fa-09eb-4d47-8967-60f6c98da94a"
    # 所在分組
    group = "EXAMPLE-GROUP"
    username = "nacos"
    password = "nacos"
  }
  consul {
    serverAddr = "127.0.0.1:8500"
  }
  apollo {
    appId = "seata-server"
    apolloMeta = "http://192.168.1.204:8801"
    namespace = "application"
  }
  zk {
    serverAddr = "127.0.0.1:2181"
    sessionTimeout = 6000
    connectTimeout = 2000
    username = ""
    password = ""
  }
  etcd3 {
    serverAddr = "http://localhost:2379"
  }
  file {
    name = "file.conf"
  }
}

以上內容主要修改了注冊中心與配置中心為Nacos並且修改了Nacos地址與登錄賬號/登錄密碼,命名空間,分組;

配置部署到Nacos

這里簡化了下Nacos官網下載的config.txt內容,從官網下載的配置文本以下內容標記需要修改的需要關注

#事務組 重點關注
service.vgroupMapping.my_test_tx_group=default
#服務段分組地址
service.default.grouplist=127.0.0.1:8091
#保持默認
service.enableDegrade=false
#保持默認
service.disableGlobalTransaction=false
#存儲方式選擇 db模式則數據庫
store.mode=db
#需修改
store.lock.mode=db
#需修改
store.session.mode=db
store.publicKey=
#需修改
store.db.datasource=druid
#需修改
store.db.dbType=mysql
#需修改
store.db.driverClassName=com.mysql.jdbc.Driver
#需修改
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
#需修改
store.db.user=root
#需修改
store.db.password=123456
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.distributedLockTable=distributed_lock
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
client.undo.dataValidation=true
#需修改
#jackson改為kryo 解決數據庫Datetime類型問題
client.undo.logSerialization=kryo
client.undo.onlyCareUpdateColumns=true
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none

其中該配置需要重點關注service.vgroupMapping.my_test_tx_group=default這里的配置與微服務應用中的配置必須要一致后面會描述到。

由於有時間類型是Seata回滾反序列化Date類型無法成功反序列化，需要修改序列化方式解決該問題: client.undo.logSerialization=kryo

修改完所有配置運行從官網下載的nacos-config.sh文件將文本內容上次到nacos配置中心中:

# -h ip -p 端口 -t 命名空間 -g 分組
sh nacos-config.sh -h localhost -p 8848 -t 7e3699fa-09eb-4d47-8967-60f6c98da94a -g EXAMPLE-GROUP

部署好配置文件之后在Nacos命名空間為7e3699fa-09eb-4d47-8967-60f6c98da94a(dev)的配置管理界面可以看到文本中的內容。

Seata數據庫

按照config.txt中對應的數據庫連接信息創建Seata數據庫並且創建以下幾張表

CREATE TABLE IF NOT EXISTS `global_table`
(
    `xid`                       VARCHAR(128) NOT NULL,
    `transaction_id`            BIGINT,
    `status`                    TINYINT      NOT NULL,
    `application_id`            VARCHAR(32),
    `transaction_service_group` VARCHAR(32),
    `transaction_name`          VARCHAR(128),
    `timeout`                   INT,
    `begin_time`                BIGINT,
    `application_data`          VARCHAR(2000),
    `gmt_create`                DATETIME,
    `gmt_modified`              DATETIME,
    PRIMARY KEY (`xid`),
    KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
    KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(
    `branch_id`         BIGINT       NOT NULL,
    `xid`               VARCHAR(128) NOT NULL,
    `transaction_id`    BIGINT,
    `resource_group_id` VARCHAR(32),
    `resource_id`       VARCHAR(256),
    `branch_type`       VARCHAR(8),
    `status`            TINYINT,
    `client_id`         VARCHAR(64),
    `application_data`  VARCHAR(2000),
    `gmt_create`        DATETIME(6),
    `gmt_modified`      DATETIME(6),
    PRIMARY KEY (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
    `row_key`        VARCHAR(128) NOT NULL,
    `xid`            VARCHAR(96),
    `transaction_id` BIGINT,
    `branch_id`      BIGINT       NOT NULL,
    `resource_id`    VARCHAR(256),
    `table_name`     VARCHAR(32),
    `pk`             VARCHAR(36),
    `gmt_create`     DATETIME,
    `gmt_modified`   DATETIME,
    PRIMARY KEY (`row_key`),
    KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8;

部署Seata Server

以上工作准備就緒,進入bin目錄運行seata-server.bat(windows用戶)/seata-server.sh(linux用戶)即可。

Seata應用場景模擬

這里做一個用戶服務用戶登錄成功后調用會員服務增加會員積分場景案例。

父工程改造

工程名稱：spring-cloud-alibaba-version-parent，增加mybatis，seata序列化等依賴版本管理。

<!-- properties 增加版本號 -->
<!-- mybatis -->
<mybatis.plus.version>3.4.2</mybatis.plus.version>
<mybatis.plus.ds.version>2.5.4</mybatis.plus.ds.version>
<seata.serializer.kryo.version>1.3.0</seata.serializer.kryo.version>

<!-- dependencyManagement 增加以下依賴 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>${mybatis.plus.version}</version>
</dependency>
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-serializer-kryo</artifactId>
    <version>${seata.serializer.kryo.version}</version>
</dependency>

會員服務工程改造

工程名稱:spring-cloud-alibaba-service-member,增加數據庫與Seata依賴，增加用戶會員積分接口。

pom.xml

 <!-- Seata  & mybatis-plus -->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
<dependency>
	<groupId>io.seata</groupId>
	<artifactId>seata-serializer-kryo</artifactId>
</dependency>
<dependency>
	<groupId>com.baomidou</groupId>
	<artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>
<dependency>
	<groupId>mysql</groupId>
	<artifactId>mysql-connector-java</artifactId>
</dependency>

bootstrap.yaml

#注意,此處省略之前配置的信息....
#注意,此處省略之前配置的信息....
#注意,此處省略之前配置的信息....
#注意,此處省略之前配置的信息....
#數據庫信息配置
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/member_db?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true
    username: root
    password: 123456
#Seata配置
seata:
  enabled: true
  application-id: ${spring.application.name}
  #對應nacos配置 service.vgroupMapping.my_test_tx_group
  tx-service-group: 'my_test_tx_group'
  service:
    vgroup-mapping:
      #對應nacos配置 service.vgroupMapping.my_test_tx_group 的值 default
      my_test_tx_group: 'default'
  registry:
    type: nacos
    nacos:
      server-addr: ${spring.cloud.nacos.discovery.server-addr}
      namespace: ${spring.cloud.nacos.discovery.namespace}
      group: ${spring.cloud.nacos.discovery.group}
      #cluster: ${spring.cloud.nacos.discovery.cluster}
  config:
    type: nacos
    nacos:
      server-addr: ${spring.cloud.nacos.discovery.server-addr}
      namespace: ${spring.cloud.nacos.discovery.namespace}
      group: ${spring.cloud.nacos.discovery.group}

注意事項：

1. bootstrap.yaml中seata.tx-service-group 配置項一定要配置nacos配置中心中service.vgroupMapping對應的my_test_tx_group。也就是說一定要保持一致。
2. bootstrap.yaml中seata.service.vgroup-mapping.my_test_tx_group配置項一定要配置nacos配置中心對應service.vgroupMapping.my_test_tx_group配置祥的值。

如果沒有注意上方兩點將會導致啟動時報:no available service 'default' found, please make sure registry config correct。

創建member_db數據庫

其中undo_log表為Seata回滾日志表，需要在每個使用到Seata的業務服務數據庫中都需要創建。

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_member_integral
-- ----------------------------
DROP TABLE IF EXISTS `t_member_integral`;
CREATE TABLE `t_member_integral`  (
  `ID` bigint(20) NOT NULL COMMENT '主鍵',
  `USERNAME` varchar(55) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '用戶名稱',
  `INTEGRAL` int(11) DEFAULT NULL COMMENT '積分',
  `CREDATE` datetime(0) DEFAULT NULL COMMENT '時間',
  PRIMARY KEY (`ID`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Table structure for 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) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int(11) NOT NULL,
  `log_created` datetime(0) NOT NULL,
  `log_modified` datetime(0) NOT NULL,
  `ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

新增會員積分CRUD

我這里新增以下類,具體內容大家都比較熟悉。

MemberIntegralController.java
IMemberIntegralBiz.java
IMemberIntegralBizImpl.java
MemberIntegralMapper.java
MemberIntegral.xml

在這里所有增加會員積分的邏輯都寫在同一個類中 MemberIntegralController.java

import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.gitee.eample.member.service.biz.IMemberIntegralBiz;
import com.gitee.eample.member.service.domain.MemberIntegral;
import com.gtiee.example.common.exception.Response;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Date;

/**
 * 用戶積分
 *
 * @author wentao.wu
 */
@RestController
@RequestMapping("/member/integral")
public class MemberIntegralController {
    @Autowired
    private IMemberIntegralBiz memberIntegralBiz;

    @PostMapping("/login/{username}")
    public Response<Boolean> login(@PathVariable("username") String username) {
        // 每天第一次登錄則增加積分，我這里就不判斷了，每次調用都新增一條積分記錄了
        MemberIntegral memberIntegral = new MemberIntegral();
        memberIntegral.setId(IdWorker.getId());
        memberIntegral.setIntegral(10);//固定10積分
        memberIntegral.setUsername(username);
        memberIntegral.setCredate(new Date());
        memberIntegralBiz.save(memberIntegral);
        return Response.createOk("登錄新增會員積分成功!", true);
    }
}

運行MemberServiceApplication.java啟動服務，如果想知道有沒有注冊成功：

第一可以看Seata Server端有沒有日志輸出，該日志內容主要為注冊的業務服務的數據庫信息。

第二可以看業務服務有沒有輸出以下日志，有輸出以下日志則Seata Server端注冊成功

2021-11-05 09:56:30.962  INFO 16420 --- [           main] i.s.c.r.netty.NettyClientChannelManager  : will connect to 2.0.4.58:8091
2021-11-05 09:56:30.962  INFO 16420 --- [           main] i.s.c.rpc.netty.RmNettyRemotingClient    : RM will register :jdbc:mysql://localhost:3306/member_db
2021-11-05 09:56:30.967  INFO 16420 --- [           main] i.s.core.rpc.netty.NettyPoolableFactory  : NettyPool create channel to transactionRole:RMROLE,address:2.0.4.58:8091,msg:< RegisterRMRequest{resourceIds='jdbc:mysql://localhost:3306/member_db', applicationId='service-member', transactionServiceGroup='my_test_tx_group'} >

用戶服務工程改造

工程名稱:spring-cloud-alibaba-service-member,增加數據庫與Seata依賴，增加用戶登錄接口，增加調用會員服務積分接口feign。

由於內容一致此處省略pom.xml,bootstrap.xml(里面注意數據庫要修改為用戶服務的數據庫)。

創建user_db數據庫

其中undo_log表為Seata回滾日志表，需要在每個使用到Seata的業務服務數據庫中都需要創建。

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_user
-- ----------------------------
DROP TABLE IF EXISTS `t_user`;
CREATE TABLE `t_user`  (
  `ID` bigint(20) NOT NULL COMMENT '主鍵',
  `USERNAME` varchar(55) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '用戶名',
  `PWD` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '密碼',
  `ADDR` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '地址',
  `LAST_LOGIN_DATE` datetime(0) DEFAULT NULL COMMENT '最后登錄時間',
  PRIMARY KEY (`ID`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of t_user
-- ----------------------------
INSERT INTO `t_user` VALUES (1, 'test1', '123456', '123', NULL);

-- ----------------------------
-- Table structure for 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) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int(11) NOT NULL,
  `log_created` datetime(0) NOT NULL,
  `log_modified` datetime(0) NOT NULL,
  `ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

新增用戶登錄CRUD

我這里新增以下類,具體內容大家都比較熟悉。

UserController.java
IUserBiz.java
IUserBizImpl.java
UserMapper.java
UserMapper.xml
MemberInfoControllerClient.java

MemberInfoControllerClient.java

/**
 * service-member服務遠程調用接口
 *
 * @author wentao.wu
 */
@FeignClient(name = "service-member")
public interface MemberInfoControllerClient {
    /**
     * 登錄送積分
     *
     * @param username
     * @return
     */
    @PostMapping("/member/integral/login/{username}")
    Response<Boolean> login(@PathVariable("username")String username);
}

IUserBiz.java

public interface IUserBiz extends IService<User> {
    /**
     * 用戶登錄並且贈送第一次登錄積分
     *
     * @param command
     * @return
     */
    boolean login(UserLoginCommand command);

}

IUserBizImpl.java

package com.gitee.eample.user.service.biz;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gitee.eample.user.service.controller.command.UserLoginCommand;
import com.gitee.eample.user.service.dao.UserMapper;
import com.gitee.eample.user.service.domain.User;
import com.gitee.eample.user.service.feign.MemberInfoControllerClient;
import com.gtiee.example.common.exception.Response;
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import java.util.Date;

@Service
public class IUserBizImpl extends ServiceImpl<UserMapper, User> implements IUserBiz {

    @Autowired
    private MemberInfoControllerClient client;

    @GlobalTransactional(name = "login_add_member_intergral",rollbackFor = Exception.class)//開啟分布式事務
    @Override
    public boolean login(UserLoginCommand command) {
        LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(User::getUsername, command.getUsername())
                .eq(User::getPwd, command.getPwd());
        User loginUser = getOne(wrapper);
        if (ObjectUtils.isEmpty(loginUser)) {
            return false;
        }
        //調用會員登錄接口增加積分
        Response<Boolean> response = client.login(command.getUsername());
        if (response.isOk()) {//增加積分成功，或已增加積分
            //調用積分接口成功，修改當前用戶登錄時間
            loginUser.setLastLoginDate(new Date());
            updateById(loginUser);
            //假設此處發生異常，不但修改當前用戶登錄時間需要回滾並且新增的會員積分信息也回滾才算正常
            int i = 0 / 0;
            return true;
        } else {
            //增加積分失敗
            return false;
        }
    }
}

UserController.java

import com.gitee.eample.user.service.biz.IUserBiz;
import com.gitee.eample.user.service.controller.command.UserLoginCommand;
import com.gtiee.example.common.exception.Response;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * User Business Controller
 *
 * @author wentao.wu
 */
@RestController
@RequestMapping("/users/")
public class UserController {
    private Logger logger = LoggerFactory.getLogger(UserController.class);
    @Autowired
    private IUserBiz userBiz;

    @PostMapping("/login")
    public Response<Boolean> login(UserLoginCommand command) {
        try {
            boolean result = userBiz.login(command);
            if (result) {
                return Response.createOk("登錄並贈送積分成功!", result);
            }else{
                return Response.createError("賬號或密碼不存在!", result);
            }
        } catch (Exception e) {
            logger.error("登錄失敗!", e);
            return Response.createError("服務器繁忙請稍后再試!", false);
        }
    }

}

運行啟動類UserServiceApplication.java。

服務改造成功后主要模擬有三個場景：

1. 有分布式事務處理發生異常場景：調用積分接口成功，修改當前用戶登錄時間之后發生異常，用戶表的修改操作進行回滾，同時會員服務新增的用戶對應的積分數據同樣發生回滾
2. 無分布式事務處理發生異常場景: 調用積分接口成功，修改當前用戶登錄時間之后發生異常，用戶表的修改操作進行回滾，用戶會員新增的數據並沒有發生回滾，此處造成數據異常。
3. 正常執行場景: 調用積分接口成功，修改當前用戶登錄時間之后未發生異常，所有操作生效。

有分布式事務處理發生異常場景

IUserBizImpl.java中login方法增加分布式事務注解 @GlobalTransactional(name = "login_add_member_intergral",rollbackFor = Exception.class)//開啟分布式事務，name為屬性名稱，rollbackFor 為指定回滾異常。

首先在用戶服務表中插入一條用戶數據，作為登錄用戶：

INSERT INTO `user_db`.`t_user`(`ID`, `USERNAME`, `PWD`, `ADDR`, `LAST_LOGIN_DATE`) VALUES (1, 'test1', '123456', '123', NULL);

並且當前會員服務t_member_integral表中還沒有數據還沒初始化過數據，當前場景操作會修改t_user.LAST_LOGIN_DATE，並且向t_member_integral表中插入數據；但是最后發生異常導致操作失敗，並且存在分布式事務注解，此時會回滾所有服務DML操作。

請求用戶登錄接口:

請求成功后查看t_user與t_member_integral依舊沒有發生任何改變：

表示分布式事務處理成功無任何異常。

無分布式事務處理發生異常場景

IUserBizImpl.java中login方法注釋掉全局事務(分布式事務),並且修改為本地事務：

//@GlobalTransactional(name = "login_add_member_intergral",rollbackFor = Exception.class)//開啟分布式事務
@Transactional

請求用戶登錄接口:

此時發生的異常導致了用戶服務中修改LAST_LOGIN_DATE操作被回滾成功，但是t_member_integral表中依然插入了積分數據並未被回滾：

表示在跨服務調用下沒有分布式事務將會導致數據不一致，事務異常。

正常執行場景

IUserBizImpl.java中login方法注釋掉本地事務,並且修改為全局事務（分布式事務），這里改不改無所謂，事務都是成功的，無論使用本地事務與全局事務都不會有問題，此處改成全局事務主要是驗證全局事務不會影響什么：

@GlobalTransactional(name = "login_add_member_intergral",rollbackFor = Exception.class)//開啟分布式事務
//@Transactional

同時將login方法中的異常處理去除掉:

//假設此處發生異常，不但修改當前用戶登錄時間需要回滾並且新增的會員積分信息也回滾才算正常
int i = 0 / 0;

請求用戶登錄接口，此時所有操作全部成功，用戶服務修改LAST_LOGIN_DATE成功，並且t_member_integral表中數據新增成功；這里就不貼圖了，浪費大家流量。

總結

• 每個業務服務對應的數據庫中都需要包含undo_log表，這個表主要是記錄全局事務操作的日志，后續發生異常Seata會通過該日志進行事務回滾補償;
• Seata回滾反序列化時Date類型無法反序列化，所以要修改Seata的序列化為：kryo;(此問題將在1.5版本 Seata發布后徹底解決)

源碼代碼存放地址

gitee: https://gitee.com/SimpleWu/spring-cloud-alibaba-example.git
cnblogs: https://www.cnblogs.com/SimpleWu
持續更新目錄:https://www.cnblogs.com/SimpleWu/p/15476427.html