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

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官网介绍的特色服务：

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

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

2.1 环境准备

运行本测试，需要你提前准备如下的软件运行环境：

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

2.2 Seata管理端

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

sh seata-server.sh 8091 file

观察8091端口是否启动。

2.3 数据存储

本测试服务，需要创建两张表，分别是订单表和库存表：

2.4 构建Spring Boot服务

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

  • 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数据源

2，Seata初始化

/**
 * 配置全局事务扫描器。有两个参数，一个是应用名称，一个是事务分组
 *
 * @return
 */
@Bean
public GlobalTransactionScanner globalTransactionScanner() {
  return new GlobalTransactionScanner("springboot-dubbo-storage", "my_test_tx_group");
}

3，配置注册中心，目前可用的配置中心有file、nacos 、apollo、zk、consul，file类型本身不具备注册中心的动态发现和动态配置功能，官方的初衷是在不依赖第三方配置注册中心的基础上快速集成测试seata功能。配置内容在file.conf和registry.conf。

4，注解标记事务方法，在需要分布式事务的方法上，加上@GlobalTransactional注解即可。

2.5 测试

依次启动Seata、springboot-dubbo-storage、springboot-dubbo-order、springboot-dubbo-client后，打开postman测试，配置测试参数为：

可以看到，在addOrder报错后，会有全局事务的rollback过程。

3. 参考资料

  • Seata
  • 如何使用Seata保证Dubbo微服务间的一致性
  • SpringBoot+Dubbo+Seata分布式事务实战
  • 分布式事务选型的取舍
  • 常用的分布式事务解决方案

