关于分布式:分布式事务解决方案之-Alibaba-Seata

4次阅读

共计 2566 个字符,预计需要花费 7 分钟才能阅读完成。

对于事务的几点常识

本地事务

该类事务须要满足四大个性:ACID(原子性、一致性、隔离性、持久性),仅限于对繁多数据库资源的访问控制。

  • 原子性(Atomicity):指事务作为整体来执行,要么全副执行,要么全副不执行。
  • 一致性(Consistency):指事务应确保数据从一个统一的状态转变为另一个统一状态。
  • 隔离性(Isolation):指多个事务并发时,一个事务的执行不应影响其它事务的执行。
  • 持久性(Durability):指已提交的事务批改数据会被长久保留。

柔性事务

如果将实现了 ACID 的四大事务个性的事务成为刚性事务的话,那么基于 BASE 事务因素的事务则成为柔性事务。

BASE 是根本可用、柔性状态和最终一致性这三个个性的缩写。

  • 根本可用(Basically Available):容许分布式事务参与方不肯定要同时在线。
  • 柔性状态(Soft state):则容许零碎状态更新有肯定的延时。
  • 最终一致性(Eventually consistent):通常是通过消息传递的形式保证系统的 最终一致性

ACID 事务中对隔离性的要求很高,在事务执行过程中,必须将所有的资源锁定。而柔性事务的理念则是通过业务逻辑将互斥锁操作从资源层面移至业务层面。通过放宽对 强一致性 的要求,来换取零碎吞吐量的晋升。

基于 XA 标准的两阶段提交

通过形象进去的 AP(应用程序)、TM(事务管理器)、RM(资源管理器)的概念能够保障事务的 强一致性 。其中 TMRM 间采纳 XA 的协定进行双向通信。

与传统的本地事务相比,XA 协定减少了 Prepare 阶段,数据库除了被动承受提交指令以外,还能够反向告诉调用方事务是否能够被提交。

TM 能够收集所有分支事务的 Prepare 后果,最初进行原子的提交,保障事务的强一致性。

Alibaba Seata 简介

概述

Seata 是一款开源的分布式事务解决方案,提供高性能和简略易用的分布式事务服务,提供了 ATSAGAXA 事务模式。

术语

  • TC 事务协调者:保护全局和分支事务的状态,驱动全局事务提交或回滚。
  • TM 事务管理器:定义全局事务的范畴,从开始全局事务 > 提交或回滚事务。
  • RM 资源管理器:治理分支事务处理的资源,与 TC 单干以注册分支事务和报告分支事务的状态,驱动分支事务提交或回滚。

接入 Seata 分布式事务

首先咱们用到的是 SeataAT 模式,该模式的特点就是对业务无入侵式,分二阶段提交。

  • 一阶段:业务数据和回滚日志记录在同一个本地事务中提交,开释本地锁和连贯资源。
  • 二阶段:提交异步化,十分疾速,回滚通过一阶段的回滚日志进行反向弥补。

启动 Seata Server

下载地址:https://seata.io/zh-cn/blog/download.html

创立表

在我的项目数据库中增加事务所要用到的表:

CREATE TABLE IF NOT EXISTS `undo_log`
(
`id`            BIGINT(20)   NOT NULL AUTO_INCREMENT COMMENT ‘increment id’,
`branch_id`     BIGINT(20)   NOT NULL COMMENT ‘branch transaction id’,
`xid`           VARCHAR(100) NOT NULL COMMENT ‘global transaction id’,
`context`       VARCHAR(128) NOT NULL COMMENT ‘undo_log context,such as serialization’,
`rollback_info` LONGBLOB     NOT NULL COMMENT ‘rollback info’,
`log_status`    INT(11)      NOT NULL COMMENT ‘0:normal status,1:defense status’,
`log_created`   DATETIME     NOT NULL COMMENT ‘create datetime’,
`log_modified`  DATETIME     NOT NULL COMMENT ‘modify datetime’,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB
AUTO_INCREMENT = 1
DEFAULT CHARSET = utf8 COMMENT =’AT transaction mode undo table’;

引入依赖

pom.xml 中引入 Seata 依赖:

<dependency>
<groupId>io.seata</groupId>
<artifactId>seata-spring-boot-starter</artifactId>
<version>1.1.0</version>
</dependency>

application.yml 文件中退出以下配置:

seata:
enabled: true
application-id: test  #可自定义
tx-service-group: my_test_tx_group #可自定义
# enable-auto-data-source-proxy: true
# use-jdk-proxy: false
service:
vgroup-mapping:
my_test_tx_group: default
grouplist:
default: 127.0.0.1:8091
#     disable-global-transaction: false
config:
type: file
file:
name: file.conf
registry:
type: file

相干注解

在事务发起者的接口上退出 @GlobalTransactional 注解即可。

  • 文章作者:彭超
  • 本文首发于集体博客:https://antoniopeng.com/2020/07/20/%E5%88%86%E5%B8%83%E5%BC%8F/%E5%88%86%E5%B8%83%E5%BC%8F%E4%BA%8B%E5%8A%A1%E8%A7%A3%E5%86%B3%E6%96%B9%E6%A1%88%E4%B9%8B%20Alibaba%20Seata/
  • 版权申明:本博客所有文章除特地申明外,均采纳 CC BY-NC-SA 4.0 许可协定。转载请注明来自 彭超 | Blog!
正文完
 0