分布式事务一站式解决方案-Seata

news2024/9/24 1:27:13

分布式事务一站式解决方案-

  • 分布式事务一站式解决方案
    • 分布式事务产生背景
    • 三个概念
    • Seata下载和安装
    • 实际业务模拟演示
      • 不加 @GlobalTransactional 注解，正常操作下单
      • 不加 @GlobalTransactional 注解，下单过程出异常或者超时了
      • 加 @GlobalTransactional 注解，下单过程出异常或者超时了
    • 原理
      • undo_log 表作用
      • 二阶段提交原理
      • 分布式事务的执行流程（下订单-减库存-账户更新）

分布式事务一站式解决方案

分布式事务产生背景

一般来说，如果是微服务架构，会采用分布式系统开发，既然是多个微服务，那肯定是有多个独立的数据库的，那问题来了，
在这里插入图片描述
所以迫切希望提供一种分布式事务，解决微服务架构下的分布式事务问题

三个概念

在这里插入图片描述

Seata下载和安装

下载就不说了，直接去官方网站下载最新版本即可，注意安装 Seata 之前需要启动 Nacos，下载 Nacos 后直接 startup.cmd -m standalone 启动即可。
解压 seata-server-2.0.0.zip ，然后进入 conf 目录，更改 application.yml 配置如下，注意 console.user.username console.user.password seata.security.secretKey seata.security.tokenValidityInMilliseconds 这4个一定要配置，不然启动报错

20:37:31.390  WARN --- [                     main] [letWebServerApplicationContext] [             refresh]  [] : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'webSecurityConfig': Unsatisfied dependency expressed through field 'userDetailsService'; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'customUserDetailsServiceImpl': Injection of autowired dependencies failed; 
nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'console.user.username' in value "${console.user.username}"

20:39:36.510  WARN --- [                     main] [letWebServerApplicationContext] [             refresh]  [] : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'webSecurityConfig': Unsatisfied dependency expressed through field 'tokenProvider'; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'jwtTokenUtils': Injection of autowired dependencies failed;
nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'seata.security.secretKey' in value "${seata.security.secretKey}

server:
  port: 7091
spring:
  application:
    name: seata-server
logging:
  config: classpath:logback-spring.xml
  file:
    path: ${log.home:${user.home}/logs/seata}
  extend:
    logstash-appender:
      destination: 127.0.0.1:4560
    kafka-appender:
      bootstrap-servers: 127.0.0.1:9092
      topic: logback_to_logstash
console:
  user:
    username: seata
    password: seata      

seata:
  security:
    secretKey: 'seata'
    tokenValidityInMilliseconds: 1000000
  config:
    # support: nacos 、 consul 、 apollo 、 zk  、 etcd3
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      namespace:
      group: SEATA_GROUP
      username: nacos
      password: nacos
      context-path:
      ##if use MSE Nacos with auth, mutex with username/password attribute
      #access-key:
      #secret-key:
      # data-id: seataServer.properties
  registry:
    # support: nacos 、 eureka 、 redis 、 zk  、 consul 、 etcd3 、 sofa
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace:
      cluster: default
      username: nacos
      password: nacos
      context-path:
      ##if use MSE Nacos with auth, mutex with username/password attribute
      #access-key:
      #secret-key:
  store:
    # support: file 、 db 、 redis 、 raft
    mode: db
    session:
      mode: db
    lock:
      mode: db
    file:
      dir: sessionStore
      max-branch-session-size: 16384
      max-global-session-size: 512
      file-write-buffer-cache-size: 16384
      session-reload-read-size: 100
      flush-disk-mode: async
    db:
      datasource: druid
      db-type: mysql
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://192.168.133.128:3306/seata?useUnicode=true&rewriteBatchedStatements=true&serverTimezone=GMT
      user: root
      password: root
      min-conn: 10
      max-conn: 100
      global-table: global_table
      branch-table: branch_table
      lock-table: lock_table
      distributed-lock-table: distributed_lock
      query-limit: 1000
      max-wait: 5000

