专栏名称: 码不动
感谢大家的喜欢与关注
目录
相关文章推荐
51好读  ›  专栏  ›  码不动

SpringBoot基于Dubbo和Seata的分布式事务解决方案

码不动  · 简书  ·  · 2020-10-09 14:28

正文

1. 分布式事务初探

一般来说,目前市面上的数据库都支持 本地事务 ,也就是在你的应用程序中,在一个数据库连接下的操作,可以很容易的实现事务的操作。

但是目前,基于SOA的思想,大部分项目都采用微服务架构后,就会出现了跨服务间的事务需求,这就称为 分布式事务

本文假设你已经了解了事务的运行机制,如果你不了解事务,那么我建议先去看下事务相关的文章,再来阅读本文。

1.1 什么是分布式事务

对于传统的单体应用而言,实现 本地事务 可以依赖Spring的@Transactional注解标识方法,实现事务非常简单。

我们以最常见的电商系统为例,简单拆分为用户客户端、订单服务、库存服务、商品服务等等,在用户下单过程中,需要同时调用各个服务,但是,每个服务都是独立部署的,数据库连接是不共享的,因此要保证这些操作全部执行,或者全部不执行,就需要 分布式事务 的支持。

1.2 分布式事务解决方案

  • 全局事务,基于DTP模型实现,需要三种角色即Application 应用系统,Transaction Manager 事务管理器,Resource Manager资源管理器;
  • 基于可靠消息服务的分布式事务,通过消息队列实现事务的一致性;
  • TCC,即Try、Confirm、Cancel,属于补偿型分布式事务,Try:尝试待执行的事务,Confirm:执行事务,Cancel:取消执行的事务;

1.3 Seata介绍

Seata 是一款开源的分布式事务解决方案,致力于在微服务架构下提供高性能和简单易用的分布式事务服务。Seata 于2019.1正式对外开源,前身是阿里巴巴2014年诞生的 TXC(Taobao Transaction Constructor)。以下是Seata官网介绍的特色服务:

image

Seata 将为用户提供了 AT、TCC 和 XA 事务模式,为用户打造一站式的分布式解决方案。更多关于Seata的介绍,可参考其官网。

2. Spring Boot,Dubbo和Seata实现分布式事务案例

2.1 环境准备

运行本测试,需要你提前准备如下的软件运行环境:
image.png

本案例,主要模仿简单的下单扣减库存的过程,架构图如下:

image

2.2 Seata管理端

下载Seata的最新版本,并解压后,进入seata/bin目录,启动:

sh seata-server.sh 8091 file

观察8091端口是否启动。

2.3 数据存储
本测试服务,需要创建两张表,分别是订单表和库存表:

CREATE TABLE `t_order` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `order_no` varchar(255) DEFAULT NULL,
  `user_id` varchar(255) DEFAULT NULL,
  `commodity_code` varchar(255) DEFAULT NULL,
  `count` int(11) DEFAULT '0',
  `amount` double(14,2) DEFAULT '0.00',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

CREATE TABLE `t_storage` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `commodity_code` varchar(255) DEFAULT NULL,
  `name` varchar(255) DEFAULT NULL,
  `count` int(11) DEFAULT '0',
  PRIMARY KEY (`id`),
  UNIQUE KEY `commodity_code` (`commodity_code`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

2.4 构建Spring Boot服务

示例代码可参考Github仓库,仓库的目录结构如下:

image
  • springboot-base:存储公共调用的基类接口,mapper接口,Model层的类等,可mvn install后,供另外三个module调用。
  • springboot-dubbo-storage:库存服务;
  • springboot-dubbo-order:订单服务;
  • springboot-dubbo-client:RPC消费者,提供对外接口;

基于Spring Boot构建Dubbo服务可参考之前的博文《Spring Boot(五)之集成Dubbo部署RPC服务》,构建本项目的过程就不再赘述了。

加入Seata组件后,与普通Dubbo项目的不同之处在于

1,配置Seata数据源

/**
 * seata数据源
 *
 * init datasource proxy
 * @Param: druidDataSource  datasource bean instance
 * @Return: DataSourceProxy  datasource proxy
 */
@Bean
public DataSourceProxy dataSourceProxy(DruidDataSource druidDataSource){
    return new DataSourceProxy(druidDataSource);
}

2,Seata初始化







请到「今天看啥」查看全文