到此这篇关于详解SpringBoot基于Dubbo和Seata的分布式事务解决方案的文章就介绍到这了,更多相关SpringBoot 分布式事务内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Springboot-dubbo-fescar 阿里分布式事务的实现方法

    大家可以自行百度下阿里分布式事务,在这里我就不啰嗦了.下面是阿里分布式事务开源框架的一些资料,本文是springboot+dubbo+fescar的集成. 快速开始 https://github.com/alibaba/fescar/wiki/Quick-Start GIT地址 https://github.com/alibaba/fescar 1.sql CREATE TABLE `undo_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `br

  • SpringBoot+Dubbo+Seata分布式事务实战详解

    前言 Seata 是 阿里巴巴开源的分布式事务中间件,以高效并且对业务0侵入的方式,解决微服务场景下面临的分布式事务问题. 事实上,官方在GitHub已经给出了多种环境下的Seata应用示例项目,地址:https://github.com/seata/seata-samples. 为什么笔者要重新写一遍呢,主要原因有两点: 官网代码示例中,依赖太多,分不清哪些有什么作用 Seata相关资料较少,笔者在搭建的过程中,遇到了一些坑,记录一下 一.环境准备 本文涉及软件环境如下: SpringBoot

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

    1. 分布式事务初探 一般来说,目前市面上的数据库都支持本地事务,也就是在你的应用程序中,在一个数据库连接下的操作,可以很容易的实现事务的操作. 但是目前,基于SOA的思想,大部分项目都采用微服务架构后,就会出现了跨服务间的事务需求,这就称为分布式事务. 本文假设你已经了解了事务的运行机制,如果你不了解事务,那么我建议先去看下事务相关的文章,再来阅读本文. 1.1 什么是分布式事务 对于传统的单体应用而言,实现本地事务可以依赖Spring的@Transactional注解标识方法,实现事务非常简

  • springboot整合shardingsphere和seata实现分布式事务的实践

    各个框架版本信息 springboot: 2.1.3 springcloud: Greenwich.RELEASE seata: 1.0.0 shardingsphere:4.0.1 maven 依赖        <dependency>         <!--<groupId>io.shardingsphere</groupId>-->         <groupId>org.apache.shardingsphere</group

  • 详解Springboot整合Dubbo之代码集成和发布

    详解Springboot整合Dubbo之代码集成和发布

    本文介绍了Springboot整合Dubbo之代码集成和发布,分享给大家,具体如下: 1. boot-dubbo-api相关 打开boot-dubbo-api项目,正在src/main/java下创建一个包,并创建你需要dubbo暴露的接口TestService.java,并创建一个实体类用于测试User.java.如下图所示: 创建文件和包结构 User.java package com.boot.domain; import lombok.Data; import java.io.Seria

  • 详解springboot中redis的使用和分布式session共享问题

    详解springboot中redis的使用和分布式session共享问题

    对于分布式使用Nginx+Tomcat实现负载均衡,最常用的均衡算法有IP_Hash.轮训.根据权重.随机等.不管对于哪一种负载均衡算法,由于Nginx对不同的请求分发到某一个Tomcat,Tomcat在运行的时候分别是不同的容器里,因此会出现session不同步或者丢失的问题. 实际上实现Session共享的方案很多,其中一种常用的就是使用Tomcat.Jetty等服务器提供的Session共享功能,将Session的内容统一存储在一个数据库(如MySQL)或缓存(如Redis)中. 本文旨在

  • 详解Springboot整合ActiveMQ（Queue和Topic两种模式）

    写在前面: 从2018年底开始学习SpringBoot,也用SpringBoot写过一些项目.这里对学习Springboot的一些知识总结记录一下.如果你也在学习SpringBoot,可以关注我,一起学习,一起进步. ActiveMQ简介 1.ActiveMQ简介 Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件:由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行. 2.ActiveMQ下载 下载地址:htt

  • 详解springboot+aop+Lua分布式限流的最佳实践

    一.什么是限流?为什么要限流? 不知道大家有没有做过帝都的地铁,就是进地铁站都要排队的那种,为什么要这样摆长龙转圈圈?答案就是为了限流!因为一趟地铁的运力是有限的,一下挤进去太多人会造成站台的拥挤.列车的超载,存在一定的安全隐患.同理,我们的程序也是一样,它处理请求的能力也是有限的,一旦请求多到超出它的处理极限就会崩溃.为了不出现最坏的崩溃情况,只能耽误一下大家进站的时间. 限流是保证系统高可用的重要手段!!! 由于互联网公司的流量巨大,系统上线会做一个流量峰值的评估,尤其是像各种秒杀促销活动,

  • 详解springboot+mybatis-plue实现内置的CRUD使用详情

    mybatis-plus的特性 无侵入:只做增强不做改变,引入它不会对现有工程产生影响,如丝般顺滑 损耗小:启动即会自动注入基本CURD,性能基本无损耗,直接面向对象操作 强大的 CRUD操作:内置通用 Mapper.通用Service,仅仅通过少量配置即可实现单表大部分 CRUD 操作,更有强大的条件构造器,满足各类使用需求 支持 Lambda形式调用:通过 Lambda 表达式,方便的编写各类查询条件,无需再担心字段写错 支持主键自动生成:支持多达 4种主键策略(内含分布式唯一 ID 生成器

  • 详解SpringBoot中的参数校验(项目实战)

    Java后端发工作中经常会对前端传递过来的参数做一些校验,在业务中还要抛出异常或者不断的返回异常时的校验信息,充满了if-else这种校验代码,在代码中相当冗长.例如说,用户注册时,会校验手机格式的正确性,用户名的长度等等.虽说前端也可以做参数校验,但是为了保证我们API接口的可靠性,以保证最终数据入库的正确性,后端进行参数校验不可忽视. Hibernate Validator 提供了一种统一方便的方式,让我们快速的实现参数校验. Hibernate Validator 使用注解,实现声明式校验

  • 详解SpringBoot的三种缓存技术(Spring Cache、Layering Cache 框架、Alibaba JetCache 框架)

    引言 ​前两天在写一个实时数据处理的项目,项目要求是 1s 要处理掉 1k 的数据,这时候显然光靠查数据库是不行的,技术选型的时候老大跟我提了一下使用 Layering-Cache 这个开源项目来做缓存框架. ​之间问了一下身边的小伙伴,似乎对这块了解不多.一般也就用用 Redis 来缓存,应该是很少用多级缓存框架来专门性的管理缓存吧. ​趁着这个机会,我多了解了一些关于 SpringBoot 中缓存的相关技术,于是有了这篇文章! 在项目性能需求比较高时,就不能单单依赖数据库访问来获取数据了,必

  • 详解Springboot集成sentinel实现接口限流入门

    详解Springboot集成sentinel实现接口限流入门

    Sentinel是阿里巴巴开源的限流器熔断器,并且带有可视化操作界面. 在日常开发中,限流功能时常被使用,用于对某些接口进行限流熔断,譬如限制单位时间内接口访问次数:或者按照某种规则进行限流,如限制ip的单位时间访问次数等. 之前我们已经讲过接口限流的工具类ratelimter可以实现令牌桶的限流,很明显sentinel的功能更为全面和完善.来看一下sentinel的简介: https://github.com/spring-cloud-incubator/spring-cloud-alibab

随机推荐