启动成功便可以进入 Seata 前端管理页面
在这里插入图片描述

在这里插入图片描述
同时 Nacos 也可以看到 Seata 服务注册上来了
在这里插入图片描述

实际业务模拟演示

本次学习会用到如下三个模块，对应三个微服务，每个服务用的单独的数据库，其中 cloud-seata-order-service2001 是订单微服务、cloud-seata-storage-service2002 是库存微服务、cloud-seata-account-service2003 是账户微服务，具体的代码可以去 github 上获取
在这里插入图片描述
项目用的数据库及表如下
在这里插入图片描述
初始阶段，订单表、库存表、账户表数据如下：
在这里插入图片描述

不加 @GlobalTransactional 注解，正常操作下单

实际的业务需求就是 下订单-扣减库存-更新账户余额，由于现在是分布式系统，如何保证事务呢？
先看看正常操作下单，1号用户花费100块买了10个1号产品，发送如下请求 http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100， 此时数据库表数据是正常的
在这里插入图片描述

不加 @GlobalTransactional 注解，下单过程出异常或者超时了

假设，在下订单->扣减库存->更新账户余额，在更新账户余额这一步代码逻辑超时了或者出异常了，为什么这里超时设置的是65秒？因为 OpenFeign 远程调用的默认超时时间是 60秒

