中间件之Seata

一、引言

在微服务架构日益盛行的今天，分布式事务成为了一个必须面对和解决的问题。传统的本地事务已经无法满足分布式环境下的数据一致性需求，因此分布式事务解决方案应运而生。Seata作为一款开源的分布式事务中间件，以其高性能、易用性和灵活性受到了广泛的关注和应用。本文将对Seata进行全面深入的解析，包括其基本概念、事务模式、工作原理、代码示例以及实际应用场景，旨在帮助开发者更好地理解和使用Seata。

二、Seata概述

2.1 基本概念

Seata（Simple Extensible Autonomous Transaction Architecture）是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。Seata通过提供全局事务管理和协调服务，支持多种主流的数据库和RPC框架，以及Spring Cloud和Dubbo等微服务框架。Seata的设计目标是解决分布式事务的一致性问题，实现高可用、高性能、易扩展的分布式事务管理。

2.2 角色与组件

Seata主要由三个核心角色组成：

TC (Transaction Coordinator)：

事务协调器，维护全局和分支事务的状态，驱动全局事务提交或回滚。TC是单独部署的Server服务端。

TM (Transaction Manager)：

事务管理器，控制全局事务的边界，负责开启一个全局事务，并最终发起全局提交或全局回滚的决议。TM和RM都是嵌入到应用中的Client客户端。

RM (Resource Manager)：

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

三、Seata的事务模式

Seata支持四种分布式事务模式：AT模式、TCC模式、Saga模式和XA模式，每种模式都有其独特的适用场景和优缺点。

3.1 AT模式

3.1.1 概念与原理

AT模式（Automatic Transaction）是Seata创新的一种非侵入式的分布式事务解决方案。在AT模式下，用户只需关心自己的“业务SQL”，Seata框架会自动生成事务的二阶段提交和回滚。

AT模式的工作原理如下：

一阶段：

Seata会拦截“业务SQL”，首先解析SQL语义，找到“业务SQL”要更新的业务数据，在业务数据被更新前，将其保存成“before image”，然后执行“业务SQL”更新业务数据，在业务数据更新之后，再将其保存成“after image”，最后生成行锁。以上操作全部在一个数据库事务内完成，这样保证了一阶段操作的原子性。

二阶段提交：

如果全局事务提交，Seata不会执行任何操作，因为一阶段已经完成数据的持久化。

二阶段回滚：

如果全局事务回滚，Seata会根据“before image”和“after image”生成反向的SQL语句，并执行这些反向SQL语句来撤销一阶段的业务数据变更。

3.1.2 优缺点

优点：
简化编程模型：

对业务代码无侵入性，可以在不修改业务逻辑的情况下实现分布式事务。

高性能：

通过异步通信和批量处理等手段，提高了分布式事务的性能。

缺点：
数据一致性风险：

在极端情况下（如数据库宕机），可能会出现数据一致性风险。

不支持跨数据库事务：

AT模式主要适用于单个数据库的事务管理，对于跨数据库的事务支持有限。

3.1.3 代码示例

以下是一个使用Seata AT模式实现分布式事务的简单示例，假设有两个微服务：订单服务和库存服务，订单服务负责创建订单，库存服务负责扣减库存。当用户下单时，需要同时调用两个服务，并保证数据一致性。

// 订单服务代码示例
@GlobalTransactional
public void createOrder(Order order) {
    // 调用库存服务扣减库存
    inventoryService.decreaseStock(order.getCommodityCode(), order.getCount());

    // 创建订单
    orderMapper.insert(order);
}

// 库存服务代码示例
@GlobalTransactional
public void decreaseStock(String commodityCode, int count) {
    // 扣减库存
    storageMapper.updateStock(commodityCode, count);
}

在上述代码中，通过在createOrder和decreaseStock方法上添加@GlobalTransactional注解，Seata会自动管理这两个方法之间的事务一致性。

3.2 TCC模式

3.2.1 概念与原理

TCC模式（Try-Confirm-Cancel）是Seata支持的一种由业务方细粒度控制的侵入式分布式事务解决方案。TCC模式将分布式事务拆分为Try、Confirm和Cancel三个阶段，每个阶段都需要业务方自行实现。

Try阶段：

执行业务的预备操作，完成资源的检查和预留。如果预备操作成功，则返回try成功状态；如果预备操作失败，则返回try失败状态。

Confirm阶段：

在Try阶段成功执行后，执行业务的确认操作，完成资源的最终提交。Confirm阶段必须保证幂等性，即无论执行多少次，结果都是一样的。

