解决方案之2PC

针对不同的分布式场景业界常见的解决方案有2PC、TCC、可靠消息最终一致性、最大努力通知这几种。

1. 什么是2PC

2PC即两阶段提交协议，是将整个事务流程分为两个阶段，准备阶段(Prepare phase)、提交阶段(commit phase)，2是指两个阶段，P是指准备阶段，C是指提交阶段。
举例：张三和李四好久不见，老友约起聚餐，饭店老板要求先买单，才能出票。这时张三和李四分别抱怨近况不如意，囊中羞涩，都不愿意请客，这时只能AA。只有张三和李四都付款，老板才能出票安排就餐。但由于张三和李四都是铁公鸡，形成了尴尬的一幕：
准备阶段：老板要求张三付款，张三付款。老板要求李四付款，李四付款。
提交阶段：老板出票，两人拿票纷纷落座就餐。
例子中形成了一个事务，若张三或李四其中一人拒绝付款，或钱不够，店老板都不会给出票，并且会把已收款退回。
整个事务过程由事务管理器和参与者组成，店老板就是事务管理器，张三、李四就是事务参与者，事务管理器负责决策整个分布式事务的提交和回滚，事务参与者负责自己本地事务的提交和回滚。在计算机中部分关系数据库如Oracle、MySQL支持两阶段提交协议，如下图：

准备阶段(Prepare phase)：事务管理器给每个参与者发送Prepare消息，每个数据库参与者在本地执行事务，并写本地的Undo/Redo日志，此时事务没有提交。
(Undo日志是记录修改前的数据，用于数据库回滚，Redo日志是记录修改后的数据，用于提交事务后写入数据文件)
提交阶段(Commit phase)：如果事务管理器收到了参与者的执行失败或者超时消息时，直接给每个参与者发送回滚(Rollback)消息；否则，发送提交(Commit)消息；参与者根据事务管理器的指令执行提交或者回滚操作，并释放事务处理过程中使用的锁资源。注意:必须在最后阶段释放锁资源。
下图展示了2PC的两个阶段，分成功和失败两个情况说明：
成功情况
失败情况

2. 解决方案-XA方案

2.1 分布式事务处理模型DTP

2PC的传统方案是在数据库层面实现的，如Oracle、MySQL都支持2PC协议，为了统一标准减少行业内不必要的对接成本，需要制定标准化的处理模型及接口标准，国际开放标准组织Open Group定义了分布式事务处理模型DTP(Distributed Transaction Processing Reference Model)。
为了让大家更明确XA方案的内容，下面新用户注册送积分为例来说明：
Alt text 执行流程如下：

应用程序(AP)持有用户库和积分库两个数据源。
应用程序(AP)通过TM通知用户库RM新增用户，同时通知积分库RM为该用户新增积分，RM此时并未提交事务，此时用户和积分资源锁定。
TM收到执行回复，只要有一方失败则分别向其他RM发起回滚事务，回滚完毕，资源锁释放。
TM收到执行回复，全部成功，此时向所有RM发起提交事务，提交完毕，资源锁释放。

DTP模型定义如下角色:

AP(Application Program)：即应用程序，可以理解为使用DTP分布式事务的程序。
RM(Resource Manager)：即资源管理器，可以理解为事务的参与者，一般情况下是指一个数据库实例，通过资源管理器对该数据库进行控制，资源管理器控制着分支事务。
TM(Transaction Manager)：事务管理器，负责协调和管理事务，事务管理器控制着全局事务，管理事务生命周期，并协调各个RM。全局事务是指分布式事务处理环境中，需要操作多个数据库共同完成一个工作，这个工作即是一个全局事务。
DTP模型定义TM和RM之间通讯的接口规范叫XA，简单理解为数据库提供的2PC接口协议，基于数据库的XA协议来实现2PC又称为XA方案。
以上三个角色之间的交互方式如下：
1)TM向AP提供应用程序编程接口，AP通过TM提交及回滚事务。
2)TM交易中间件通过XA接口来通知RM数据库事务的开始、结束以及提交、回滚等。

2.2 总结