@Slf4j
@Service
public class AccountServiceImpl implements AccountService {
    @Resource
    private AccountMapper accountMapper;
    @Override
    public void decrease(Long userId, Long money) {
        log.info("------------->AccountService 开始扣减余额");
        accountMapper.decrease(userId, money);
        log.info("------------->AccountService 开始扣减余额");
        // 超时异常
         timeout();
        // 抛出异常
        // int i = 10 / 0;
    }
    private void timeout() {
        try {
            TimeUnit.SECONDS.sleep(65);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

重启项目再发送一次请求，发现页面提示超时了，被全局异常捕获
在这里插入图片描述
查看表数据，发现库存扣减了，余额扣减了，但是订单状态是创建中…，这显然是有问题的
在这里插入图片描述

加 @GlobalTransactional 注解，下单过程出异常或者超时了

同样的过程，有了 GlobalTransactional 后，经过测试，正常下单，没问题；下单过程出异常或者超时了，数据库正确回滚，结果符合预期

@Override
// 微服务项目可能会有多个方法需要保证分布式事务，name 可以很好的区分
@GlobalTransactional(name = "create-order-transaction", rollbackFor = Exception.class)
public void create(Order order) {
    // xid全局事务检查
    String xid = RootContext.getXID();
    // 1. 新建订单
    log.info("-------------> 开始新建订单, XID: {}", xid);
    order.setStatus(0);
    int result = orderMapper.insertSelective(order);

    Order orderFromDB;
    if (result > 0) {
        orderFromDB = orderMapper.selectOne(order);
        log.info("-------------> 新建订单成功, OrderInfo: {}", orderFromDB);

        // 2. 扣减库存
        log.info("-------------> 开始扣减库存");
        storageFeignApi.decrease(orderFromDB.getProductId(), orderFromDB.getCount());
        log.info("-------------> 扣减库存成功");

        // 3. 扣减账户余额
        log.info("-------------> 开始扣减余额");
        accountFeignApi.decrease(order.getUserId(), order.getMoney());
        log.info("-------------> 扣余额存成功");

        // 4. 修改订单状态
        log.info("-------------> 开始修改订单状态");
        Example whereCondition = new Example(Order.class);
        Example.Criteria criteria = whereCondition.createCriteria();
        criteria.andEqualTo("id", orderFromDB.getId());
        criteria.andEqualTo("status", 0);
        orderFromDB.setStatus(1);
        int updateResult = orderMapper.updateByExampleSelective(orderFromDB, whereCondition);
        log.info("-------------> 修改订单状态成功");
    }
    log.info("-------------> 结束新建订单, XID: {}", xid);
}

原理

答案就是 二阶段提交，从日志输出也可以看到，PhaseTwo_Rollbacked->二阶段回滚了…

2024-08-07T21:59:43.441+08:00  INFO 26572 --- [seata-account-service] [nio-2003-exec-2] e.wong.service.impl.AccountServiceImpl   : ------------->AccountService 开始扣减余额
2024-08-07T22:00:43.500+08:00  INFO 26572 --- [seata-account-service] [h_RMROLE_1_1_24] i.s.c.r.p.c.RmBranchRollbackProcessor    : rm handle branch rollback process:BranchRollbackRequest{xid='192.168.133.1:8091:2414480718769926145', branchId=2414480718769926148, branchType=AT, resourceId='jdbc:mysql://192.168.133.128:3306/seata_account', applicationData='null'}
2024-08-07T22:00:43.501+08:00  INFO 26572 --- [seata-account-service] [h_RMROLE_1_1_24] io.seata.rm.AbstractRMHandler            : Branch Rollbacking: 192.168.133.1:8091:2414480718769926145 2414480718769926148 jdbc:mysql://192.168.133.128:3306/seata_account
2024-08-07T22:00:43.542+08:00  INFO 26572 --- [seata-account-service] [h_RMROLE_1_1_24] i.s.r.d.undo.AbstractUndoLogManager      : xid 192.168.133.1:8091:2414480718769926145 branch 2414480718769926148, undo_log deleted with GlobalFinished
2024-08-07T22:00:43.543+08:00  INFO 26572 --- [seata-account-service] [h_RMROLE_1_1_24] i.seata.rm.datasource.DataSourceManager  : branch rollback success, xid:192.168.133.1:8091:2414480718769926145, branchId:2414480718769926148
2024-08-07T22:00:43.543+08:00  INFO 26572 --- [seata-account-service] [h_RMROLE_1_1_24] io.seata.rm.AbstractRMHandler            : Branch Rollbacked result: PhaseTwo_Rollbacked

undo_log 表作用

而且上面你会发现每个微服务数据库都有张 undo_log 表，这个是做什么的呢？
在订单业务方法加了GlobalTransactional 注解后，打开 65 秒注释，目的是观察中间状态，重新请求 http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100，打开 undo_log 表，发现此时有数据
在这里插入图片描述
JSON 格式化后结构如下
在这里插入图片描述
当然此时在 Seata 管理页面也可以看到分布式事务中间状态的数据
在这里插入图片描述

不过 undo_log 表的数据在事务成功提交或者回滚之后在自动删除

二阶段提交原理

第一阶段
在这里插入图片描述
二阶段有分成两种情况：正常提交和异常回滚
在这里插入图片描述
在这里插入图片描述

分布式事务的执行流程（下订单-减库存-账户更新）

在这里插入图片描述

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

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

相关文章

Shell定时上传日志到HDFS

Shell定时上传日志到HDFS

Shell定时上传日志到HDFS 一、任务需求二、实现思路三、具体实现流程3.1 规划文件上传目录3.2 开发 shell 脚本3.3 授予 shell 可执行权限3.4 手动执行查看3.4 定时执行 shell 脚本 一、任务需求 公司在线服务器每天都会产生网站运行日志，为了避免志文件过大&#…
阅读更多...
WPF学习笔记

WPF学习笔记

WPF WPF（Windows Presentation Foundation，Windows呈现基础）是微软推出的基于Windows 的用户界面框架，属于.NET Framework 3.0的一部分。它提供了统一的编程模型、语言和框架，真正做到了分离界面设计人员与开发人员的…
阅读更多...
学习STM32（6）-- STM32单片机ADCDAC的应用

学习STM32（6）-- STM32单片机ADCDAC的应用

1 引 言 深入了解并掌握STM32F103单片机在模拟数字转换（ADC）和数字模拟转换（DAC）应用方面的功能和操作。学习如何配置STM32F103的ADC模块，实现模拟信号到数字信号的精确转换；同时，探索DAC模块…
阅读更多...
【AI学习】[2024北京智源大会]具身智能：具身智能关键技术研究：操纵、决策、导航

【AI学习】[2024北京智源大会]具身智能：具身智能关键技术研究：操纵、决策、导航

具身智能关键技术研究：操纵、决策、导航 董 豪 | 北京大学助理教授 依然是边看边做些记录 这张图的重点是在说，我们的大脑，也是不同的部分处理不同的功能。这里面有些功能，比如视觉、听觉理解等功能，LLM已经具备&…
阅读更多...
一键浪漫的回忆：微软开源的修复工具！！【送源码】

一键浪漫的回忆：微软开源的修复工具！！【送源码】

项目介绍 “Bringing-Old-Photos-Back-to-Life”是一款由微软开发的创新软件解决方案，它利用人工智能技术来修复和增强老旧照片的质量。这款工具可以解决老旧照片中常见的问题，如褪色、低分辨率以及物理损坏（如划痕和撕裂）。通过采…
阅读更多...
分析 Vue3 Effect 函数看响应式依赖收集和触发更新过程

分析 Vue3 Effect 函数看响应式依赖收集和触发更新过程

先给一个简单的实例，分析依赖收集和更新的过程 let obj { name: "hefeng6500", age: 10, flag: true }const state reactive(obj);effect(() > {app.innerHTML state.name state.age })setTimeout(() > {state.age 20 }, 1000)reactive 函数只…
阅读更多...
吴恩达：如何系统学习机器学习？

吴恩达：如何系统学习机器学习？

最近在知乎圆桌里看到吴恩达的回答，【如何系统学习机器学习？】颇为惊喜，仿佛看到了知乎刚成立时的样子，请各个行业大佬来分享专业知识。 该回答目前已经有三千多赞，评论区也相当火爆，一片膜拜之声。 吴恩…
阅读更多...
java学习19VUE

java学习19VUE

VUE NPM npm的全称是Node Package Manager 中文名为Node.js包管理器，是一个NodeJS包管理和分发工具，已经成为了非官方的发布Node模块(包)的标准。NPM可以方便地从一个全球的代码库中获取并安装Node.js模块，这些模块可以用于构建应用程序、…
阅读更多...
开发框架DevExpress XAF v24.2产品路线图预览——增强跨平台性

开发框架DevExpress XAF v24.2产品路线图预览——增强跨平台性

DevExpress XAF是一款强大的现代应用程序框架，允许同时开发ASP.NET和WinForms。XAF采用模块化设计，开发人员可以选择内建模块，也可以自行创建，从而以更快的速度和比开发人员当前更强有力的方式创建应用程序。 DevExpress XAF是一…
阅读更多...
Python 之Scikit-learn（二） -- Scikit-learn标准化数据

Python 之Scikit-learn（二） -- Scikit-learn标准化数据

在机器学习中，数据标准化是一项关键的预处理步骤。标准化（Standardization）是将数据转换为具有均值为0和标准差为1的分布。这样可以确保特征在相同的尺度上，有助于提升某些机器学习算法的性能和稳定性。 Scikit-learn提供了一个简…
阅读更多...
一篇教会搭建ELK日志分析平台

一篇教会搭建ELK日志分析平台

日志分析的概述 日志分析是运维工程师解决系统故障，发现问题的主要手段日志主要包括系统日志、应用程序日志和安全日志系统运维和开发人员可以通过日志了解服务器软硬件信息、检查配置过程中的错误及错误发生的原因经常分析日志可以了解服务器的负荷，性…
阅读更多...
Date类型的字段序列化成JSON字符串

Date类型的字段序列化成JSON字符串

我们发现收到的响应结果里面有一个参数为： 我们收到的时间字符串格式是由JSON序列化框架来决定的。 spring将JAVA数据类型的序列和反序列化为JSON字符串是依赖jackson(com.fasterxml.jackson.core:jackson-core)库来实现的。 Date类型的字段在序列化成JSON字符串时…
阅读更多...
【人工智能】人工智能与机器学习的相关介绍

【人工智能】人工智能与机器学习的相关介绍

文章目录 人工智能的发展历程人工智能与机器学习关系图谱数据处理机器学习ML和深度学习DL的区别人工智能按照学习方式划分监督学习算法无监督学习算法总结 人工智能的发展历程 重要的时间点了解一下： 早在1950年人工智能就已经开始兴起 1997年deep blue战胜了人类国…
阅读更多...
天津美术学院2024级专升本新生开学报道须知

天津美术学院2024级专升本新生开学报道须知

天津美术学院2024级新生入学须知 亲爱的新同学： 祝贺你成为天津美术学院的新成员，开启新的求学历程！为方便新生入学，现将有关事宜通知如下： 一、报到安排 1.报到时间：2024年9月6日上午8：30—…
阅读更多...
MYSQL的引擎、清空数据的两种方式

MYSQL的引擎、清空数据的两种方式

目录 1.MYSQL引擎介绍 1.1MySQL的引擎作用： 1.2 MySQL的3类引擎 1.3 MyISAM和InnoDB的区别 1.4设定引擎 2. 清空数据有两种不同的方式 2.1 区别 1.MYSQL引擎介绍 MySQL有多种引擎，能执行create table、select等命令，在数据量不多时…
阅读更多...
二十九、MongoDB（1）

二十九、MongoDB（1）

🌻🌻 目录 一、MongoDB简介1.1 什么是 MongoDB1.2 MongoDB特点1.3 MongoDB 体系结构 二、下载与安装2.1 MongoDB下载2.2 在Linux 上的安装2.2.1 安装前的准备2.2.2 开始安装2.2.3 测试软链接启动 2.3 在windows上的安装 三、基本增删改查操作3.1 选择或创…
阅读更多...
lvs防火墙mark标记解决调度问题

lvs防火墙mark标记解决调度问题

实验环境是在之前部署DR模式集群的基础上做的，参考如下 部署DR模式集群 以http和https为例，当我们在webserver中同时开放80和443端口，那么默认控制是分开轮询的，就会出现了一个轮询错乱的问题： 当第一次访问80被轮询…
阅读更多...
浅谈基础的图算法——Tarjan求强联通分量算法（c++）

浅谈基础的图算法——Tarjan求强联通分量算法（c++）

文章目录 强联通分量SCC概念例子有向图的DFS树代码例题讲解[POI2008] BLO-Blockade题面翻译题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 思路AC代码 【模板】割点（割顶）题目背景题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 提示…
阅读更多...
【论文分享】测量城市夜间活力及其与城市空间结构的关系：一种数据驱动的方法

【论文分享】测量城市夜间活力及其与城市空间结构的关系：一种数据驱动的方法

近年来，夜间活力作为反映城市经济和生活质量的重要指标受到关注。本次我们给大家带来一篇SCI论文的全文翻译。该论文采用了数据驱动的方法来测量夜间活力，并探索了其与城市空间结构的关系。该论文派生的洞见可以帮助制定空间策略，以增强夜间活…
阅读更多...
微信小程序 - 自定义底部菜单栏

微信小程序 - 自定义底部菜单栏

微信小程序底部菜单栏是可以通过自定义来实现的。主要涉及：新建组件、编写组件代码、设置样式、配置导航栏、在页面中引用。自定义底部导航栏可以创建出符合项目设计需求效果，实现个性化的页面切换功能。 如下图效果，为比较常见的中间突出半圆…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023