Cancel阶段：

在Try阶段成功执行后，如果全局事务需要回滚，则执行业务的取消操作，释放Try阶段预留的资源。Cancel阶段也必须保证幂等性。

3.2.2 优缺点

优点：
灵活性高：

TCC模式允许业务方细粒度地控制事务的每个阶段，可以适应复杂的业务场景。

性能优越：

TCC模式在第一阶段只锁定必要的资源，减少了资源锁持有时间，提高了并发性能。

缺点：
业务侵入性强：

TCC模式需要业务方实现Try、Confirm和Cancel三个阶段的操作，增加了业务代码的复杂度。

实现难度大：

需要保证Try、Confirm和Cancel三个阶段的幂等性，以及处理各种异常情况，实现难度较大。

3.2.3 代码示例

以下是一个使用Seata TCC模式实现分布式事务的示例：

// TCC接口定义
public interface TccActionOne {
    @TwoPhaseBusinessAction(name = "DubboTccActionOne", commitMethod = "commit", rollbackMethod = "rollback")
    public boolean prepare(BusinessActionContext actionContext, @BusinessActionContextParameter(paramName = "a") String a);

    public boolean commit(BusinessActionContext actionContext);

    public boolean rollback(BusinessActionContext actionContext);
}

// TCC接口实现
@Service
public class TccActionOneImpl implements TccActionOne {
    @Override
    public boolean prepare(BusinessActionContext actionContext, String a) {
        // 执行业务的预备操作
        // ...
        return true; // 返回try成功状态
    }

    @Override
    public boolean commit(BusinessActionContext actionContext) {
        // 执行业务的确认操作
        // ...
        return true; // 返回commit成功状态
    }

    @Override
    public boolean rollback(BusinessActionContext actionContext) {
        // 执行业务的取消操作
        // ...
        return true; // 返回rollback成功状态
    }
}

在上述代码中，TccActionOne接口定义了Try、Confirm和Cancel三个阶段的操作，TccActionOneImpl类实现了这些操作。业务方需要在每个阶段中编写相应的业务逻辑，并保证这些逻辑的幂等性。

3.3 Saga模式

3.3.1 概念与原理

Saga模式是一种长事务模式，它将一个长事务拆分成多个小事务，每个小事务都是一个短事务。Saga模式的核心思想是补偿，即如果某个小事务失败了，可以通过回滚之前的小事务来保证整个长事务的正确性。

Saga模式的工作原理如下：

  • 正向执行：依次执行每个小事务，如果所有小事务都执行成功，则长事务成功。
  • 逆向补偿：如果某个小事务执行失败，则依次执行之前所有成功小事务的补偿操作，直到所有小事务都回滚到初始状态。

3.3.2 优缺点

优点：
适用于长事务：

Saga模式特别适用于需要跨多个服务或数据库完成的长事务。

业务侵入性较低：

Saga模式只需要业务方实现正向和反向两个操作，相对于TCC模式来说侵入性较低。

缺点：
补偿操作的复杂性：

在复杂业务场景下，补偿操作可能很难实现，且容易出现补偿失败的情况。

数据一致性风险：

在极端情况下（如网络分区），可能会出现数据一致性风险。

3.3.3 代码示例

以下是一个使用Seata Saga模式实现分布式事务的示例：

// 伪代码示例  
  
// 定义一个服务接口，包含正向服务和补偿服务  
interface SagaService {  
    void execute(); // 正向服务  
    void compensate(); // 补偿服务  
}  
  
// 实现Saga服务  
class OrderService implements SagaService {  
    @Override  
    public void execute() {  
        // 执行订单创建的正向逻辑  
    }  
  
    @Override  
    public void compensate() {  
        // 执行订单创建的补偿逻辑  
    }  
}  
  
class PaymentService implements SagaService {  
    @Override  
    public void execute() {  
        // 执行支付的正向逻辑  
    }  
  
    @Override  
    public void compensate() {  
        // 执行支付的补偿逻辑  
    }  
}  
  
// Saga协调器  
class SagaCoordinator {  
    public void executeSaga(List<SagaService> services) {  
        for (SagaService service : services) {  
            try {  
                service.execute(); // 执行正向服务  
            } catch (Exception e) {  
                // 出现异常时，回滚已执行的服务  
                for (int i = services.indexOf(service) - 1; i >= 0; i--) {  
                    services.get(i).compensate();  
                }  
                throw e; // 抛出异常，中断流程  
            }  
        }  
        // 所有服务执行成功，提交事务  
    }  
}  
  
