分布式事物【Seata实现、下载启动Seata服务、搭建聚合父工程构建】(四)-全面详解（学习总结---从入门到深化）

不念不忘少年蓝@ 2023-10-13 16:16 7阅读 0赞

## ![976e8e63178149ce89a54ff4a77609e1.gif][] ##

![06562dff83ca4349a9d9c7558c14da03.png][]

**目录**

分布式事物解决方案\_XA方案

分布式事物解决方案\_Seata实现

Seata提供XA模式实现分布式事务\_业务说明

Seata提供XA模式实现分布式事务\_下载启动Seata服务

Seata提供XA模式实现分布式事务\_搭建聚合父工程构建

创建工程distribute-transaction

字符编码

注解生效激活

Java编译版本选择

File Type过滤

pom配置版本

IDEA开启Dashboard

Seata提供XA模式实现分布式事务\_转账功能实现上

创建bank2

--------------------

## 分布式事物解决方案\_XA方案 ##

![10b253eb9425449293a3f3287bb98530.png][]

**什么是DTP**

2PC的传统方案是在数据库层面实现的，如Oracle、MySQL都支持 2PC协议，为了统一标准减少行业内不必要的对接成本，需要制定 标准化的处理模型及接口标准，国际开放标准组织Open Group定 义分布式事务处理模型DTP（Distributed Transaction Processing Reference Model）。

![c4d79fe0e02c4ac5a80d04baf1e17515.png][]

![8dcd23a79a444a96a18dee5b6050776b.png][]

##  ##

## 分布式事物解决方案\_Seata实现 ##

![de8703744524409da88f6d38074c0ee4.png][]

**Seata是什么**

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简 单易用的分布式事务服务。Seata 为用户提供了 **AT、TCC、SAGA** 和 **XA** 事务模式，为用户打造一站式的分布式解决方案。

![d9153a2beca04b33a1f4233d6646e506.png][]

**Seata整体框架**

**全局事务与分支事务的关系图**

![bc8fc5ad1a404ad39023c8eea04b2b1b.png][]

与传统2PC的模型类似，Seata定义了三个组件来协议分布式事务的处理过程

![0a1b06938def46898ad6d4f58acd3ccd.png][] ![321c165f9faa445b97479f1a9aab7d1e.png][]

还拿新用户注册送积分举例Seata的分布式事务过程

![6d82cbd2f78a4b12b8aa97a1c79ecec8.png][]

**执行流程 ：**

![1b1a5be7dfcc4831931d2ace9e3de576.png][]

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

![cb2c33b2891e4b1e980243a1cd14101a.png][]

##  ##

## Seata提供XA模式实现分布式事务\_业务说明 ##

![fb55fcaef0a0444680471fc6c0887fba.png][]

**业务说明**

本实例通过Seata中间件实现分布式事务，模拟两个账户的转账交易 过程。两个账户在两个不同的银行（张三在bank1、李四在 bank2），bank1和bank2是两个微服务。交易过程中，张三给李四 转账制定金额。上述交易步骤，要么一起成功，要么一起失败，必须是一个整体性的事务。

![f21416e7608b42e89defa90bcde9f1e6.png][]

**工程环境**

![d14dc0b9edcf4751b11925914c525cfb.png][]

**创建数据库**

