VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > 编程开发 > Java教程 >
  • SpringCloudAlibaba项目之Seata分布式事务

SpringCloudAlibaba项目之Seata分布式事务

1、分布式事务

   事务是数据库的概念,数据库事务(ACID:原子性、一致性、隔离性和持久性);

  分布式事务的产生,是由于数据库的拆分和分布式架构(微服务)带来的,在常规情况下,我们在一个进程中操作一个数据库,这属于本地事务,如果在一个进程中操作多个数据库,或者在多个进程中操作一个或多个数据库,就产生了分布式事务;

(1)数据库分库分表就产生了分布式事务;

 (2)项目拆分服务化也产生了分布式事务;

2、Seata简介

  Seata 是一款开源的分布式事务解决方案,致力于在微服务架构下提供高性能和简单易用的分布式事务服务。

  Seata为用户提供了AT、TCC、SAGA和XA事务模式,为用户打造一站式的分布式解决方案;

四种事务模式中,XA模式正在开发中...,其他事务模式已经实现;

目前使用的流行度情况是:AT > TCC > Saga;

我们可以参看seata各公司使用列表:

https://github.com/seata/seata/issues/1246 大部分公司都采用的AT事务模式;

Seata已经在国内很多团队开始落地,其中不乏有大公司;

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

官网文档:https://seata.io/zh-cn/docs/overview/what-is-seata.html

在Seata的架构中,一共有三个角色:

TC (Transaction Coordinator) - 事务协调者

维护全局和分支事务的状态,驱动全局事务提交或回滚;

TM (Transaction Manager) - 事务管理器

定义全局事务的范围:开始全局事务、提交或回滚全局事务;

RM (Resource Manager) - 资源管理器

管理分支事务处理的资源,与TC交互以注册分支事务和报告分支事务的状态,并驱动分支事务提交或回滚;

其中TC为单独部署的 Server 服务端,TM和RM为嵌入到应用中的 Client 客户端;

在Seata中,一个分布式事务的生命周期如下:

TM请求TC开启一个全局事务,TC会生成一个XID作为该全局事务的编号,XID会在微服务的调用链路中传播,保证将多个微服务的子事务关联在一起;

RM请求TC将本地事务注册为全局事务的分支事务,通过全局事务的XID进行关联;

TM请求TC告诉XID对应的全局事务是进行提交还是回滚;

TC驱动RM将XID对应的自己的本地事务进行提交还是回滚;

3、Seata服务端部署(TC事务协调者)

  因为TC需要进行全局事务和分支事务的记录,所以需要对应的存储,目前,TC有三种存储模式( store.mode ):

file模式:适合单机模式,全局事务会话信息在内存中读写,并持久化本地文件 root.data,性能较高;

db模式:(mysql 5.7+)适合集群模式,全局事务会话信息通过 db 共享,相对性能差点;

redis模式:解决db存储的性能问题;

 这里使用windows系统演示db模式;

(1)下载安装包

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

(2)修改配置文件

 

 (3)创建数据库表

 官网已经为我们创建好了脚本,只需要引入使用即可:https://github.com/seata/seata/tree/1.4.0/script/server/db

 运行mysql.sql文

复制代码
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
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;
复制代码

总共三张表,global_table(存储全局会话数据)、branch_table(存储分支会话数据)、lock_table(存储锁数据)

4、Seata服务端搭建-nacos

 (1)修改注册中心

 (2)修改配置中心

 (3)启动seata

 5、Seata客户端搭建

  (1)pom.xml文件引入依赖

复制代码
<!-- nacos 服务注册发现(客户端)依赖 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- nacos-config 配置中心依赖 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- seata 分布式事务依赖 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
复制代码

接口调用需要openfeign依赖

<!-- openfeign 远程调用依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

  (2)各微服务对应的数据库中添加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,
    PRIMARY KEY(`id`),
    UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8
复制代码

  (3)将配置注册到nacos注册中心

  到https://github.com/seata/seata  下,先将整个文件下载下来,将内部的script脚本文件复制一份到seata的根目录下

 修改内部script\config\config.txt文件内容

关于config.txt文件中vgroupMapping.default_tx_group和在项目里配置的要一致

 执行script\config-center\nacos\nacos-config.sh把config.txt文件导入到nacos配置中心

注意:执行出现找不到config.txt的话修改一下nacos-config.sh里面关于config.txt的路径指向你本地的即可。如果电脑无法运行.sh文件,安装git即可。

 注册成功

(3)各微服务添加配置

application.properties

复制代码
#配置seata的注册中心
seata.enabled=true
seata.application-id=${spring.application.name}
#配置事务分组
seata.tx-service-group=default_tx_group
seata.registry.type=nacos
seata.registry.nacos.server-addr=127.0.0.1:8848
seata.registry.nacos.application=seata-server
seata.registry.nacos.namespace=
seata.registry.nacos.username=nacos
seata.registry.nacos.password=nacos
seata.registry.nacos.group=SEATA_GROUP
#配置seata的配置中心
seata.config.type=nacos
seata.config.nacos.server-addr=127.0.0.1:8848
seata.config.nacos.namespace=
seata.config.nacos.username=nacos
seata.config.nacos.password=nacos
seata.config.nacos.group=SEATA_GROUP
复制代码

 消费者

 OrderController

复制代码
/**
 * 订单服务
 */
@RestController
@RequestMapping("/order")
public class OrderController {

    @Resource
    private StockOpenFeignService stockOpenFeignService;

    @Resource
    private OrderService orderService;

    /**
     * 新增订单
     * @return
     */
    @RequestMapping("/addOrder")
    @GlobalTransactional //分布式事务注解,这个一般放在业务层,这里图方便
    public String addOrder(){
        Order order = new Order("袜子");
        int id = orderService.addOrder(order);
        System.out.println("订单新增成功-id:" + id);
        //调用库存扣减
        String result = stockOpenFeignService.subStock(id);
        return new Result(200,"订单服务-订单新增成功",result).toString();
    }
}
复制代码
StockOpenFeignService
复制代码
/**
 * 库存服务接口
 * name:指定调用rest接口所对应的服务名
 * path:指定调用rest接口所在的StockController指定的@RequestMapping
 */
@FeignClient(name = "service-seata-stock",path = "stock")
public interface StockOpenFeignService {

    //声明需要调用的rest接口对应的方法
    /**
     * 库存扣减
     * @return
     */
    @PostMapping("/subStock")
    String subStock(int id);
}
复制代码

生产者

 StockController

复制代码
/**
 * 库存服务
 */
@RestController
@RequestMapping("/stock")
public class StockController {

    @Value("${server.port}")
    private String port;

    @Resource
    private StockService stockService;/**
     * 库存扣减
     * @return
     */
    @PostMapping("/subStock")
    public String subStock(@RequestBody int id) {
        System.out.println("进入库存扣减接口");int num = stockService.subStock(id);
        Result result = null;
        if(num > 0){
            System.out.println("库存扣减成功-id:" + id);
            result = new Result(200,"扣减库存服务-库存成功");
        }else {
            result = new Result(201,"扣减库存服务-库存失败");
        }
        return result.toString();
    }
}
复制代码

总结: 实践是检验真理的唯一标准。

参考链接:https://blog.csdn.net/calonmo/article/details/106630754

 

原文:https://www.cnblogs.com/qiantao/p/15741320.html


相关教程