// 使用示例  
public class SagaExample {  
    public static void main(String[] args) {  
        List<SagaService> services = Arrays.asList(new OrderService(), new PaymentService());  
        SagaCoordinator coordinator = new SagaCoordinator();  
        try {  
            coordinator.executeSaga(services);  
        } catch (Exception e) {  
            System.err.println("Saga execution failed: " + e.getMessage());  
        }  
    }  
}

3.4 XA模式

3.4.1 概念与原理

执行阶段：

RM（资源管理器）将分支事务注册到全局事务协调器（TC）。
RM执行分支业务操作，但不提交。这确保了分支事务不会立即生效，等待全局协调后再决定是否提交。
RM报告分支事务执行状态给TC。

完成阶段：

TC检测各个分支事务的执行状态。
如果所有分支事务都成功，TC通知所有RM提交事务，即提交所有分支事务的更改。
如果有任何分支事务失败，TC通知所有RM回滚事务，即回滚所有分支事务的更改。
RM接收来自TC的指令，根据指令来提交或回滚分支事务。

3.4.2 优缺点

优点
  1. 保证了数据的强一致性，满足ACID原则。
  2. 几乎所有主流的数据库都支持XA协议，实现简单。
  3. 没有代码侵入，开发者无需修改业务代码。
缺点
  1. 性能较差，因为一阶段需要锁定数据库资源，等待二阶段结束才释放。
  2. 依赖关系型数据库实现事务，不适用于非关系型数据库。
  3. 存在单点问题，全局事务协调器可能成为系统瓶颈。

3.4.3 代码示例

XA模式的代码实现涉及Seata的配置和事务注解的使用。以下是一个简化的代码示例，展示了如何在Spring Boot项目中使用Seata的XA模式：

// 引入Seata依赖（在pom.xml中）  
<dependency>  
    <groupId>io.seata</groupId>  
    <artifactId>seata-spring-boot-starter</artifactId>  
    <version>你的Seata版本</version>  
</dependency>  
  
// 配置文件（application.yml）  
seata:  
  enabled: true  
  data-source-proxy-mode: XA  
  # 其他Seata配置...  
  
// 服务实现类  
@Service  
public class OrderService {  
  
    @Autowired  
    private OrderMapper orderMapper;  
  
    @GlobalTransactional  
    public void createOrder(Order order) {  
        // 执行订单创建逻辑  
        orderMapper.insert(order);  
        // 调用其他服务或执行其他业务逻辑...  
    }  
}  
  
// Mapper接口  
@Mapper  
public interface OrderMapper {  
    void insert(Order order);  
    // 其他数据库操作方法...  
}  
  
// 实体类  
public class Order {  
    private Long id;  
    private String userId;  
    private BigDecimal amount;  
    // 其他字段和getter/setter方法...  
}

在上面的代码中，@GlobalTransactional注解标记了全局事务的边界。当createOrder方法被调用时，Seata会启动一个全局事务，并协调所有参与的分支事务以保证数据的一致性。注意，这里假设数据库已经支持XA协议，并且已经正确配置了Seata Server和相关依赖。

四、总结

Seata作为开源的分布式事务中间件，在微服务架构下提供了高性能和简单易用的分布式事务服务。它支持AT、TCC、Saga和XA四种事务模式，每种模式各有优缺点和适用场景。AT模式通过自动生成事务的二阶段提交和回滚，简化了编程模型，但存在数据一致性风险和跨数据库事务支持有限的问题。TCC模式允许业务方细粒度控制事务的每个阶段，灵活性高且性能优越，但业务侵入性强且实现难度大。Saga模式适用于长事务，通过补偿操作保证事务正确性，但补偿操作复杂且存在数据一致性风险。XA模式则利用数据库对XA协议的支持，保证数据强一致性，但性能较差且存在单点问题。开发者在选择使用Seata时，应根据具体业务场景和需求，选择合适的事务模式，并合理配置和使用Seata以保证分布式事务的一致性和性能。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/898723.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

计算机系统的层次

计算机系统的层次

目录 计算机系统的层次ISA&#xff08;指令集体系结构&#xff09; 计算机系统的层次 计算机硬件是基础指令集体系结构&#xff1a;将硬件的功能封装从指令供软件使用操作系统&#xff1a;提供人机交互界面、提供服务功能的内核例程语言处理系统&#xff1a; 语言处理程序&…
阅读更多...
群晖通过 Docker 安装 GitLab