**bank1库，包含张三账户**

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank1`
    /*!40100 DEFAULT CHARACTER SET utf8 */;
    USE `bank1`;
    /*Table structure for table `account_info` */
    DROP TABLE IF EXISTS `account_info`;
    CREATE TABLE `account_info` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT,
      `account_name` varchar(100) COLLATE utf8_bin
    DEFAULT NULL COMMENT '户主姓名'
    ,
      `account_no` varchar(100) COLLATE utf8_bin
    DEFAULT NULL COMMENT '银行卡号'
    ,
      `account_password` varchar(100) COLLATE
    utf8_bin DEFAULT NULL COMMENT '帐户密码'
    ,`account_balance` double DEFAULT NULL COMMENT
    '帐户余额'
    ,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT
    CHARSET=utf8 COLLATE=utf8_bin
    ROW_FORMAT=DYNAMIC;
    /*Data for the table `account_info` */
    insert  into
    `account_info`(`id`,`account_name`,`account_no`
    ,`account_password`,`account_balance`) values(2,'张三','1',NULL,1000);

**bank2库，包含李四账户**

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank2`
    /*!40100 DEFAULT CHARACTER SET utf8 */;
    USE `bank2`;
    /*Table structure for table `account_info` */
    DROP TABLE IF EXISTS `account_info`;
    CREATE TABLE `account_info` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT,
      `account_name` varchar(100) COLLATE utf8_bin
    DEFAULT NULL COMMENT '户主姓名'
    ,
      `account_no` varchar(100) COLLATE utf8_bin
    DEFAULT NULL COMMENT '银行卡号'
    ,
      `account_password` varchar(100) COLLATE
    utf8_bin DEFAULT NULL COMMENT '帐户密码'
    ,`account_balance` double DEFAULT NULL COMMENT
    '帐户余额'
    ,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT
    CHARSET=utf8 COLLATE=utf8_bin
    ROW_FORMAT=DYNAMIC;
    /*Data for the table `account_info` */
    insert  into
    `account_info`(`id`,`account_name`,`account_no`
    ,`account_password`,`account_balance`) values(3,'李四','2',NULL,0);

#  #

## Seata提供XA模式实现分布式事务\_下载启动Seata服务 ##

![b60acc5254d04d7e81813103a9da57d8.png][]

**下载seata服务器**

> 下载地址 ：https://github.com/seata/seata/releases

![575f296cd3a042b6b39a63e1cda611b0.png][]

**解压并启动**

tar -zxvf seata-server-1.4.2.tar.gz -C
    /usr/local/
    #后台运行
    nohup sh seata-server.sh -p 9999 -h
    192.168.66.100 -m file &> seata.log &

> **注意：**
> 
> 其中9999为服务端口号；file为启动模式，这里指seata服务将采用文件的方式存储信息。

**测试**

查看启动日志

cat seata.log

![423f30a086e845b69464fee67f94c440.png][]

#  #

## Seata提供XA模式实现分布式事务\_搭建聚合父工程构建 ##

## 创建工程distribute-transaction ##

![1f480466e1d14a0ab7ddde00dae83913.png][]

## 字符编码 ##

![0e5da10bdb1a4d8a8f1530ec0164c1b8.png][]

## 注解生效激活 ##

![81148fd0b24441af8eb849a501e161f2.png][]

## Java编译版本选择 ##

<build>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compilerplugin</artifactId>
                    <configuration>
                        <source>1.8</source>
                        <target>1.8</target>
                        <encoding>UTF-8</encoding>
                    </configuration>
                </plugin>
            </plugins>
        </build>

## File Type过滤 ##

![e5b1f0e254f346139a6a8dc856e75ab2.png][]

## pom配置版本 ##