整个2PC的事务流程涉及到三个角色AP、RM、TM。AP指的是使用2PC分布式事务的应用程序；RM指的是资源管理器，它控制着分支事务；TM指的是事务管理器，它控制着整个全局事务。
- 在准备阶段RM执行实际的业务操作，但不提交事务，资源锁定；
- 在提交阶段TM会接受RM在准备阶段的执行回复，只要有任一个RM执行失败，TM会通知所有RM执行回滚操作，否则，TM将会通知所有RM提交该事务。提交阶段结束资源锁释放。
XA方案的问题
- 需要本地数据库支持XA协议。
- 资源锁需要等到两个阶段结束才释放，性能较差。

3. 解决方案-Seata方案

Seata是由阿里中间件团队发起的开源项目Fescar，后更名为Seata，它是一个是开源的分布式事务框架。传统2PC的问题在Seata中得到了解决，它通过对本地关系数据库的分支事务的协调来驱动完成全局事务，是工作在应用层的中间件。主要优点是性能较好，且不长时间占用连接资源，它以高效并且对业务0侵入的方式解决微服务场景下面临的分布式事务问题，它目前提供AT模式(即2PC)及TCC模式的分布式事务解决方案。 Seata的设计思想如下：
Seata的设计目标其一是对业务无侵入，因此从业务无侵入的2PC方案着手，在传统2PC的基础上演进，并解决2PC方案面临的问题。
Seata把一个分布式事务理解成一个包含了若干分支事务的全局事务。全局事务的职责是协调其下管辖的分支事务达成一致，要么一起成功提交，要么一起失败回滚。此外，通常分支事务本身就是一个关系数据库的本地事务，下图是全局事务与分支事务的关系图： Alt text 与传统2PC的模型类似，Seata定义了3个组件来协议分布式事务的处理过程：

Transaction Coordinator(TC)：事务协调器，它是独立的中间件，需要独立部署运行，它维护全局事务的运行状态，接收TM指令发起全局事务的提交与回滚，负责与RM通信协调各各分支事务的提交或回滚。
Transaction Manager(TM)：事务管理器，TM需要嵌入应用程序中工作，它负责开启一个全局事务，并最终向TC发起全局提交或全局回滚的指令。
Resource Manager(RM)：控制分支事务，负责分支注册、状态汇报，并接收事务协调器TC的指令，驱动分支(本地)事务的提交和回滚。
还拿新用户注册送积分举例Seata的分布式事务过程：

具体的执行流程如下：

用户服务的TM向TC申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的XID。
用户服务的RM向TC注册分支事务，该分支事务在用户服务执行新增用户逻辑，并将其纳入XID对应全局事务的管辖。
用户服务执行分支事务，向用户表插入一条记录。
逻辑执行到远程调用积分服务时(XID在微服务调用链路的上下文中传播)。积分服务的RM向TC注册分支事务，该分支事务执行增加积分的逻辑，并将其纳入 XID 对应全局事务的管辖。
积分服务执行分支事务，向积分记录表插入一条记录，执行完毕后，返回用户服务。
用户服务分支事务执行完毕。
TM向TC发起针对XID的全局提交或回滚决议。
TC调度XID下管辖的全部分支事务完成提交或回滚请求。

Seata实现2PC与传统2PC的差别：

架构层次方面，传统2PC方案的RM实际上是在数据库层，RM本质上就是数据库自身，通过XA协议实现，而Seata的RM是以jar包的形式作为中间件层部署在应用程序这一侧的。
两阶段提交方面，传统2PC无论第二阶段的决议是commit还是rollback，事务性资源的锁都要保持到Phase2完成才释放。而Seata的做法是在Phase1 就将本地事务提交，这样就可以省去Phase2持锁的时间，整体提高效率。

4. Seata实现2PC事务

4.1 业务功能需求

两个账户在三个不同的银行(张三在bank1、李四在bank2)，bank1和bank2是两个个微服务。交易过程是，张三给李四转账指定金额。
上述交易步骤，要么一起成功，要么一起失败，必须是一个整体性的事务。
Alt text

4.2 程序实现

用户转账的业务逻辑。整个业务逻辑由2个微服务提供支持：

bank1金融服务
bank2金融服务

使用技术架构: Dubbo + SEATA + Zookeeper + SpringBoot + MySQL