群晖通过 Docker 安装 GitLab

Docker 配置容器步骤都是大同小异的&#xff0c;可以参考&#xff1a; 群晖通过 Docker 安装 Gitea-CSDN博客 1. 在 Docker 文件夹中创建 GitLab&#xff0c;并创建子文件夹 2. 设置权限 3. 打开 Docker 应用&#xff0c;并在注册表搜索 gitlab-ce 4. 选择 gitlab-ce 映像运行…
阅读更多...
什么是不同类型的微服务测试？

什么是不同类型的微服务测试？

大家好&#xff0c;我是锋哥。今天分享关于【什么是不同类型的微服务测试&#xff1f;】面试题&#xff1f;希望对大家有帮助&#xff1b; 什么是不同类型的微服务测试&#xff1f; 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 微服务架构中的测试可以分为多种类…
阅读更多...
多尺度建模：从理论到实践的深入探讨

多尺度建模：从理论到实践的深入探讨

#1024程序员节 | 征文# 引言 在现代科学与工程中&#xff0c;很多现象和过程在不同的空间和时间尺度上展现出复杂性。因此&#xff0c;能够有效地进行多尺度建模&#xff0c;已经成为了许多领域&#xff08;如物理、生物、工程、环境科学等&#xff09;研究的一个重要方向。本…
阅读更多...
vue后台管理系统从0到1（5）

vue后台管理系统从0到1（5）

文章目录 vue后台管理系统从0到1&#xff08;5&#xff09;完善侧边栏修改bug渲染header导航栏 vue后台管理系统从0到1&#xff08;5&#xff09; 接上一期&#xff0c;我们需要完善我们的侧边狼 完善侧边栏 我们在 element 组件中可以看见&#xff0c;这一个侧边栏是符合我们…
阅读更多...
【操作系统】06.进程控制

【操作系统】06.进程控制

一、进程创建 1.1 认识fork函数 在linux中fork函数是非常重要的函数&#xff0c;它从已存在进程中创建一个新进程。新进程为子进程&#xff0c;而原进程为父进程。 进程调用fork&#xff0c;当控制转移到内核中的fork代码后&#xff0c;内核将 分配新的内存块和内核数据结构…
阅读更多...
Aspose.PDF功能演示：使用 JavaScript 从 PDF 中提取文本

Aspose.PDF功能演示：使用 JavaScript 从 PDF 中提取文本

在数据提取、业务文档自动化和文本挖掘方面&#xff0c;使用 JavaScript 从PDF中提取文本非常有用。它允许开发人员自动执行从 PDF 收集信息的过程&#xff0c;从而显著提高处理大量文档的生产力和效率。在这篇博文中&#xff0c;我们将学习如何使用 JavaScript 从 PDF 中提取文…
阅读更多...
人工智能的未来应用与发展前景

人工智能的未来应用与发展前景

随着人工智能&#xff08;AI&#xff09;技术的快速进步&#xff0c;我们正亲历着它在各行各业中带来的巨大变革。无论是医疗、企业管理&#xff0c;还是日常生活&#xff0c;AI 技术都在改变着我们的工作和生活方式。那么&#xff0c;人工智能的应用前景究竟如何&#xff1f;它…
阅读更多...
【消息队列】RabbitMQ实现消费者组机制

【消息队列】RabbitMQ实现消费者组机制

目录 1. RabbitMQ 的 发布订阅模式 2. GRPC 服务间的实体同步 2.1 生产者服务 2.2 消费者服务 3. 可靠性 3.1 生产者丢失消息 3.2 消费者丢失消息 3.3 RabbitMQ 中间件丢失消息 1. RabbitMQ 的 发布订阅模式 https://www.rabbitmq.com/tutorials/tutorial-three-go P 生…
阅读更多...
winUI3 c++ 入门 2、 样式

winUI3 c++ 入门 2、 样式

目录 一、winUI3 基本概念及样式 1、边距 2、如何使用样式 1）、布局控件内定义样式 2）、APP.xmal定义全局样式 3）、单独的样式文件 3.1)、新增字典资源 xmal 3.2）、在里面设置样式 3.3）、引用样式 3、更多样式修改 1）、修改默认属性 2）、修改所有的默认颜色…
阅读更多...
垃圾收集器与内存分配机制（一）

垃圾收集器与内存分配机制（一）

