SpringCloudAlibaba 之初识 Seata(客户端使用)

- 日理万妓 2023-09-27 12:52 104阅读 0赞

前言

本篇来使用一下Seata处理微服务下的分布式事务。我们准备先准备两个工程一个 seata\_order 和seata\_storage 下面我就贴一下引用的maven注意所有的Alibaba的maven 版本是 `2.2.3.RELEASE`

开始整合

先给两个库中添加表结构

##这是库存服务的表
    DROP TABLE IF EXISTS `storage_tbl`; 
    CREATE TABLE `storage_tbl` ( 
    `id` int(11) NOT NULL AUTO_INCREMENT, 
    `commodity_code` varchar(255) DEFAULT NULL, 
    `count` int(11) DEFAULT 0, PRIMARY KEY (`id`),
    UNIQUE KEY (`commodity_code`) ) 
    ENGINE=InnoDB DEFAULT CHARSET=utf8; 
    
    ## 这是订单服务表
    DROP TABLE IF EXISTS `order_tbl`;
    CREATE TABLE `order_tbl` ( 
    `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) DEFAULT NULL, 
    `commodity_code` varchar(255) DEFAULT NULL,
    `count` int(11) DEFAULT 0, 
    `money` int(11) DEFAULT 0, PRIMARY KEY (`id`) )
    ENGINE=InnoDB DEFAULT CHARSET=utf8;
    ## seata用来做回滚用的 （如果是分库的话每个库都要创建这张表）
    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;

下面我贴一下maven的依赖

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.3.2.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
    <dependency> 
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
    </dependency>
    <dependency> 
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.17</version>
    </dependency>
    <dependency> 
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency> 
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    </dependency>
    <dependency> 
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    </dependency>

下面我们来看看yml 文件中的配置，主要是配置一个seata 的通信地址和seata的事务分组，因为我们的seata-serve已经注册到了nacos中

![6a44a2c20991208dfdb6dca64c5f7e79.png][]

maven 依赖

spring:
      datasource:
        username: root
        password: root
        url: jdbc:mysql://192.168.1.7:3306/seata_order?autoReconnect=true&useUnicode=true&nullCatalogMeansCurrent=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
        driver-class-name: com.mysql.cj.jdbc.Driver
        type: com.alibaba.druid.pool.DruidDataSource
        initialSize: 5
        minIdle: 5
        maxActive: 20
        # 配置获取连接等待超时的时间
        maxWait: 60000
        #上面都是数据库的链接信息没什么好说的
      cloud:
        nacos:
          discovery: #注册服务到nacos中去
            server-addr: 192.168.1.7:8848
        alibaba:
          seata:#设置事务分支 默认就是 my_test_tx_group
            tx-service-group: my_test_tx_group
      application:
        name: bugvip-order 
    #mybatis
    mybatis-plus:
      mapper-locations: classpath*:/mapper/***Mapper.xml
      map-underscore-to-camel-case: true
      global-config:
        #数据库相关配置
        db-config:
          #主键类型  AUTO:"数据库ID自增", INPUT:"用户输入ID", ID_WORKER:"全局唯一ID (数字类型唯一ID)", UUID:"全局唯一ID UUID";
          id-type: AUTO
      configuration:
        log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    seata: #设置seata的通讯地址 去nacos 找 seata服务端 TC的地址
      registry:
        type: nacos
        nacos:
          server-addr: 192.168.1.7:8848
          username: nacos
          password: nacos
          application:  seata-server #服务name要和nacos中保持一致 默认就是seata-server

下面我们看看业务中是怎么使用seata（没错很简单就是一个注解 @GlobalTransactional）远程调用那些我们这里就不多说了

@GlobalTransactional
    @Override
    public void insert(Order order) {
     //在order服务中添加订单信息
        orderMapper.insert(order);
        //远程待用库存服务进行库存扣减
        stockService.reduct(1);
        //我们手动抛出一个异常看看能不能将order中的订单信息回滚
        int i =10/0;
    }

![5e58f118946dfb3dce72bd685cbe034c.png][]

可以在order表中查看数据发现并没有插入（实现了回滚）

![3744eb3e4fbb433fd6af641b1ae31183.png][]

当然库存服务中可以看到先修改后面回滚了

![600c07e5ef522c1d444b8117a7be0579.png][]

数据表中的数据并没有变动,说明我们的seata的事务生效且成功保证了事务的一致性

![099a26b482d077a0dbcbeb4b97cf36f8.png][]

服务端搭建成功之后客户端使用的时候还是很简单的。一个注解搞定 我们在异常之前打个断点就可以在 undo\_log表中的数据就是用来回滚的数据（可以理解为反向解析我们执行的sql 后面一旦回滚就以他为准）

![219a9d7029d703322a0d5cf8621b1cf0.png][]

[6a44a2c20991208dfdb6dca64c5f7e79.png]: https://img-blog.csdnimg.cn/img_convert/6a44a2c20991208dfdb6dca64c5f7e79.png
[5e58f118946dfb3dce72bd685cbe034c.png]: https://img-blog.csdnimg.cn/img_convert/5e58f118946dfb3dce72bd685cbe034c.png
[3744eb3e4fbb433fd6af641b1ae31183.png]: https://img-blog.csdnimg.cn/img_convert/3744eb3e4fbb433fd6af641b1ae31183.png
[600c07e5ef522c1d444b8117a7be0579.png]: https://img-blog.csdnimg.cn/img_convert/600c07e5ef522c1d444b8117a7be0579.png
[099a26b482d077a0dbcbeb4b97cf36f8.png]: https://img-blog.csdnimg.cn/img_convert/099a26b482d077a0dbcbeb4b97cf36f8.png
[219a9d7029d703322a0d5cf8621b1cf0.png]: https://img-blog.csdnimg.cn/img_convert/219a9d7029d703322a0d5cf8621b1cf0.png