4.2 部署Seata、Zookeeper

下载SEATA: https://seata.apache.org/zh-cn/unversioned/download/seata-server
解压并启动

cmd

seata-server.bat -p 8888 -m file

其中8888为服务端口号, m为启动模式，file指seata服务将采用文件的方式存储信息。
启动完成：
Alt text 3. 下载Zookeeper: https://zookeeper.apache.org/releases.html
4. 解压并启动

cmd

D:\apache-zookeeper-3.7.2-bin\conf>copy zoo_sample.cfg zoo.cfg
D:\apache-zookeeper-3.7.2-bin\conf>cd ../bin
D:\apache-zookeeper-3.7.2-bin\bin>zkServer.cmd

启动完成： Alt text

4.3 数据库初始化

在MySQL数据库中创建bank1和bank2两个数据库, 导入数据库脚本。

bank1.sqlbank2.sql

sql

CREATE DATABASE `bank1` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';

DROP TABLE IF EXISTS `account_info`;
CREATE TABLE `account_info` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`account_name` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '户
主姓名',
`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '银行
卡号',
`account_password` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT
'帐户密码',
`account_balance` double NULL DEFAULT NULL COMMENT '帐户余额',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT =
Dynamic;
INSERT INTO `account_info` VALUES (2, '张三的账户', '1', '', 10000);

sql

CREATE DATABASE `bank2` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';

CREATE TABLE `account_info` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`account_name` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '户
主姓名',
`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '银行
卡号',
`account_password` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT
'帐户密码',
`account_balance` double NULL DEFAULT NULL COMMENT '帐户余额',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT =
Dynamic;
INSERT INTO `account_info` VALUES (3, '李四的账户', '2', NULL, 0);

分别在bank1、bank2库中创建undo_log表，此表为Seata框架使用:

sql

