编程语言
首页 > 编程语言> > 宇智波程序笔记3-Spring Cloud同步场景分布式事务怎样做?试试Seata

宇智波程序笔记3-Spring Cloud同步场景分布式事务怎样做?试试Seata

作者:互联网

一、概述

在微服务架构下,虽然我们会尽量避免分布式事务,但是只要业务复杂的情况下这是一个绕不开的问题,如何保证业务数据一致性呢?本文主要介绍同步场景下使用SeataAT模式来解决一致性问题。

Seata是 阿里巴巴 开源的 一站式分布式事务解决方案 中间件,以 高效 并且对业务 0 侵入 的方式,解决 微服务 场景下面临的分布式事务问题

 

二、Seata介绍

整体事务逻辑是基于 两阶段提交 的模型,核心概念包括以下3个角色:

目前的Seata有两种模式可使用分别对应不同业务场景

2.1. AT模式

该模式适合的场景:

 
一个典型的分布式事务过程:

  1. TM 向 TC 申请开启一个全局事务,全局事务创建成功并生成一个全局唯一的 XID

  2. XID 在微服务调用链路的上下文中传播。

  3. RM 向 TC 注册分支事务,将其纳入 XID 对应全局事务的管辖。

  4. TM 向 TC 发起针对 XID 的全局提交或回滚决议。

  5. TC 调度 XID 下管辖的全部分支事务完成提交或回滚请求。

 

2.2. MT模式

该模式逻辑类似TCC,需要 自定义实现 preparecommitrollback的逻辑,适合 非关系型数据库 的场景

 

三、Seata场景样例

模拟一个简单的用户下单场景,4个子工程分别是 Bussiness(事务发起者)、Order(创建订单)、Storage(扣减库存) 和 Account(扣减账户余额)

3.1. 部署Seata的Server端

Discover注册、Config配置和Store存储模块默认都是使用file只能适用于单机,我们安装的时候分别改成使用nacosMysql以支持server端集群

3.1.1. 下载最新版本并解压

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

 

3.1.2. 修改 conf/registry.conf 配置

注册中心和配置中心默认是file这里改为nacos;设置 registry 和 config 节点中的typenacos,修改serverAddr为你的nacos节点地址。

registry {
  type = "nacos"

  nacos {
    serverAddr = "192.168.28.130"
    namespace = "public"
    cluster = "default"
  }
}

config {
  type = "nacos"

  nacos {
    serverAddr = "192.168.28.130"
    namespace = "public"
    cluster = "default"
  }
}

 

3.1.3. 修改 conf/nacos-config.txt配置

 

3.1.4. 初始化seata的nacos配置

cd conf
sh nacos-config.sh 192.168.28.130

成功后在nacos的配置列表中能看到seata的相关配置

 

3.1.5. 初始化数据库

执行conf/db_store.sql中的脚本

 

3.1.6. 启动seata-server

sh bin/seata-server.sh -p 8091 -h 192.168.28.130

 

3.2. 应用配置

3.2.1. 初始化数据库

执行脚本 seata-demo.sql

CREATE DATABASE `seata-demo` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
USE `seata-demo`;

--==========================回滚日志表==========================
-- 此脚本必须初始化在你当前的业务数据库中,用于AT 模式XID记录。与server端无关(注:业务数据库)
drop table `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,
  `ext` varchar(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;


--==========================业务模拟表==========================
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;


DROP TABLE IF EXISTS `account_tbl`;
CREATE TABLE `account_tbl` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` varchar(255) DEFAULT NULL,
  `money` int(11) DEFAULT 0,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;


-- 初始化库存模拟数据
INSERT INTO storage_tbl (www.jintianxuesha.com  www.yuntianyul.com www.baihuayl7.cn id, commodity_code, count) VALUES (1, 'P001', 9999999);
INSERT INTO account_tbl (id, user_id, money) VALUES ('1', 'U001', 10000);

需在业务相关的数据库中添加 undo_log 表,用于保存需要回滚的数据

 

3.2.2. 添加registry.conf配置

直接把 seata-server 中的registry.conf复制到每个服务中去即可,不需要修改

 

3.2.3. 修改配置

demo中的每个服务各自修改配置文件

 

3.2.4. 配置数据源代理

Seata是通过代理数据源实现分布式事务,所以需要配置io.seata.rm.datasource.DataSourceProxyBean,且是@Primary默认的数据源,否则事务不会回滚,无法实现分布式事务

public class DataSourceProxyConfig www.yifayuled.cn{
    www.yachengyl.cn   www.yixingylzc.cn  www.qiaoheibpt.com www.baishenjzc.cn
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource(www.lafei6d.cn) {
        return new DruidDataSource();
    }

    @Primary
    @Bean
    public DataSourceProxy dataSourceProxy(www.yixinpt2.cn DruidDataSource druidDataSource) {
        return new DataSourceProxy(druidDataSource);
    }
}

因为使用了mybatis的starter所以需要排除DataSourceAutoConfiguration,不然会产生循环依赖

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})

 

3.2.5. 事务发起者添加全局事务注解

事务发起者 business-service 添加 @GlobalTransactional 注解

@GlobalTransactional
public void placeOrder(String userId) www.javachenglei.com{
    ......
}

 

3.3. 测试

提供两个接口测试

  1. 事务成功:扣除库存成功 > 创建订单成功 > 扣减账户余额成功
    http://localhost:9090/placeOrder

  2. 事务失败:扣除库存成功 > 创建订单成功 > 扣减账户余额失败,事务回滚
    http://www.lecaixuangj.cn localhost:9090/placeOrderFallBack

 

3.4. demo地址

https://www.hongtuuzhuc.cn gitee.com/zlt2000/microservices-platform/tree/master/zlt-demo/seata-demo

 

往期精彩回顾

 

标签:事务,Seata,DEFAULT,Spring,宇智波,nacos,NULL,id,seata
来源: https://www.cnblogs.com/woshixiaowang/p/13549915.html