<properties>
            <spring-boot.version>2.6.3</spring-boot.version>
            <spring.cloud.version>2021.0.1</spring.cloud.version>
            <spring.cloud.alibaba.version>2021.0.1.0</spring.cloud.alibaba.version>
          <lombok.version>1.18.22</lombok.version>
    </properties>
        <dependencyManagement>
            <dependencies>  
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-bootstarter-parent</artifactId>
                    <version>${spring-boot.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-clouddependencies</artifactId>
                    <version>${spring.cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloudalibaba-dependencies</artifactId>
                    <version>${spring.cloud.alibaba.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>${lombok.version}</version>
                </dependency>
            </dependencies>
        </dependencyManagement>

## IDEA开启Dashboard ##

**普通的Run面板**

![7af31299e145409aaf1080d6cca4d1ea.png][]

**Run Dashboard面板**

![b2df0eaa99ef40fbbf38a4415972ec69.png][]

**修改配置文件**

> 在.idea/workspace.xml 文件中找到

**添加配置**

## Seata提供XA模式实现分布式事务\_转账功能实现上 ##

**实现如下功能**

> 李四账户增加金额。

## 创建bank2 ##

![24a9e0460dfa4959a2598de87f7b2946.png][]

**pom引入依赖**

<dependency>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starterweb</artifactId>
            </dependency>
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus-bootstarter</artifactId>
                <version>3.5.1</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connectorjava</artifactId>
                <version>5.1.49</version>
            </dependency>
            <dependency>
               <groupId>org.projectlombok</groupId>
               <artifactId>lombok</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starteralibaba-nacos-discovery</artifactId>
            </dependency>

**编写主启动类**

//添加对mapper包扫描 Mybatis-plus
    @MapperScan("com.tong.mapper")
    @SpringBootApplication
    @Slf4j
    //开启发现注册
    @EnableDiscoveryClient
    public class SeataBank2Main6002 {
        public static void main(String[] args) {
           SpringApplication.run(SeataBank1Main6002.class,args);
            log.info("************** SeataBank1Main6002 *************");
       }
    }

**编写YML配置文件**

server:
     port: 6002
    spring:
     application:
       name: seata-bank2
    cloud:
       nacos:
         discovery:
            # Nacos server地址
           server-addr: 192.168.66.101:8848
     datasource:
       url: jdbc:mysql://localhost:3306/bank2?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
       username: root
       password01: 123456
       driver-class-name: com.mysql.jdbc.Driver

**代码生成**

引入Mybatis Plus代码生成依赖

<dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plusgenerator</artifactId>
                <version>3.5.2</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.velocity</groupId>
                <artifactId>velocity-enginecore</artifactId>
                <version>2.0</version>
            </dependency>

**生成代码**

package com.tong.utils;
    import com.baomidou.mybatisplus.generator.FastAutoGenerator;
    import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
    import java.util.Arrays;
    import java.util.List;
    public class CodeGenerator {
        public static void main(String[] args) {
          FastAutoGenerator.create("jdbc:mysql://192.168.66.100:3306/bank2", "root", "123456")
                   .globalConfig(builder -> {
                        builder.author("itxiaotong")// 设置作者
                               .commentDate("MM-dd") // 注释日期格式
                               .outputDir(System.getProperty("user.dir")+"/xa-seata/bank2"+ "/src/main/java/") // 指定输出目录
                               .fileOverride(); //覆盖文件
                   })
                    // 包配置
                   .packageConfig(builder -> { builder.parent("com.tong") // 包名前缀
                               .entity("entity")//实体类包名
                               .mapper("mapper")//mapper接口包名
                               .service("service"); //service包名
                   })
                   .strategyConfig(builder -> {
                        // 设置需要生成的表名
                        List<String> strings = Arrays.asList("account_info");
                        builder.addInclude(strings)
                                // 开始实体类配置
                               .entityBuilder()
                                // 开启lombok模型
                               .enableLombok()
                                //表名下划线转驼峰
                               .naming(NamingStrategy.underline_to_camel)
                                //列名下划线转驼峰
                               .columnNaming(NamingStrategy.underline_to_camel);
                   })
                   .execute();
       }
    }

**编写转账接口**

public interface IAccountInfoService {
        //李四增加金额
        void updateAccountBalance(String accountNo, Double amount);
    }

**编写转账接口实现类**

@Service
    @Slf4j
    public class AccountInfoServiceImpl implements IAccountInfoService {
        @Autowired
        AccountMapper accountMapper;
        @Override
        public void updateAccountBalance(String accountNo, Double amount) {
            // 1. 获取用户信息
            AccountInfo accountInfo = accountMapper.selectById(accountNo);
            accountInfo.setAccountBalance(accountInfo.getAccountBalance() + amount);
            accountMapper.updateById(accountInfo);
       }
    }

**编写控制层**

@RestController
    @RequestMapping("/bank2")
    public class Bank2Controller {
        @Autowired
        IAccountInfoService accountInfoService;
        //接收张三的转账
        @GetMapping("/transfer")
        public String transfer(Double amount){
            //李四增加金额
            accountInfoService.updateAccountBalance("3",amount);
            return "bank2"+amount;
       }
    }

#  #

[976e8e63178149ce89a54ff4a77609e1.gif]: https://img-blog.csdnimg.cn/976e8e63178149ce89a54ff4a77609e1.gif
[06562dff83ca4349a9d9c7558c14da03.png]: https://img-blog.csdnimg.cn/06562dff83ca4349a9d9c7558c14da03.png
[10b253eb9425449293a3f3287bb98530.png]: https://img-blog.csdnimg.cn/10b253eb9425449293a3f3287bb98530.png
[c4d79fe0e02c4ac5a80d04baf1e17515.png]: https://img-blog.csdnimg.cn/c4d79fe0e02c4ac5a80d04baf1e17515.png
[8dcd23a79a444a96a18dee5b6050776b.png]: https://img-blog.csdnimg.cn/8dcd23a79a444a96a18dee5b6050776b.png
[de8703744524409da88f6d38074c0ee4.png]: https://img-blog.csdnimg.cn/de8703744524409da88f6d38074c0ee4.png
[d9153a2beca04b33a1f4233d6646e506.png]: https://img-blog.csdnimg.cn/d9153a2beca04b33a1f4233d6646e506.png
[bc8fc5ad1a404ad39023c8eea04b2b1b.png]: https://img-blog.csdnimg.cn/bc8fc5ad1a404ad39023c8eea04b2b1b.png
[0a1b06938def46898ad6d4f58acd3ccd.png]: https://img-blog.csdnimg.cn/0a1b06938def46898ad6d4f58acd3ccd.png
[321c165f9faa445b97479f1a9aab7d1e.png]: https://img-blog.csdnimg.cn/321c165f9faa445b97479f1a9aab7d1e.png
[6d82cbd2f78a4b12b8aa97a1c79ecec8.png]: https://img-blog.csdnimg.cn/6d82cbd2f78a4b12b8aa97a1c79ecec8.png
[1b1a5be7dfcc4831931d2ace9e3de576.png]: https://img-blog.csdnimg.cn/1b1a5be7dfcc4831931d2ace9e3de576.png
[cb2c33b2891e4b1e980243a1cd14101a.png]: https://img-blog.csdnimg.cn/cb2c33b2891e4b1e980243a1cd14101a.png
[fb55fcaef0a0444680471fc6c0887fba.png]: https://img-blog.csdnimg.cn/fb55fcaef0a0444680471fc6c0887fba.png
[f21416e7608b42e89defa90bcde9f1e6.png]: https://img-blog.csdnimg.cn/f21416e7608b42e89defa90bcde9f1e6.png
[d14dc0b9edcf4751b11925914c525cfb.png]: https://img-blog.csdnimg.cn/d14dc0b9edcf4751b11925914c525cfb.png
[b60acc5254d04d7e81813103a9da57d8.png]: https://img-blog.csdnimg.cn/b60acc5254d04d7e81813103a9da57d8.png
[575f296cd3a042b6b39a63e1cda611b0.png]: https://img-blog.csdnimg.cn/575f296cd3a042b6b39a63e1cda611b0.png
[423f30a086e845b69464fee67f94c440.png]: https://img-blog.csdnimg.cn/423f30a086e845b69464fee67f94c440.png
[1f480466e1d14a0ab7ddde00dae83913.png]: https://img-blog.csdnimg.cn/1f480466e1d14a0ab7ddde00dae83913.png
[0e5da10bdb1a4d8a8f1530ec0164c1b8.png]: https://img-blog.csdnimg.cn/0e5da10bdb1a4d8a8f1530ec0164c1b8.png
[81148fd0b24441af8eb849a501e161f2.png]: https://img-blog.csdnimg.cn/81148fd0b24441af8eb849a501e161f2.png
[e5b1f0e254f346139a6a8dc856e75ab2.png]: https://img-blog.csdnimg.cn/e5b1f0e254f346139a6a8dc856e75ab2.png
[7af31299e145409aaf1080d6cca4d1ea.png]: https://img-blog.csdnimg.cn/7af31299e145409aaf1080d6cca4d1ea.png
[b2df0eaa99ef40fbbf38a4415972ec69.png]: https://img-blog.csdnimg.cn/b2df0eaa99ef40fbbf38a4415972ec69.png
[24a9e0460dfa4959a2598de87f7b2946.png]: https://img-blog.csdnimg.cn/24a9e0460dfa4959a2598de87f7b2946.png