CREATE TABLE IF NOT EXISTS `undo_log`
(
    `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
    ) ENGINE = InnoDB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);

4.4 工程代码

源码附上： https://gitee.com/javaee_home/distritrans_learn

搭建springboot+dubbo工程项目访问https://start.dubbo.apache.org/bootstrap.html ，按照下图在线生成代码：其中需要勾选的Dependencies为：

Dubbo Registry & Config & Metadata: zookeeper
Dubbo Protocol: TCP
Web: SpringWeb
SQL: MyBatis Framework
点击生成后下载导入IDEA进行代码调整。

创建三个子模块：

dtx-seata-bank1: 操作张三账户，连接数据库bank1
dtx-seata-bank2: 操作李四账户，连接数据库bank2
dtx-seata-common: 接口模块，用于第三方调用接口服务包

父工程中指定springboot、dubbo、seata版本

distritrans_learndtx-seata-commondtx-seata-bank1dtx-seata-bank2

xml

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
</properties>

<modules>
    <module>dtx-seata-bank1</module>
    <module>dtx-seata-bank2</module>
    <module>dtx-seata-common</module>
</modules>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <type>pom</type>
            <version>3.2.10</version>
            <exclusions>
                <exclusion>
                    <artifactId>log4j</artifactId>
                    <groupId>log4j</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>slf4j-log4j12</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>2.7.18</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <version>8.0.33</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>3.2.10</version>
        </dependency>
        <dependency>
            <groupId>io.seata</groupId>
            <artifactId>seata-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.3.2</version>
        </dependency>
    </dependencies>
</dependencyManagement>

xml

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <java.version>1.8</java.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

xml

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <java.version>1.8</java.version>
</properties>
<dependencies>
    <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.2.21</version>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>com.example</groupId>
        <artifactId>dtx-seata-common</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <type>pom</type>
        <exclusions>
            <exclusion>
                <artifactId>log4j</artifactId>
                <groupId>log4j</groupId>
            </exclusion>
            <exclusion>
                <artifactId>slf4j-log4j12</artifactId>
                <groupId>org.slf4j</groupId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

xml

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <java.version>1.8</java.version>
</properties>

<dependencies>
    <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
    </dependency>
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.2.21</version>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <type>pom</type>
        <exclusions>
            <exclusion>
                <artifactId>log4j</artifactId>
                <groupId>log4j</groupId>
            </exclusion>
            <exclusion>
                <artifactId>slf4j-log4j12</artifactId>
                <groupId>org.slf4j</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>com.example</groupId>
        <artifactId>dtx-seata-common</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

配置Seata
Seata自1.0之后支持yml文件配置，可以不再需要registry.conf、file.conf文件，直接所有配置加入合并到application.yml文件中，另外这里项目简单起见，不使用配置中心, 直接采用本地yml文件直连Seata方式。
XA模式是Seata创新的一种非侵入式的分布式事务解决方案，Seata在内部做了对数据库操作的代理层，我们使用Seata XA模式时，实际上用的是Seata自带的数据源代理DataSourceProxyXA，Seata在这层代理中加入了很多逻辑，比如插入回滚undo_log日志，检查全局锁等。
在dtx-seata-bank1模块和dtx-seata-bank2模块配置application.yml:

dtx-seata-bank1dtx-seata-bank2

yml

server:
  port: 8081
#====================================stream =============================================
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.101.105:3306/bank1?useSSL=false&allowMultiQueries=true
    username: root
    password: root
  application:
    name: dtx-seata-bank1

#====================================mybatis =============================================
mybatis:
  mapper-locations: classpath:mapper/*Mapper.xml
  type-aliases-package: com.example.dtxseatabank1.entity
  configuration:
    map-underscore-to-camel-case: true

#====================================Dubbo config===============================================
dubbo:
  application:
    id: dtx-seata-bank1
    name: dtx-seata-bank1
    qosEnable: false
  protocol:
    id: dubbo
    name: dubbo
    port: 20880
  registry:
    id: dtx-seata-bank1-registry
    address: zookeeper://192.168.101.105:2181
  config-center:
    address: zookeeper://192.168.101.105:2181
  metadata-report:
    address: zookeeper://192.168.101.105:2181
#====================================Seata Config===============================================
seata:
  enabled: true
  application-id: dtx-seata-bank1
  tx-service-group: my_test_tx_group # 事务群组(可以每个应用独立取名，也可以使用相同的名字)
  client:
    rm-report-success-enable: true
    rm-table-meta-check-enable: false # 自动刷新缓存中的表结构(默认false)
    rm-report-retry-count: 5 # 一阶段结果上报TC重试次数(默认5)
    rm-async-commit-buffer-limit: 10000 # 异步提交缓存队列长度(默认10000)
    rm:
      lock:
        lock-retry-internal: 10 # 校验或占用全局锁重试间隔(默认10ms)
        lock-retry-times: 30 # 校验或占用全局锁重试次数(默认30)
        lock-retry-policy-branch-rollback-on-conflict: true # 分支事务与其它全局回滚事务冲突时锁策略(优先释放本地锁让回滚成功)
    tm-commit-retry-count: 3 # 一阶段全局提交结果上报TC重试次数(默认1次，建议大于1)
    tm-rollback-retry-count: 3 # 一阶段全局回滚结果上报TC重试次数(默认1次，建议大于1)
    undo:
      undo-data-validation: true # 二阶段回滚镜像校验(默认true开启)
      undo-log-serialization: jackson # undo序列化方式(默认jackson)
      undo-log-table: undo_log  # 自定义undo表名(默认undo_log)
    support:
      spring:
        datasource-autoproxy: true
  service:
    vgroup-mapping:
      my_test_tx_group: default # TC 集群(必须与seata-server保持一致)
    enable-degrade: false # 降级开关
    disable-global-transaction: false # 禁用全局事务(默认false)
    grouplist:
      default: 192.168.101.104:8888
  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
    type: TCP
    server: NIO
    heartbeat: true
    serialization: seata
    compressor: none
    enable-client-batch-send-request: true # 客户端事务消息请求是否批量合并发送(默认true)
  log:
    exception-rate: 100
  data-source-proxy-mode: XA  # 采用XA模式, 默认AT模式

yml

server:
  port: 8108
#====================================stream =============================================
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.101.105:3306/bank2?useSSL=false&allowMultiQueries=true
    username: root
    password: root
  application:
    name: dtx-seata-bank2

#====================================mybatis =============================================
mybatis:
  mapper-locations: classpath:mapper/*Mapper.xml
  type-aliases-package: com.example.dtxseatabank2.entity
  configuration:
    map-underscore-to-camel-case: true
#====================================Dubbo config===============================================
dubbo:
  application:
    id: dtx-seata-bank2
    name: dtx-seata-bank2
    qosEnable: false
  protocol:
    id: dubbo
    name: dubbo
    port: 20885
  registry:
    id: dtx-seata-bank2-registry
    address: zookeeper://192.168.101.105:2181
  config-center:
    address: zookeeper://192.168.101.105:2181
  metadata-report:
    address: zookeeper://192.168.101.105:2181

#====================================Seata Config===============================================
seata:
  enabled: true
  application-id: dtx-seata-bank2
  tx-service-group: my_test_tx_group # 事务群组(可以每个应用独立取名，也可以使用相同的名字)
  client:
    rm-report-success-enable: true
    rm-table-meta-check-enable: false # 自动刷新缓存中的表结构(默认false)
    rm-report-retry-count: 5 # 一阶段结果上报TC重试次数(默认5)
    rm-async-commit-buffer-limit: 10000 # 异步提交缓存队列长度(默认10000)
    rm:
      lock:
        lock-retry-internal: 10 # 校验或占用全局锁重试间隔(默认10ms)
        lock-retry-times: 30 # 校验或占用全局锁重试次数(默认30)
        lock-retry-policy-branch-rollback-on-conflict: true # 分支事务与其它全局回滚事务冲突时锁策略(优先释放本地锁让回滚成功)
    tm-commit-retry-count: 3 # 一阶段全局提交结果上报TC重试次数(默认1次，建议大于1)
    tm-rollback-retry-count: 3 # 一阶段全局回滚结果上报TC重试次数(默认1次，建议大于1)
    undo:
      undo-data-validation: true # 二阶段回滚镜像校验(默认true开启)
      undo-log-serialization: jackson # undo序列化方式(默认jackson)
      undo-log-table: undo_log  # 自定义undo表名(默认undo_log)
    support:
      spring:
        datasource-autoproxy: true
  service:
    vgroup-mapping:
      my_test_tx_group: default # TC 集群(必须与seata-server保持一致)
    enable-degrade: false # 降级开关
    disable-global-transaction: false # 禁用全局事务(默认false)
    grouplist:
      default: 192.168.101.104:8888
  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
    type: TCP
    server: NIO
    heartbeat: true
    serialization: seata
    compressor: none
    enable-client-batch-send-request: true # 客户端事务消息请求是否批量合并发送(默认true)
  log:
    exception-rate: 100
  data-source-proxy-mode: XA  # 采用XA模式

关于vgroup_mapping的配置： vgroup_mapping.事务分组服务名=Seata Server集群名称(默认名称为default) default.grouplist = Seata Server集群地址
5. 功能代码实现张三转账

DtxSeataBank1Application.javaApiController.javaBank1MoneyServiceImpl.javaAccountInfoMapper.java

java

@SpringBootApplication(scanBasePackages = "com.example.dtxseatabank1",
        exclude = {DataSourceAutoConfiguration.class})
@EnableDubbo(scanBasePackages = "com.example.dtxseatabank1")
@MapperScan("com.example.dtxseatabank1.mapper")
public class DtxSeataBank1Application {

    public static void main(String[] args) {

        SpringApplication.run(DtxSeataBank1Application.class, args);
    }
}

java

@Autowired
Bank1MoneyService bank1MoneyService;

@RequestMapping("/transferMoney")
public Map<String, String> transferMoney(String amount){
    Map<String, String> result = new HashMap<>();
    bank1MoneyService.updateAccountBalance("1", Double.parseDouble(amount));
    result.put("code", "success");
    return result;
}

java

private Logger logger = LoggerFactory.getLogger(Bank1MoneyServiceImpl.class);
@Autowired
AccountInfoMapper accountInfoMapper;
@DubboReference(version = "1.0.0", timeout = 6000) // 设置6s可以验证超时回滚
private Bank2MoneyService bank2MoneyService;

//张三转账
@GlobalTransactional   // 开启全局事务
@Transactional
public void updateAccountBalance(String accountNo, double amount) {
    logger.info("******** Bank1 Service Begin ... xid: {}", RootContext.getXID());
    //张三扣减金额
    accountInfoMapper.updateAccountBalance(accountNo, amount);
    //向李四转账

    String remoteRst = bank2MoneyService.transfer("李四", amount);
    //远程调用失败
    if (remoteRst.equals("fallback")) {
        throw new RuntimeException("bank1 下游服务异常");
    }
    //人为制造错误
    if (amount == 3) {
        throw new RuntimeException("bank1 make exception 3");
    }
}

java

@Mapper
public interface AccountInfoMapper {

    //更新账户金额
    int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);
}

将@GlobalTransactional注解标注在全局事务发起的Service实现方法上，开启全局事务：
GlobalTransactionalInterceptor会拦截@GlobalTransactional注解的方法，生成全局事务ID(XID)，XID会在整个分布式事务中传递。在远程调用时，Seata会拦截dubbo调用将XID传递到下游服务。

Dubbo注解说明

@Service、@Reference注解从Dubbo3.0版本开始就已经废弃，改用@DubboService和@DubboReference，以区别于Spring中的@Service 、@Reference注解, 另外EnableDubbo用来启动Dubbo相关配置并指定Spring Boot扫描包路径。

功能代码实现李四转账
李四账号事务中作为分支事务不使用@GlobalTransactional, 本地事务方案仍然使用@Transactional标识

Bank2MoneyServiceImpl.javaDtxSeataBank2Application.javaAccountInfoMapper.java

java

@DubboService(version = "1.0.0", interfaceClass = Bank2MoneyService.class)
public class Bank2MoneyServiceImpl implements Bank2MoneyService {

    private Logger logger = LoggerFactory.getLogger(Bank2MoneyServiceImpl.class);
    @Autowired
    AccountInfoMapper accountInfoMapper;

    @Transactional
    public String transfer(String accountNo, double amount) {
        logger.info("******** Bank2 Service Begin ... xid: {}", RootContext.getXID());
        //李四增加金额
        accountInfoMapper.updateAccountBalanceByName(accountNo, amount);
        //制造异常
        if (amount == 2) {
            throw new RuntimeException("bank1 make exception 2");
        }
        // 制造超时
        if(amount == 4){
            try {
                Thread.sleep(7000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
        return "bank2" + amount;
    }
}

java

@SpringBootApplication(scanBasePackages = "com.example.dtxseatabank2",
        exclude = {DataSourceAutoConfiguration.class})
@EnableDubbo(scanBasePackages = "com.example.dtxseatabank2")
@MapperScan("com.example.dtxseatabank2.mapper")
public class DtxSeataBank2Application {

    public static void main(String[] args) {
        SpringApplication.run(DtxSeataBank2Application.class, args);
    }

}

java

@Mapper
public interface AccountInfoMapper {
    //更新账户金额
    int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);
}

启动项目后，可以观察Zookeeper上面Dubbo服务元数据信息和Dubbo服务信息：

测试场景

张三向李四转账成功。
李四事务失败，张三事务回滚成功。
张三事务失败，李四事务回滚成功。
分支事务超时测试。测试过程中如果打断点，阻塞时可以可以观察Seata服务页面全局事务情况：访问地址是：http://Seata服务器IP地址:7091/

信息

目前Seata只是提供了控制台查询事务数据功能，但还未提供任何事务控制能力

解决方案之2PC ​

1. 什么是2PC ​

2. 解决方案-XA方案 ​

2.1 分布式事务处理模型DTP ​

2.2 总结 ​

3. 解决方案-Seata方案 ​

4. Seata实现2PC事务 ​

4.1 业务功能需求 ​

4.2 程序实现 ​

4.2 部署Seata、Zookeeper ​

4.3 数据库初始化 ​

4.4 工程代码 ​

解决方案之2PC

1. 什么是2PC

2. 解决方案-XA方案

2.1 分布式事务处理模型DTP

2.2 总结

3. 解决方案-Seata方案

4. Seata实现2PC事务

4.1 业务功能需求

4.2 程序实现

4.2 部署Seata、Zookeeper

4.3 数据库初始化

4.4 工程代码