目录 一、为什么我们要去了解垃圾收集和内存分配 二、对象已死&#xff1f; 1. 引用计数算法 2. 可达性分析算法 3. 再谈引用 4. 生存还是死亡 5. 回收方法区 三、垃圾收集算法 1. 简介 2. 分代收集理论 2.1. 弱分代/强分代假说 2.2. 前面两代假说的缺陷 3. 标记-清…
阅读更多...
智能去毛刺：2D视觉引导机器人如何重塑制造业未来

智能去毛刺：2D视觉引导机器人如何重塑制造业未来

机器人技术已经深入到各个工业领域中&#xff0c;为制造业带来了前所未有的变革。其中&#xff0c;2D视觉引导机器人技术以其精准、高效的特点&#xff0c;在去毛刺工艺中发挥着越来越重要的作用。本文将为您介绍2D视觉引导机器人技术的基本原理及其在去毛刺工艺中的应用&#…
阅读更多...
blender 理解 积木组合 动画制作 学习笔记

blender 理解 积木组合 动画制作 学习笔记

一、学习blender视频教程链接 案例2&#xff1a;积木组合_动画制作_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV1Bt4y1E7qn?vd_sourced0ea58f1127eed138a4ba5421c577eb1&p10&spm_id_from333.788.videopod.episodes 二、说明 之前已经学习了如何制作积木组…
阅读更多...
20 Shell Script输入与输出

20 Shell Script输入与输出

标出输入、标准输出、错误输出 一、程序的基本三个IO流 一&#xff09;文件描述符 ​ 任何程序在Linux系统中都有3个基本的文件描述符 ​ 比如: ​ cd/proc/$$/fd ​ 进入当前shell程序对于内核在文件系统的映射目录中: [rootlocalhost ~]# cd /proc/$$/fd [rootlocalhos…
阅读更多...
Ubuntu22.04环境搭建MQTT服务器

Ubuntu22.04环境搭建MQTT服务器

官网&#xff1a; https://mosquitto.org 1.引入库 sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa2.升级安装工具 sudo apt-get update 3.安装 sudo apt-get install mosquitto 4.安装客户端 sudo apt-get install mosquitto-clients5.添加修改配置文件 进…
阅读更多...
微信小程序上传图片添加水印

微信小程序上传图片添加水印

微信小程序使用wx.chooseMedia拍摄或从手机相册中选择图片并添加水印&#xff0c; 代码如下&#xff1a; // WXML代码&#xff1a;<canvas canvas-id"watermarkCanvas" style"width: {{canvasWidth}}px; height: {{canvasHeight}}px;"></canvas&…
阅读更多...
【Linux】冯诺依曼体系结构 OS的概念

【Linux】冯诺依曼体系结构 OS的概念

&#x1fa90;&#x1fa90;&#x1fa90;欢迎来到程序员餐厅&#x1f4ab;&#x1f4ab;&#x1f4ab; 主厨&#xff1a;邪王真眼 主厨的主页&#xff1a;Chef‘s blog 所属专栏&#xff1a;青果大战linux 总有光环在陨落&#xff0c;总有新星在闪烁 前言废话&#xff1a…
阅读更多...
将java项目jar包打包成exe服务

将java项目jar包打包成exe服务

1.结构展示 2.注意事项 前提: 环境准备:jdk8 和 .net支持 { 1.控制面板》程序和功能》启用和关闭windows功能》.net的勾选》2.jdk8自行百度安装环境3.其他项目必须的软件环境安装等&#xff08;数据库...&#xff09; }第一次准备: 1.将打包好的jar包放到premiumServices.exe…
阅读更多...
销冠教你如何转化观望客户

销冠教你如何转化观望客户

在销售实践中&#xff0c;常会遇到这样的场景&#xff1a;客户对我们的提案表现出极大的兴趣&#xff0c;但在执行阶段却显得迟疑&#xff0c;频繁表示“还需观望&#xff0c;再考虑”。这种态度不仅拖慢了项目进度&#xff0c;甚至可能导致项目完全停滞&#xff0c;从而错失宝…
阅读更多...
Spring Boot技术栈在论坛网站开发中的应用

Spring Boot技术栈在论坛网站开发中的应用

2相关技术 2.1 MYSQL数据库 MySQL是一个真正的多用户、多线程SQL数据库服务器。 是基于SQL的客户/服务器模式的关系数据库管理系统&#xff0c;它的有点有有功能强大、使用简单、管理方便、安全可靠性高、运行速度快、多线程、跨平台性、完全网络化、稳定性等&#xff0c;非常…
阅读更多...
最新文章

Copyright @ 2022~2023