中间件之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 {@Overridepublic boolean prepare(BusinessActionContext actionContext, String a) {// 执行业务的预备操作// ...return true; // 返回try成功状态}@Overridepublic boolean commit(BusinessActionContext actionContext) {// 执行业务的确认操作// ...return true; // 返回commit成功状态}@Overridepublic 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以保证分布式事务的一致性和性能。

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【Java网络编程】从套接字(Socket)概念到UDP与TCP套接字编程

【Java网络编程】从套接字(Socket)概念到UDP与TCP套接字编程

目录 网络编程 1.socket套接字 2.udp数据报套接字编程 DatagramSocket API DatagramPacket API Java基于UDP实现客户端-服务器代码实例 3.tcp流套接字编程 ServerSocket API Socket API TCP中的长短连接 Java基于TCP客户端-服务器代码实例 网络编程 1.socket套接字 S…
阅读更多...
正则表达式基本语法(快速认知)

正则表达式基本语法(快速认知)

正则表达式:一种用于匹配字符串的模式。它可以用于搜索、替换、验证字符串等多种操作。 基本语法: 字符类: [abc]: 匹配 a、b 或 c。[a-z]: 匹配小写字母。[A-Z]: 匹配大写字母。[0-9]: 匹配数字母 比如我们的电话号码是11个数字组成, 则可以表示为: String tel"[0-9][0…
阅读更多...
uniapp 引入了uview-ui后，打包错误，主包过大解决方案

uniapp 引入了uview-ui后，打包错误，主包过大解决方案

原因&#xff1a;由于使用uniapp来设计小程序&#xff0c;使用uview的组件库&#xff0c;导致了主包过大&#xff0c;无法打包 前提条件&#xff1a;已经完成了分包&#xff0c;如果还没有分包的先分包&#xff0c;需要上传代码时用到 1. 通常情况&#xff0c;大多数都是通过点…
阅读更多...
构建中小企业设备管理平台：Spring Boot应用

构建中小企业设备管理平台：Spring Boot应用

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

ReactOS系统中平衡二叉树按从左到右的顺序找到下一个结点

ReactOS系统中平衡二叉树按从左到右的顺序找到下一个结点MmIterateNextNode()按从左到右的顺序找到下一个结点 文章目录 ReactOS系统中平衡二叉树按从左到右的顺序找到下一个结点MmIterateNextNode()按从左到右的顺序找到下一个结点MmIterateNextNode() MmIterateNextNode() /*…
阅读更多...
深入剖析 C 与 C++ 动态内存管理之术

深入剖析 C 与 C++ 动态内存管理之术

亲爱的读者朋友们&#x1f603;&#xff0c;此文开启知识盛宴与思想碰撞&#x1f389;。 快来参与讨论&#x1f4ac;&#xff0c;点赞&#x1f44d;、收藏⭐、分享&#x1f970;&#xff0c;共创活力社区。 &#x1f525;&#x1f525;&#x1f525;【C】进阶&#xff1a;类相关…
阅读更多...
Python实现基于WebSocket的stomp协议调试助手工具

Python实现基于WebSocket的stomp协议调试助手工具

stomp协议很简单&#xff0c;但是搜遍网络竟没找到一款合适的客户端工具。大多数提供的都是客户端库的使用。可能是太简单了吧&#xff01;可是即便这样&#xff0c;假如有一可视化的工具&#xff0c;将方便的对stomp协议进行抓包调试。网上类似MQTT的客户端工具有很多&#xf…
阅读更多...
linux shell 脚本语言教程（超详细！）

linux shell 脚本语言教程（超详细！）

Shell 编程详细指南 什么是 Shell&#xff1f; Shell 是用户与操作系统内核之间的接口&#xff0c;允许用户通过命令行输入来控制操作系统。它充当命令解释器&#xff0c;读取用户输入的命令并执行相应的操作。Shell 提供了强大的脚本编程能力&#xff0c;可以自动化许多任务…
阅读更多...
【javax maven项目缺少_Maven的依赖管理 引入依赖】

【javax maven项目缺少_Maven的依赖管理 引入依赖】

javax maven项目缺少_Maven的依赖管理 引入依赖 Maven的依赖管理 - 引入依赖依赖管理(引入依赖)导入依赖 https://blog.csdn.net/weixin_28932089/article/details/112381468 Maven的依赖管理 - 引入依赖 依赖管理(引入依赖) 能够掌握依赖引入的配置方式 导入依赖 导入依赖练…
阅读更多...
银行客户贷款行为数据挖掘与分析

银行客户贷款行为数据挖掘与分析

#1024程序员节 | 征文# 在新时代下&#xff0c;消费者的需求结构、内容与方式发生巨大改变&#xff0c;企业要想获取更多竞争优势&#xff0c;需要借助大数据技术持续创新。本文分析了传统商业银行面临的挑战&#xff0c;并基于knn、逻辑回归、人工神经网络三种算法&#xff0…
阅读更多...
重构案例：将纯HTML/JS项目迁移到Webpack

重构案例：将纯HTML/JS项目迁移到Webpack

我们已经了解了许多关于 Webpack 的知识&#xff0c;但要完全熟练掌握它并非易事。一个很好的学习方法是通过实际项目练习。当我们对 Webpack 的配置有了足够的理解后&#xff0c;就可以尝试重构一些项目。本次我选择了一个纯HTML/JS的PC项目进行重构&#xff0c;项目位于 GitH…
阅读更多...
[旧日谈]高清画面撕裂问题考

[旧日谈]高清画面撕裂问题考

背景 无边框透明背景透明的窗口&#xff0c;在随着缩放比例非整数倍数放大时的画面发生了露底、撕裂问题。 当我们在使用Qt开发的时候&#xff0c;遇到了一个结构性问题。因为我们的软件是自己做的&#xff0c;所以要自己定义标题栏&#xff0c;所以我们设置了软件为FrameLess…
阅读更多...
mono源码交叉编译 linux arm arm64全过程

mono源码交叉编译 linux arm arm64全过程

初级代码游戏的专栏介绍与文章目录-CSDN博客 我的github&#xff1a;codetoys&#xff0c;所有代码都将会位于ctfc库中。已经放入库中我会指出在库中的位置。 这些代码大部分以Linux为目标但部分代码是纯C的&#xff0c;可以在任何平台上使用。 源码指引&#xff1a;github源…
阅读更多...
mysql——事务详解

mysql——事务详解

一、事务定义 事务&#xff1a;事务是一个最小的不可在分的工作单元&#xff1b;通常一个事务对应一个完整的业务(例如银行账户转账业务&#xff0c;该业务是一个最小的工作单元)事务保证多条sql语句要么同时执行成功&#xff0c;要么同时执行失败一个完整的业务需要批量的DML…
阅读更多...
移除Microsoft Edge浏览器“由你的组织管理“提示的方法

移除Microsoft Edge浏览器“由你的组织管理“提示的方法

背景&#xff1a; 点击Microsoft Edge浏览器右上角的按钮有时候会出现提示“由你的组织管理”。但实际上自己的电脑并没有被公司或其他企业管理。 解决方案&#xff1a; 提示&#xff1a;修改注册表如果操作不当会影响电脑&#xff0c;请提前备份注册表&#xff01;&#xff…
阅读更多...
Java 开发——（上篇）从零开始搭建后端基础项目 Spring Boot 3 + MybatisPlus

Java 开发——（上篇）从零开始搭建后端基础项目 Spring Boot 3 + MybatisPlus

一、概述 记录时间 [2024-10-23] 本文是一个基于 Spring Boot 3 MybatisPlus 的项目实战开发&#xff0c;主要涵盖以下几个方面&#xff1a; 从零开始的项目创建IDEA 中开发环境的热部署Maven、Swagger3、MybatisPlus 等的配置路由映射知识静态资源访问文件上传功能实现拦截器…
阅读更多...
Qt之QCamera的简单使用

Qt之QCamera的简单使用

文章目录 一、相机操作相关示例1.摄像头操作内容使用示例2.摄像头信息展示使用示例3.摄像头设置切换、预览操作示例 二、相机使用个人操作理解1.相机类支持信息获取2.相机类曝光、焦点、图像处理控制信息获取3.快速启动相机设置&#xff08;各个设备处于理想状态&#xff09; 三…
阅读更多...
地平线x5下运行yolo11s-seg模型

地平线x5下运行yolo11s-seg模型

经过地瓜机器人工作人员&#xff08;感谢吴超同学&#xff09;的及时技术支持&#xff0c;整体比较顺利的跑起来了yolo11s-seg分割模型。将一些经验记录下来&#xff1a; 首先下载使用docker镜像&#xff1a; https://developer.d-robotics.cc/forumDetail/228559182180396619 …
阅读更多...
linux驱动—注册总线分析

linux驱动—注册总线分析

成功地在直接注册了一个总线&#xff0c;并且在总线目录下创建了属性文件&#xff0c;什么会在 sys/bus 目录下生成 mybus,目录以及对应的 devices,drivers, drivers_autoprobe,drivers_probe&#xff0c;uevent目录和属性呢? /sys,目录下的目录都对应一个kobject&#xff0c;…
阅读更多...
如何成为录屏高手？2024年全新录屏工具梳理，你选对了吗？

如何成为录屏高手？2024年全新录屏工具梳理，你选对了吗？

如何录屏&#xff1f;录屏现在对我们来说太重要了&#xff0c;不管是做教学视频、演示文稿&#xff0c;还是录游戏或者教别人怎么用软件&#xff0c;都离不开录屏工具。但是市面上录屏软件一大堆&#xff0c;挑个适合自己的真不容易。今天&#xff0c;我就来给你介绍几款特别火…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023