若依微服务实现分布式事务

一、基本介绍

1、什么是分布式事务

指一次大的操作由不同的小操作组成的，这些小的操作分布在不同的服务器上，分布式事务需要保证这些小操作要么全部成功，要么全部失败。从本质上来说，分布式事务就是为了保证不同数据库的数据一致性。

2、为什么要使用分布式事务

在微服务独立数据源的思想，每一个微服务都有一个或者多个数据源，虽然单机单库事务已经非常成熟，但是由于网路延迟和不可靠的客观因素，分布式事务到现在也还没有成熟的方案，对于中大型网站，特别是涉及到交易的网站，一旦将服务拆分微服务，分布式事务一定是绕不开的一个组件，通常解决分布式事务问题。

3、seata 分布式事务

Seata是阿里开源的一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。

Seata目标打造一站式的分布事务的解决方案，最终会提供四种事务模式：

  • AT 模式：参见(《Seata AT 模式》 https://seata.io/zh-cn/docs/dev/mode/at-mode.html)文档

  • TCC 模式：参见(《Seata TCC 模式》 https://seata.io/zh-cn/docs/dev/mode/tcc-mode.html)文档

  • Saga 模式：参见(《SEATA Saga 模式》 https://seata.io/zh-cn/docs/dev/mode/at-mode.html)文档

  • XA 模式：正在开发中...

目前使用的流行度情况是：AT > TCC > Saga。因此，我们在学习Seata的时候，可以花更多精力在AT模式上，最好搞懂背后的实现原理，毕竟分布式事务涉及到数据的正确性，出问题需要快速排查定位并解决。

二、下载方式

  • Windows平台安装包下载
    可以从https://github.com/seata/seata/releases下载seata-server-$version.zip包

Windows下载解压后（.zip），直接点击bin/seata-server.bat就可以了。（本文使用1.4.0版本）

三、如何使用

1、创建相关测试数据库和表

# 订单数据库信息 seata_order
DROP DATABASE IF EXISTS seata_order;
CREATE DATABASE seata_order;DROP TABLE IF EXISTS seata_order.p_order;
CREATE TABLE seata_order.p_order
(id               INT(11) NOT NULL AUTO_INCREMENT,user_id          INT(11) DEFAULT NULL,product_id       INT(11) DEFAULT NULL,amount           INT(11) DEFAULT NULL,total_price      DOUBLE       DEFAULT NULL,status           VARCHAR(100) DEFAULT NULL,add_time         DATETIME     DEFAULT CURRENT_TIMESTAMP,last_update_time DATETIME     DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,PRIMARY KEY (id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;DROP TABLE IF EXISTS seata_order.undo_log;
CREATE TABLE seata_order.undo_log
(id            BIGINT(20) NOT NULL AUTO_INCREMENT,branch_id     BIGINT(20) NOT NULL,xid           VARCHAR(100) NOT NULL,context       VARCHAR(128) NOT NULL,rollback_info LONGBLOB     NOT NULL,log_status    INT(11) NOT NULL,log_created   DATETIME     NOT NULL,log_modified  DATETIME     NOT NULL,PRIMARY KEY (id),UNIQUE KEY ux_undo_log (xid, branch_id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;# 产品数据库信息 seata_product
DROP DATABASE IF EXISTS seata_product;
CREATE DATABASE seata_product;DROP TABLE IF EXISTS seata_product.product;
CREATE TABLE seata_product.product
(id               INT(11) NOT NULL AUTO_INCREMENT,price            DOUBLE   DEFAULT NULL,stock            INT(11) DEFAULT NULL,last_update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,PRIMARY KEY (id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;DROP TABLE IF EXISTS seata_product.undo_log;
CREATE TABLE seata_product.undo_log
(id            BIGINT(20) NOT NULL AUTO_INCREMENT,branch_id     BIGINT(20) NOT NULL,xid           VARCHAR(100) NOT NULL,context       VARCHAR(128) NOT NULL,rollback_info LONGBLOB     NOT NULL,log_status    INT(11) NOT NULL,log_created   DATETIME     NOT NULL,log_modified  DATETIME     NOT NULL,PRIMARY KEY (id),UNIQUE KEY ux_undo_log (xid, branch_id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;INSERT INTO seata_product.product (id, price, stock)
VALUES (1, 10, 20);# 账户数据库信息 seata_account
DROP DATABASE IF EXISTS seata_account;
CREATE DATABASE seata_account;DROP TABLE IF EXISTS seata_account.account;
CREATE TABLE seata_account.account
(id               INT(11) NOT NULL AUTO_INCREMENT,balance          DOUBLE   DEFAULT NULL,last_update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,PRIMARY KEY (id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;DROP TABLE IF EXISTS seata_account.undo_log;
CREATE TABLE seata_account.undo_log
(id            BIGINT(20) NOT NULL AUTO_INCREMENT,branch_id     BIGINT(20) NOT NULL,xid           VARCHAR(100) NOT NULL,context       VARCHAR(128) NOT NULL,rollback_info LONGBLOB     NOT NULL,log_status    INT(11) NOT NULL,log_created   DATETIME     NOT NULL,log_modified  DATETIME     NOT NULL,PRIMARY KEY (id),UNIQUE KEY ux_undo_log (xid, branch_id)
) ENGINE = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8mb4;
INSERT INTO seata_account.account (id, balance)
VALUES (1, 50);

其中，每个库中的undo_log表，是Seata AT模式必须创建的表，主要用于分支事务的回滚。
另外，为了测试方便，插入了一条id = 1的account记录，和一条id = 1的product记录。

2、引入ruoyi-common-datasource依赖（包含seata配置）

<!-- ruoyi common datasource -->
<dependency><groupId>com.ruoyi</groupId><artifactId>ruoyi-common-datasource</artifactId>
</dependency>

3、服务配置文件

# spring配置
spring: redis:host: localhostport: 6379password: datasource:druid:stat-view-servlet:enabled: trueloginUsername: adminloginPassword: 123456dynamic:druid:initial-size: 5min-idle: 5maxActive: 20maxWait: 60000timeBetweenEvictionRunsMillis: 60000minEvictableIdleTimeMillis: 300000validationQuery: SELECT 1 FROM DUALtestWhileIdle: truetestOnBorrow: falsetestOnReturn: falsepoolPreparedStatements: truemaxPoolPreparedStatementPerConnectionSize: 20filters: stat,wall,slf4jconnectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000datasource:# 主库数据源master:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/ry-cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8username: rootpassword: password# seata_order数据源order:username: rootpassword: passwordurl: jdbc:mysql://localhost:3306/seata_order?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8driver-class-name: com.mysql.cj.jdbc.Driver# seata_account数据源account:username: rootpassword: passwordurl: jdbc:mysql://localhost:3306/seata_account?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8driver-class-name: com.mysql.cj.jdbc.Driver# seata_product数据源product:username: rootpassword: passwordurl: jdbc:mysql://localhost:3306/seata_product?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8driver-class-name: com.mysql.cj.jdbc.Driverseata: true    #开启seata代理，开启后默认每个数据源都代理，如果某个不需要代理可单独关闭# seata配置
seata:enabled: true# Seata 应用编号，默认为 ${spring.application.name}application-id: ${spring.application.name}# Seata 事务组编号，用于 TC 集群名tx-service-group: ${spring.application.name}-group# 关闭自动代理enable-auto-data-source-proxy: false# 服务配置项service:# 虚拟组和分组的映射vgroup-mapping:ruoyi-system-group: default# 分组和 Seata 服务的映射grouplist:default: 127.0.0.1:8091config:type: fileregistry:type: file# mybatis配置
mybatis:# 搜索指定包别名typeAliasesPackage: com.ruoyi.system# 配置mapper的扫描，找到所有的mapper.xml映射文件mapperLocations: classpath:mapper/**/*.xml# swagger配置
swagger:title: 系统模块接口文档license: Powered By ruoyilicenseUrl: https://ruoyi.vip

注意：
一定要设置spring.datasource.dynamic.seata配置项为true，开启对Seata的集成，否则会导致Seata全局事务回滚失败。

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

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

相关文章

ssm137基于SSM框架的微博系统+vue

ssm137基于SSM框架的微博系统+vue

微博系统网站的设计与实现 摘 要 网络技术和计算机技术发展至今&#xff0c;已经拥有了深厚的理论基础&#xff0c;并在现实中进行了充分运用&#xff0c;尤其是基于计算机运行的软件更是受到各界的关注。加上现在人们已经步入信息时代&#xff0c;所以对于信息的宣传和管理就…
阅读更多...
家用洗地机哪个品牌好？家用洗地机排行榜前十名

家用洗地机哪个品牌好？家用洗地机排行榜前十名

随着洗地机逐渐进入大众视野&#xff0c;这种集吸、拖、洗功能于一体的清洁工具&#xff0c;凭借其高效便捷的特点&#xff0c;成为家庭清洁的新宠。洗地机不仅能够减少地面清洁时间&#xff0c;节省体力&#xff0c;还能提高清洁效果。然而&#xff0c;面对琳琅满目的洗地机品…
阅读更多...
[学习笔记]（Python3）防止SQL注入、XSS攻击和文件上传漏洞

[学习笔记]（Python3）防止SQL注入、XSS攻击和文件上传漏洞

学习笔记&#xff1a;防止SQL注入、XSS攻击和文件上传漏洞&#xff08;Python3&#xff09; 本笔记由生成式大模型GPT-4o自动整理。注意AI可能犯错。代码和理论由GPT-4o(2024-5-21)自行撰写未经人工复核。 参数化查询防SQL注入 参数化查询通过将SQL语句和数据分离来防止SQL注…
阅读更多...
Web会话管理

Web会话管理

一、会话管理的概念&#xff1a; 在人机交互时&#xff0c;会话管理是保持用户的整个会话活动的互动与计算机系统跟踪过程会话管理分类: 桌面会话管理、浏览器会话管理、Web服务器的会话管理。 二、为什么需要会话管理&#xff1f; HTTP是一种无状态协议&#xff0c;一次请…
阅读更多...
Vue.js 混入（Mixins）高级用法：提升代码复用与灵活性

Vue.js 混入（Mixins）高级用法：提升代码复用与灵活性

Vue.js 中的混入&#xff08;Mixins&#xff09;是一种强大而灵活的设计模式&#xff0c;它允许你将可复用的组件功能抽离为独立的模块&#xff0c;并在多个组件间共享。本文将深入探讨混入的高级用法&#xff0c;包括如何传递参数给混入、解决命名冲突、以及如何利用高阶组件思…
阅读更多...
【Python-OS】os.path.isfile()

【Python-OS】os.path.isfile()

作用&#xff1a; 检查指定路径是否指向一个文件 即检查指定路径下是否存在该文件 os.path.isfile(path)注&#xff1a; path&#xff1a; 可以自行指定路径&#xff0c;需要具体到文件名(需要加上扩展名) 返回值&#xff1a; True or False
阅读更多...
java项目之智能家居系统源码（springboot+vue+mysql）

java项目之智能家居系统源码（springboot+vue+mysql）

风定落花生&#xff0c;歌声逐流水&#xff0c;大家好我是风歌&#xff0c;混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的智能家居系统。项目源码以及部署相关请联系风歌&#xff0c;文末附上联系信息 。 项目简介&#xff1a; 基于Springboot的智能家居系…
阅读更多...
【高校科研前沿】湖北工业大学为第一署名单位在《Science》发表Letters文章：应对青藏高原河流泥沙激增

【高校科研前沿】湖北工业大学为第一署名单位在《Science》发表Letters文章：应对青藏高原河流泥沙激增

文章简介 论文名称&#xff1a;Combating sediment surge in Tibetan rivers&#xff08;应对青藏高原河流泥沙激增&#xff09; 相关作者及单位&#xff1a;杨洪教授&#xff08;英国雷丁大学&#xff09;&刘德富教授&#xff08;湖北工业大学&#xff09;&Julian R…
阅读更多...
huggingface 笔记：聊天模型

huggingface 笔记：聊天模型

1 构建聊天 聊天模型继续聊天。传递一个对话历史给它们&#xff0c;可以简短到一个用户消息&#xff0c;然后模型会通过添加其响应来继续对话一般来说&#xff0c;更大的聊天模型除了需要更多内存外&#xff0c;运行速度也会更慢首先&#xff0c;构建一个聊天&#xff1a; ch…
阅读更多...
灵动微单片机洗衣机方案——【软硬件开发支持】

灵动微单片机洗衣机方案——【软硬件开发支持】

RAMSUN英尚以洗衣机洗涤主驱电机为例&#xff0c;主驱电机和多电机控制首选MM32SPIN0280.灵动微电子能够提供完整的软硬件开发支持&#xff0c;目前方案已经在主流家电厂出货。 洗衣机方案 皮带洗衣机 DD直驱洗衣机 波轮洗衣机 Mini壁挂和桌面洗衣机 洗涤烘干双变频方案 热泵烘…
阅读更多...
python前端通过API接口调用与后端进行数据交互前端如何调用api接口通过关键词获取电商平台热销商品数据

python前端通过API接口调用与后端进行数据交互前端如何调用api接口通过关键词获取电商平台热销商品数据

要在Python前端通过API接口调用与后端进行数据交互并通过关键词获取电商平台热销商品数据&#xff0c;可以通过封装好的api接口通过链接直接请求获取数据&#xff0c;以下是接入api的请求示例&#xff1a; # coding:utf-8 """ Compatible for python2.x and py…
阅读更多...
uniapp - 文章模块页面

uniapp - 文章模块页面

在上一篇文章中&#xff0c;创建了一个空白的文章模块页面。在这一篇文章&#xff0c;让我们来向页面中填充内容。 目录 页面效果涉及uniapp组件1.view2.swiper3.scroll-view4.属性解读1) class"style1 style2 .."2) circular单属性无赋值3) :autoplay"autoplay…
阅读更多...
信息标记形式 (XML, JSON, YAML)

信息标记形式 (XML, JSON, YAML)

文章目录 &#x1f5a5;️介绍&#x1f5a5;️三种形式&#x1f3f7;️XML (Extensible Markup Language)&#x1f516;规范&#x1f516;注释&#x1f516;举例&#x1f516;其他 &#x1f3f7;️JSON (JavaScript Object Notation)&#x1f516;规范&#x1f516;注释&#x…
阅读更多...
游戏行业如何利用隐私计算技术增强玩家体验

游戏行业如何利用隐私计算技术增强玩家体验

PrimiHub一款由密码学专家团队打造的开源隐私计算平台&#xff0c;专注于分享数据安全、密码学、联邦学习、同态加密等隐私计算领域的技术和内容。 在游戏行业&#xff0c;玩家体验的个性化是提升用户粘性和满意度的关键。随着技术的发展&#xff0c;游戏公司现在可以利用大量的…
阅读更多...
存内计算从浮点运算优化对数据经济的提升

存内计算从浮点运算优化对数据经济的提升

本篇文章将介绍存内计算技术对于数据经济的提升&#xff0c;我们将从提出问题、解答问题与阐述应用三个方面进行展开介绍&#xff0c;并引入浮点存算、等新兴存算技术进行简要介绍。 一.数据经济&存内计算&#xff0c;结合是否可行&#xff1f; 数据经济与存内计算&#…
阅读更多...
浅说线性DP（上）

浅说线性DP（上）

前言 在说线性dp之前&#xff0c;我们先来聊一聊动态规划是啥&#xff1f; 动态规划到底是啥&#xff1f; 动态规划是普及组内容中最难的一个部分&#xff0c;也是每年几乎必考的内容。它对思维的要求极高&#xff0c;它和图论、数据结构不同的地方在于它没有一个标准的数学…
阅读更多...
mysql 01 linux 上安装mysql服务端

mysql 01 linux 上安装mysql服务端

01.linux安装 MySQL的大部分安装包都包含了服务器程序和客户端程序&#xff0c;不过在Linux下使用RPM包时会有单独的服 务器RPM包和客户端RPM包&#xff0c;需要分别安装。 1.查看是否已经安装了MySQL rpm -qa | grep mysql如果什么都没有&#xff0c;就是还没有装过MySQL …
阅读更多...
Vue3记录校验工具类：validata.ts

Vue3记录校验工具类：validata.ts

在vue文件使用&#xff1a; import { validateNull } from //utils/validata; validateNull(需要校验的数据)validata.ts文件&#xff1a; /*** 判断是否为空* param val 数据*/ export const validateNull (val: any) > {if (typeof val boolean) {return false;}if (t…
阅读更多...
C++核心编程——4.7 多态

C++核心编程——4.7 多态

4.7.1 多态的基本概念 多态是C面向对象三大特性之一 多态表示提供一个公共的函数接口&#xff0c;当传入不同参数对象时&#xff0c;执行不同的函数实现。 语法 virtual 返回值类型 函数名() {} 分类 静态多态 动态多态&#xff08;加“virtual“&#xff09; 函数重载 和 …
阅读更多...
基于Pytorch框架的深度学习RegNet神经网络二十五种宝石识别分类系统源码

基于Pytorch框架的深度学习RegNet神经网络二十五种宝石识别分类系统源码

第一步&#xff1a;准备数据 25种宝石数据&#xff0c;总共800张&#xff1a; { "0": "Alexandrite","1": "Almandine","2": "Benitoite","3": "Beryl Golden","4": "Carne…
阅读更多...
最新文章

Copyright @ 2022~2023